Oracle连接数据库封装类

package com.jwgl.util;  

  

import java.sql.Connection;  

import java.sql.DriverManager;  

import java.sql.PreparedStatement;  

import java.sql.ResultSet;  

import java.sql.SQLException;  

import java.sql.Statement;  

  

  

/** 

 * 封装Oracle数据库常用操作 

 *  

 * @author 刘鹏 

 *  

 */  

public class DbUtil {  

    /** 

     * 取得Connection 

     *  

     * @return 

     */  

    public static final String DBDRIVER="oracle.jdbc.driver.OracleDriver";  

    public static final String DBURL="jdbc:oracle:thin:@127.0.0.1:1521:orcl";  

    public static final String DBUSER="kong";  

    public static final String DBPASS="kong";  

      

      

    public static Connection conn = null;  

    public static Statement pstm = null;  

    public static PreparedStatement pstmt = null;  

    public static ResultSet rs = null;  

      

      

    /** 

     * 取得数据库连接 

     * @return 

     */  

    public static Connection getConnection(){  

          

  

        try{  

            Class.forName(DBDRIVER);  

              

        }catch(ClassNotFoundException e){  

            e.printStackTrace();  

        }  

        try{  

            conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS);  

        }catch(SQLException e){  

            e.printStackTrace();  

        }  

        return conn;  

    }  

      

      

      

      

    /** 

     * 数据库操作Statement 

     * @return 

     */  

    public static Statement getStatement(Connection con){  

        //con = DbUtil.getConnection();  

        try {  

            if (con != null) {  

                pstm = con.createStatement();  

            }  

        } catch (SQLException e) {  

            // TODO Auto-generated catch block  

            e.printStackTrace();  

        }  

        return pstm;  

    }  

  

      

      

    /** 

     * 数据库操作PreparedStatement 

     * @return 

     */  

    public static PreparedStatement getPreparedStatement(Connection con,String sql) {  

        //con = DbUtil.getConnection();  

        if (con != null) {  

            try {  

                pstmt = conn.prepareStatement(sql);  

            } catch (SQLException e) {  

                  

                e.printStackTrace();  

            }  

        }  

        return pstmt;  

    }  

      

/*    此方法不需要写，会出现丢失In或者Out参数 

    public static ResultSet getResultSet(Connection conn,String sql){ 

        pstmt = DbUtil.getPreparedStatement(conn, sql); 

        try { 

            rs = pstmt.executeQuery(); 

        } catch (SQLException e) { 

             

            e.printStackTrace(); 

        } 

        return rs; 

    } 

*/    

      

    /** 

     * 关闭数据库连接 

     * @param conn 

     */  

    public static void close(Connection conn){  

        if(conn!=null){  

            try{  

                conn.close();  

            }catch(SQLException e){  

                e.printStackTrace();  

            }  

        }  

    }  

      

      

    /** 

     * 关闭数据库操作Statement 

     * @param stmt 

     */  

    public static void close(Statement stmt){  

        if(stmt!=null){  

            try{  

                stmt.close();  

            }catch(SQLException e){  

                e.printStackTrace();  

                }  

        }  

    }  

      

      

    /** 

     * 关闭数据库操作PreparedStatement 

     * @param pstmt 

     */  

    public static void close(PreparedStatement pstmt){  

        if(pstmt!=null){  

            try{  

                pstmt.close();  

            }catch(SQLException e){  

                e.printStackTrace();  

            }  

        }  

    }  

      

      

    /** 

     * 关闭数据库查询 

     * @param rs 

     */  

    public static void close(ResultSet rs){  

        if(rs!=null){  

            try{  

                rs.close();  

            }catch(SQLException e){  

                e.printStackTrace();  

            }  

        }  

    }  

      

      

    /** 

     * 主方法用于测试 

     * @param args 

     */  

    public static void main(String[] args) {  

          

        System.out.println(DbUtil.getConnection());  

    }  

  

}