JDBC连接数据库

  1. 云栖社区>
  2. 博客>
  3. 正文

JDBC连接数据库

tony~tian 2012-11-17 01:43:00 浏览919
展开阅读全文

 

一、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);
 }

}

 

 

 

网友评论

登录后评论
0/500
评论
tony~tian
+ 关注