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