JDBC基础知识（备忘）

          自从出来后，就很少用到了JDBC,大部分时间都是用框架的东西，对jdbc的知识也有些遗忘了。最近，换了项目组，接手了一个财务结算的子系统平台，因为这些对于数据的查询效率相对来说要严格点，底层的东西还相对于hibernate框架中封装好的机制来说还是是比较快的。正好有时间可以对jdbc的知识温习下。

一、JDBC的基本概念

数据库驱动也就是数据库厂商提供的jar包。sun公司为了降低学习数据库开发的成本，提供了JDBC这一套接口规范。

二、JDBC的基本使用

A.使用jdbc开发的步骤是固定的：

首先，要导入数据库驱动的jar包，然后按照下面的步骤

1.注册数据库驱动：

Class.forName("com.mysql.jdbc.Driver");

2.获取数据库连接：

Connection conn = DriverManager.getConnection(url,userName,passWord);

3.获取传输器：

Statement stat = conn.createStatement();//statement接口

创建向数据库发送sql的statement对象

OR

PrepareStatement ps = conn.perpareStatement(sql); //preparestatement接口

创建向数据库发送预编译sql的PrepareStatement对象

4.利用传输器执行sql语句获取结果集：

ResultSet rs = stat.executeQuery(sql);

用于向数据库发送查询语句

OR

int count = stat.executeUpdate(sql);

用于向数据库发送insert,update或delete语句

OR

stat.execute(sql);

用于向数据库发送任意sql语句

5.遍历结果集：

ResultSet：以表的样式在内存中保存了查询结果，其中还维护了一个游标，最开始的时候游标在第一行之前，每次调用因此next()方法就试图下移行，

如果移动成功返回true.

ResultSet提供了很多Get方法，用来获取查询结果中的不同类型的数据。

6.释放连接：

Connection是一个有限的资源，用完之后要立即释放掉

Statement/PrepareStatement占用内存，所以使用完后也要释放

ResultSet占用内存，所以使用之后也要释放掉

B.实例参考：

1.java工程的结构：



2.数据库配置文件：

driver=com.mysql.jdbc.Driver
userName=root
passWord=1234
url=jdbc:mysql://localhost:3306/jdbc

dao=com.jjyy.jdbc.dao.UserDao

3.Jdbc的简单的工具类

package com.jjyy.jdbc.utils;

import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
*
* @author JiangYu
*
*/
public class JDBCUtil {
private static Properties prop = null;
private static Connection conn= null;
static{
prop = new Properties();
try {
prop.load(new FileReader(JDBCUtil.class.getClassLoader().getResource("").getPath()));
} catch (Exception e) {
e.printStackTrace();
}
}
private JDBCUtil(){}

public static Connection getConnection() throws Exception{
Class.forName(prop.getProperty("driver"));
if(null==conn){
conn = DriverManager.getConnection(prop.getProperty("url"),prop.getProperty("userName"),prop.getProperty("passWord"));
}
return conn;
}

public static void close(Connection conn,Statement stat,ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
rs = null;
}
}
if(stat!=null){
try {
stat.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
stat = null;
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
conn = null;
}
}
}
}

4.DaoFactory

package com.jjyy.jdbc.factory;

import java.io.FileReader;
import java.util.Properties;

