JDBC连接数据库

一、JDBC数据库连接通用数据访问层（JDBCDBManager.java）

代码如下：

package com.myhome.dao;

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.sql.Statement;

/**
 * JDBC数据库连接通用数据访问层
 * */
public class JDBCDBManager {
// private static final String DRIVER_CLASS = "org.gjt.mm.mysql.Driver";
 //mySql驱动类的完全限定名和数据库连接字符串
 String mySqlDriverString="org.gjt.mm.mysql.Driver";
 String mySqlConnString="jdbc:mysql://localhost:3306/blog?user=root password=root";
 //sqlserver驱动类的完全限定名和数据库连接字符串
 String sqlserverDriverString="com.microsoft.jdbc.sqlserver.SQLServerDriver";
 String sqlserverConnString="jdbc:sqlserver://localhost:1433;DatabaseName=google_snack";
 //oracle驱动类的完全限定名和数据库连接字符串 （localhost为本地主机或ip地址如222.23.162.221）
 String oracleDriverString="oracle.jdbc.driver.OracleDriver";
 String oracleConnString="jdbc:oracle:thin:@localhost:1521:orcl";
 /**
  * 获取JDBC数据库访问连接对象
  * @throws ClassNotFoundException
  * @throws SQLException
  * */
 public Connection getConnection() throws ClassNotFoundException, SQLException{
  
// /*-------------------------mySql---------------------------------------*/
// //加载mySql数据库驱动类加载到内存中
// Class.forName(mySqlDriverString);
// //获取mySql数据库连接,通过驱动程序管理器DriverManager获取连接对象mySqlConn，mySqlConn连接的服务器和数据库信息在连接字符串中
// Connection mySqlConn=DriverManager.getConnection(mySqlConnString);
// //返回mySql连接
// return mySqlConn;
  
// /*------------------------sqlserver----------------------------------------*/
// //加载sqlserver数据库驱动类加载到内存中
// Class.forName(sqlserverDriverString);
// //获取sqlserver数据库连接，通过驱动程序管理器DriverManager获取连接对象sqlserverConn，sqlserverConn连接的服务器和数据库信息在连接字符串中
// Connection sqlserverConn=DriverManager.getConnection(sqlserverConnString,"sa","sa");
// //返回sqlserver连接
// return sqlserverConn;
  
 /*------------------------oracle----------------------------------------*/
 //加载oracle数据库驱动类加载到内存中
 Class.forName(oracleDriverString);
 //获取oracle数据库连接，通过驱动程序管理器DriverManager获取连接对象oracleConn，oracleConn连接的服务器和数据库信息在连接字符串中
 Connection oracleConn=DriverManager.getConnection(oracleConnString,"kekeai","kekeai123");
 //返回oracle连接
 return oracleConn;
 }
 /**
  * 为sql语句占位符参数赋值
  * @throws SQLException
  * */
 public void operateParameters(PreparedStatement pstmt,Object...args) throws SQLException{
  if(args!=null args.length 0){
   for (int i = 0; i args.length; i++) {
    //为sql语句的占位符  ？  赋值从1开始的
    pstmt.setObject(i + 1, args[i]);
   }
  }
 }
 /**
  * 释放数据库连接和操作占用的资源(注意关闭顺序)
  * @throws SQLException
  * */
 public void closeResource(Connection conn,PreparedStatement pstmt,ResultSet rs) throws SQLException{
  //关闭结果集
  if(rs!=null){
   rs.close();
   rs=null;
  }
  //关闭sql载体和执行对象
  if(pstmt!=null){
   pstmt.close();
   pstmt=null;
  }
  //关闭数据库连接对象
  if(conn!=null !conn.isClosed()){
   conn.close();
   conn=null;
  }
 }
 /**
  * 数据库数据更新（添加、删除、修改）
  * @throws Exception
  * */
 public int executeUpdate(String sql,Object...args) throws Exception{
  //数据库连接对象
  Connection conn=null;
  //发送sql语句到数据库（载体）并执行sql语句
   /* PreparedStatement可以防止sql注入，因此安全，并且性能更优越
    * Statement对象将sql语句发送到数据库后，数据库要做3件事，如下
    * 1分析语句
    * 2编译
    * 3执行
    * 而PreparedStatement将sql语句发送到数据库后第一次做如上3件事，以后只做第3件事，因此效率更好
    * */
  PreparedStatement pstmt=null;
  Statement stmt=null;
  //更新影响的数据库行数
  int rowCount=0;
  try {
   //获取数据库连接
   conn=getConnection();
   //分析、便宜、执行sql语句
   pstmt=conn.prepareStatement(sql);
   operateParameters(pstmt, args);
   //将sql语句发送到数据库中，并执行，rowCount是影响的行数  0表示成功 否则表示失败
   rowCount=pstmt.executeUpdate();
  } catch (Exception e) {
   //向控制台打印错误信息
   e.printStackTrace();
   //抛出自定义的异常
   throw new Exception("数据插入失败");
  }finally{
   //释放资源
   closeResource(conn, pstmt, null);
  }
  //返回影响行数
  return rowCount;
 }
 /**
  * 数据数据查询,返回ResultSet
  * 多条记录返回用list集合(在jndi中)
  * @throws Exception
  * */
 public ResultSet executeQuery(String sql,Object ... args) throws Exception{
  Connection conn = null;
  PreparedStatement pstmt = null;
  ResultSet rs = null;
  /*
  rs必须在数据库连通的情况下获取数据。 rs默认情况下，指向表头
  rs调用next()方法，表示向下移动一条记录，返回boolean值，true：有数据，false：没有数据
  rs同一时刻只能指向一条记录 rs下去就回不来
  String sql = "select id,username,age from " + tablename;
  rs只表示结果集中的数据，不能表示表头，表头例如：id,username,age，如果要取表头，需要使用ResultSetMetaData接口
   */
  conn = getConnection();
  pstmt = conn.prepareStatement(sql);
  operateParameters(pstmt, args);
  rs = pstmt.executeQuery();
  // 获取表的架构（即表结构信息，如列名称，列类型）信息,ResultSetMetaData专门获取表架构信息
  ResultSetMetaData rsm = rs.getMetaData();
  System.out.print(rsm.getColumnName(1));
  System.out.print("\t");
  System.out.print(rsm.getColumnName(2));
  System.out.print("\t");
  System.out.print(rsm.getColumnName(3));
  System.out.println();
  while (rs.next()) {
   System.out.print(rs.getString("username") + "\t");
   System.out.print(rs.getString("userpass") + "\t");
   System.out.print(rs.getString(3) + "\t");
   System.out.println("");
  }
  //返回数据库查询结果集（内存中）
  return rs;
 }
}

二、使用junit用例测试JDBCDBManager类

 Junit测试的java类：

junit测试类结构：

junit测试类代码：

package com.myhome.test;

import static org.junit.Assert.*;

import java.sql.Connection;

import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;

import com.myhome.dao.JDBCDBManager;

public class JDBCDBManagerTest {
 @BeforeClass
 public static void setUpBeforeClass() throws Exception {}
 @AfterClass
 public static void tearDownAfterClass() throws Exception {}
 @Before
 public void setUp() throws Exception {}
 @After
 public void tearDown() throws Exception {}
 @Test
 public void testExecuteUpdate() throws Exception {
  JDBCDBManager manager=new JDBCDBManager();
  Connection conn=manager.getConnection();
//  String sql="insert into users(username,userpass) values(?,?)";
//  Object [] args=new Object[]{"窗前明月光","地上鞋两双"};
//  manager.executeQuery(sql,args);
  String sql="insert into users(username,userpass) values(淡淡,蛋蛋)";
  manager.executeUpdate(sql);
 }
 @Test
 public void testExecuteQuery() throws Exception {
  JDBCDBManager manager=new JDBCDBManager();
  Connection conn=manager.getConnection();
  String sql="select * from users";
  manager.executeQuery(sql, null);
 }

}