Java 數據庫簡單操作類

 

數據庫操作類，將所有連接數據庫的配置信息以及基本的CRUD操作封裝在一個類里，方便項目里使用，將連接數據庫的基本信息放在配置文件 "dbinfo.properties" 中，通過類加載器調用(也可以通過ServletContext調用配置文件，或者配置在web.xml里通過ServletConfig調用)，需要修改數據庫連接信息時，只需修改配置文件即可。

　　

package com.latiny.db;

import java.io.*;
import java.sql.*;
import java.util.ArrayList;
import java.util.Properties;

/*
 * 數據庫操作類
 */

public class DBUtil {

    //定義需要的變量
    private static String driver =null;
    private static String url =null;
    private static String user=null;
    private static String password=null;
    
    private static Connection conn;
    //使用PreparedStatment可以防止sql注入
    private static PreparedStatement ps;
    private static ResultSet rs;
    private static CallableStatement cs;
    
    //讀配置文件
    private static Properties pp=null;
    private static InputStream fis=null;
    
    
    //加載驅動，只需要執行一次
    static
    {
        try
        {
            pp = new Properties();
            
            //當我們使用java web的時候，讀取文件要使用類加載器
            fis = DBUtil.class.getClassLoader().getResourceAsStream("dbinfo.properties");
            
            pp.load(fis);
            driver = pp.getProperty("DRIVER");
            url = pp.getProperty("URL");
            user = pp.getProperty("USER");
            password = pp.getProperty("PASSWORD");
            
            // 1 加載驅動
            Class.forName(driver);
            
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            try 
            {
                fis.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            fis = null;
        }
    }
    
    /*
     * 獲取Connection連接
     */
    public static Connection getConn()
    {
        try 
        {
            // 2 獲取數據庫連接
            conn = DriverManager.getConnection(url, user, password);
        } 
        catch (SQLException e) 
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        return conn;
    }
    
    /*
     * 直接返回rs結果，此方法不能關閉rs，因為后面調用它的類還會用到，如果關閉則不能正常使用
     */
    public static ResultSet queryResult(String sql, String[] parameters)
    {
        try 
        {
            conn = getConn();
            // 3 創建Statement對象
            ps = conn.prepareStatement(sql);
            // 4 給問號賦值，即給sql語句的條件參數賦值如果需要的話
            if(parameters!=null)
            {
                for(int i=1; i<=parameters.length; i++)
                {
                    ps.setString(i, parameters[i-1]);
                }
            }
            
            // 5 執行sql獲取返回結果
            rs = ps.executeQuery();
        } 
        catch (SQLException e) 
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return rs;    
    }
    
    /*
     * 將rs結果封裝成ArrayList，然后可以關閉rs，節省數據庫訪問資源
     */
    public static ArrayList queryResult2(String sql, String[] parameters)
    {
        ArrayList al = new ArrayList();
        
        try 
        {
            //2 獲取數據庫連接
            conn = getConn();
            //3 創建Statement對象
            ps = conn.prepareStatement(sql);
            //4  給問號賦值，即給sql語句的條件參數賦值如果需要的話
            if(parameters!=null)
            {
                for(int i=1; i<=parameters.length; i++)
                {
                    ps.setString(i, parameters[i-1]);
                }
            }
            
            //5 執行sql語句獲取返回結果
            rs = ps.executeQuery();
            
            //獲取rs的結構
            ResultSetMetaData rsmd = rs.getMetaData();
            //獲取查詢語句的列數
            int column = rsmd.getColumnCount();
            
            while(rs.next())
            {
                //對象數組，存儲一行數據
                Object[] objs = new Object[column];
                for(int i=0; i<objs.length; i++)
                {
                    objs[i] = rs.getObject(i+1);
                }
                al.add(objs);
            }
            
        } 
        catch (SQLException e) 
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally
        {
            //關閉資源
            close(rs, ps, conn);
        }

        return al;    
    }

    //調用存儲過程，帶輸入輸出參數的
    public static CallableStatement callProcedure(String sql, String[] inputPara, Integer[] outputPara)
    {
        
        try 
        {
            conn = getConn();
            cs = conn.prepareCall(sql);
            for(int i=0; inputPara!=null && i<inputPara.length; i++)
            {
                cs.setObject(i+1, inputPara[i]);
            }
            
            //給output參數賦值
            for(int j=0; outputPara!=null && j<outputPara.length; j++)
            {
                cs.registerOutParameter(inputPara.length+1+j, outputPara[j]);
            }
            
            cs.execute();
            
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally
        {
            close(rs, ps, conn);
        }
        
        return cs;
        
    }
    
    //update, insert, delete
    public static Integer updateData(String sql, String[] parameters)
    {
        int result = 0;
        try
        {
            conn = getConn();
            ps = conn.prepareStatement(sql);
            if(parameters!=null)
            {
                for(int i=0; i<parameters.length; i++)
                {
                    ps.setObject(i+1, parameters[i]);
                }
            }
            
            //執行executeUpdate並且返回受影響的行數
            result = ps.executeUpdate();
            
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            close(rs, ps, conn);
        }
        
        return result;
    }
    
    //關閉對應的數據庫連接資源
    public static void close(ResultSet rs1, PreparedStatement ps1, Connection conn1)
    {

        try 
        {
            if(rs1!=null)
            {
                rs1.close();
            }
            if(ps1!=null)
            {
                ps1.close();
            }
            if(conn1!=null)
            {
                conn1.close();
            }
            
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}

 

 

dbinfo.properties文件配置信息

DRIVER=com.mysql.jdbc.Driver
URL=jdbc:mysql://localhost:3306/servlet
USER=latiny
PASSWORD=123456