import com.jjyy.jdbc.dao.UserDao;
/**
*
* @author JiangYu
* 2015年3月28日
*
*/
public class DaoFactory {
private static Properties prop = null;

//	private static DaoFactory factory = new DaoFactory();
//
//	private DaoFactory(){};
//
//	public static DaoFactory getInstance(){
//		return factory;
//	}

private DaoFactory(){}

private  static  class DaoFactoryHolder{
private static final DaoFactory ENCE = new DaoFactory();
}

public static final DaoFactory getInstance(){
return DaoFactoryHolder.ENCE;
}
static{
prop = new Properties();
try {
prop.load(new FileReader(DaoFactory.class.getClassLoader().getResource("config.properties").getPath()));
} catch (Exception e) {
e.printStackTrace();
}
}

public UserDao getDao(){
Class clazz;
try {
clazz = Class.forName(prop.getProperty("dao"));
return (UserDao) clazz.newInstance();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}

5.UserDao接口的实现类

package com.jjyy.jdbc.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import com.jjyy.jdbc.dao.UserDao;
import com.jjyy.jdbc.entity.User;
import com.jjyy.jdbc.utils.JDBCUtil;
/**
*
* @author JiangYu
* 2015年3月28日
*
*/
public class UserDaoImpl implements UserDao {

@Override
public void add(User user) {
// TODO Auto-generated method stub

}

@Override
public User findByName(String userName) {
User user = new User();
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JDBCUtil.getConnection();
ps = conn.prepareStatement("select * from user where userName=?");
ps.setString(1, "jjyy");
rs = ps.executeQuery();
while(rs.next()){
user.setName(rs.getString("userName"));
user.setPassWord(rs.getString("passWord"));
user.setAge(rs.getInt("age"));
}
} catch (Exception e) {
e.printStackTrace();
}finally{
JDBCUtil.close(conn, ps, rs);
}
return user;
}

}

三、PrepareStatement和Statement的区别：

1.问题的引入：

Sql注入：用于jdbc程序在执行的过程中sql语句在拼装时，使用了有页面传入的参数，如果用户恶意传入一些sql中的特殊关键字，会导致sql语句意义发生改变，

这种攻击方式就是sql注入。

解决方式：由于PrepareStatement使用预编译机制，在创建PrepareStatement对象的时候就需要将sql语句传入，传入的过程中参数要用？替代，这个过程会导

致传入的sql被预编译，然后在调用PrepareStatement的setXXX将参数设置上去，由于sql语句已经经过了预编译，在传入的特殊值也只会当做特定位置的值传入

了，所以也就可以解决sql注入的问题。

2.PrepareStatement使用了预编译机制，相对于Statement来说，sql语句在执行的过程中效率要高，下面以执行批处理做实例：

【Statement】

package com.jjyy.jdbc.dao.impl;

import java.sql.Connection;
import java.sql.Statement;

import com.jjyy.jdbc.dao.StatBatchDao;
import com.jjyy.jdbc.utils.JDBCUtil;
/**
* statement 执行批处理时，可以执行任意类型的sql语句，但是它没有使用预编译，效率比较低
* @author JiangYu
*
*/
public class StatBatchDaoImpl implements StatBatchDao {

@Override
public void create() {
Connection conn = null;
Statement stat = null;
try {
conn = JDBCUtil.getConnection();
stat = conn.createStatement();
stat.addBatch("create database jjyy");
stat.addBatch("user jjyy");
stat.addBatch("create table user("
+ " id int(11) auto_increatement,"
+ " name varchar(20),"
+ " password varchar(30),"
+ " age int(11)"
+ ")");
stat.addBatch("insert into user values(1,jjyy,123,23)");
stat.executeBatch();
} catch (Exception e) {
e.printStackTrace();
}finally{
JDBCUtil.close(conn, stat, null);
}
}

}

【PrepareStatement】

<pre class="java" name="code">package com.jjyy.jdbc.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;

import com.jjyy.jdbc.dao.PsBatchDao;
import com.jjyy.jdbc.utils.JDBCUtil;
/**
* preparestatement 的批处理：
* 	优点：有预编译机制，效率比较高，执行多条结构相同，参数不同的sql时，不需要重复写sql的主干
*  缺点：只能执行主干相同的参数不同的sql,没有办法在一个批处理中加入结构不同的sql
* @author JiangYu
*
*/
public class PsBatchDaoImpl implements PsBatchDao{

@Override
public void create() {
Connection conn = null;
PreparedStatement ps = null;
try {
conn = JDBCUtil.getConnection();
ps = conn.prepareStatement("insert into user values(null,?,?,?)");

for(int i=0;i<=1000000;i++){
ps.setString(1, "name"+i);
ps.setString(2, "jjyy"+i);
ps.setInt(3, i);
ps.addBatch();

if(i%1000==0){
ps.executeBatch();
ps.clearBatch();
}
}
ps.executeBatch();

} catch (Exception e) {
e.printStackTrace();
}finally{
JDBCUtil.close(conn, ps, null);
}

}

}