java数据库开发之JDBC的完整封装兼容多种数据库

目前此代码我只用过mysql和oracle数据库测试过，但相信其它数据库都是可以的，只要导入你需要操作的数据库jar包，驱动等就可，下面上代码：

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 对jdbc的完整封装
 *
 */
public class JDBCUtil {

	private static String driver = null;
	private static String url = null;
	private static String username = null;
	private static String password = null;

	private CallableStatement callableStatement = null;//创建CallableStatement对象
	private Connection conn = null;
	private PreparedStatement pst = null;
	private ResultSet rst = null;

/*	static {
    try {
      // 加载数据库驱动程序
      Class.forName(driver);
    } catch (ClassNotFoundException e) {
      System.out.println("加载驱动错误");
      System.out.println(e.getMessage());
    }
  } */  

	public JDBCUtil(String driver,String url ,String username,String password) {
		this.driver = driver;
		this.url = url;
		this.username = username;
		this.password = password;
	}

  /**
   * 建立数据库连接
   * @return 数据库连接
   */
  public Connection getConnection() {
    try {
    	 // 加载数据库驱动程序
      try {
				Class.forName(driver);
			} catch (ClassNotFoundException e) {
				System.out.println("加载驱动错误");
	      System.out.println(e.getMessage());
				e.printStackTrace();
			}
      // 获取连接
    	conn = DriverManager.getConnection(url, username,
    			password);
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }
    return conn;
  }  

  /**
   * insert update delete SQL语句的执行的统一方法
   * @param sql SQL语句
   * @param params 参数数组，若没有参数则为null
   * @return 受影响的行数
   */
  public int executeUpdate(String sql, Object[] params) {
    // 受影响的行数
    int affectedLine = 0;  

    try {
      // 获得连接
      conn = this.getConnection();
      // 调用SQL
      pst = conn.prepareStatement(sql);  

      // 参数赋值
      if (params != null) {
        for (int i = 0; i < params.length; i++) {
        	pst.setObject(i + 1, params[i]);
        }
      }
      /*在此 PreparedStatement 对象中执行 SQL 语句，
                     该语句必须是一个 SQL 数据操作语言（Data Manipulation Language，DML）语句，比如 INSERT、UPDATE 或 DELETE
                     语句；或者是无返回内容的 SQL 语句，比如 DDL 语句。  */
      // 执行
      affectedLine = pst.executeUpdate();

    } catch (SQLException e) {
      System.out.println(e.getMessage());
    } finally {
      // 释放资源
      closeAll();
    }
    return affectedLine;
  }  

  /**
   * SQL 查询将查询结果直接放入ResultSet中
   * @param sql SQL语句
   * @param params 参数数组，若没有参数则为null
   * @return 结果集
   */
  private ResultSet executeQueryRS(String sql, Object[] params) {
    try {
      // 获得连接
      conn = this.getConnection();  

      // 调用SQL
      pst = conn.prepareStatement(sql);  

      // 参数赋值
      if (params != null) {
        for (int i = 0; i < params.length; i++) {
        	pst.setObject(i + 1, params[i]);
        }
      }  

      // 执行
      rst = pst.executeQuery();  

    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }   

    return rst;
  }  

  /**
   * SQL 查询将查询结果：一行一列
   * @param sql SQL语句
   * @param params 参数数组，若没有参数则为null
   * @return 结果集
   */
  public Object executeQuerySingle(String sql, Object[] params) {
    Object object = null;
    try {
      // 获得连接
      conn = this.getConnection();  

      // 调用SQL
      pst = conn.prepareStatement(sql);  

      // 参数赋值
      if (params != null) {
        for (int i = 0; i < params.length; i++) {
        	pst.setObject(i + 1, params[i]);
        }
      }  

      // 执行
      rst = pst.executeQuery();  

      if(rst.next()) {
        object = rst.getObject(1);
      }  

    } catch (SQLException e) {
      System.out.println(e.getMessage());
    } finally {
      closeAll();
    }  

    return object;
  }  

  /**
   * 获取结果集，并将结果放在List中
   *
   * @param sql SQL语句
   *     params 参数，没有则为null
   * @return List
   *            结果集
   */
  public List<Object> excuteQuery(String sql, Object[] params) {
    // 执行SQL获得结果集
    ResultSet rs = executeQueryRS(sql, params);  

    // 创建ResultSetMetaData对象
    ResultSetMetaData rsmd = null;  

    // 结果集列数
    int columnCount = 0;
    try {
      rsmd = rs.getMetaData();  

      // 获得结果集列数
      columnCount = rsmd.getColumnCount();
    } catch (SQLException e1) {
      System.out.println(e1.getMessage());
    }  

    // 创建List
    List<Object> list = new ArrayList<Object>();  

    try {
      // 将ResultSet的结果保存到List中
      while (rs.next()) {
        Map<String, Object> map = new HashMap<String, Object>();
        for (int i = 1; i <= columnCount; i++) {
          map.put(rsmd.getColumnLabel(i), rs.getObject(i));
        }
        list.add(map);//每一个map代表一条记录，把所有记录存在list中
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    } finally {
      // 关闭所有资源
      closeAll();
    }  

    return list;
  }  

  /**
   * 存储过程带有一个输出参数的方法
   * @param sql 存储过程语句
   * @param params 参数数组
   * @param outParamPos 输出参数位置
   * @param SqlType 输出参数类型
   * @return 输出参数的值
   */
  public Object excuteQuery(String sql, Object[] params,int outParamPos, int SqlType) {
    Object object = null;
    conn = this.getConnection();
    try {
      // 调用存储过程
    	// prepareCall:创建一个 CallableStatement 对象来调用数据库存储过程。
      callableStatement = conn.prepareCall(sql);  

      // 给参数赋值
      if(params != null) {
        for(int i = 0; i < params.length; i++) {
          callableStatement.setObject(i + 1, params[i]);
        }
      }  

      // 注册输出参数
      callableStatement.registerOutParameter(outParamPos, SqlType);  

      // 执行
      callableStatement.execute();  

      // 得到输出参数
      object = callableStatement.getObject(outParamPos);  

    } catch (SQLException e) {
      System.out.println(e.getMessage());
    } finally {
      // 释放资源
      closeAll();
    }  

    return object;
  }  

  /**
   * 关闭所有资源
   */
  private void closeAll() {
    // 关闭结果集对象
    if (rst != null) {
      try {
        rst.close();
      } catch (SQLException e) {
        System.out.println(e.getMessage());
      }
    }  

    // 关闭PreparedStatement对象
    if (pst != null) {
      try {
        pst.close();
      } catch (SQLException e) {
        System.out.println(e.getMessage());
      }
    }  

    // 关闭CallableStatement 对象
    if (callableStatement != null) {
      try {
        callableStatement.close();
      } catch (SQLException e) {
        System.out.println(e.getMessage());
      }
    }  

    // 关闭Connection 对象
    if (conn != null) {
      try {
        conn.close();
      } catch (SQLException e) {
        System.out.println(e.getMessage());
      }
    }
  }
}

使用的时候直接new一个JDBCUtil类，然后对传入对应的sql语句，例：

public class JDBCTest {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		JDBCUtil jdbcUtil = new JDBCUtil("com.mysql.jdbc.Driver",
		"jdbc:mysql://localhost:3306/myhelp?useUnicode=true&characterEncoding=utf-8&useSSL=false","root","142014068");
		String sql = "delete from menu_detial where count=6";
		System.out.println(jdbcUtil.executeUpdate(sql, null));
	}
}

更多关于java数据库开发的文章请查看下面的相关链接