一、JDBC的基本概念
1.1 JDBC是什么
JDBC (Java DataBase Connectivity) 是一组用于执行SQL语句的Java API,它由一组用Java语言编写的类和接口组成,可以为多种关系型数据库提供统一访问。他是一种标准,是由oracle公司制定的一套使用Java语言访问数据库的标准.
1.2 JDBC原理图
1.3 JDBC提供的常用接口和类
- DriverManager: 管理数据库驱动程序,用于建立数据库连接
- Driver: 提供给各个数据库厂商的接口,每一个数据库厂商要想可以使用Java语言来与他们的数据库进行通信,必须实现此接口.(主要处理与数据库服务器之间的通信)
- Connection: 此接口具有用于联系数据库的所有方法
- Statement: 从此接口创建的对象将SQL语句提交到数据库
- ResultSet: 在使用Statement对象执行SQL查询后,这个对象保存从数据库检索的数据
- SQLException: 处理数据库应用程序中发生的异常
- 7.PrepareStament:Statement的子类,具有预编译功能
二、JDBC入门应用
2.1statement的应用
- 如下代码示例
package part01;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.junit.Test;
public class TestDemo01 {
@Test
/**
* 查询数据的方法
* @throws ClassNotFoundException
* @throws SQLException
*/
public void queryData() throws ClassNotFoundException, SQLException{
Connection connection =null;
Statement statement =null;
ResultSet query =null;
//注册驱动
Class.forName("com.mysql.jdbc.Driver");
//获取连接对象
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/seven02","root", "4567");
//获取Statement对象
statement = connection.createStatement();
//创建sql语句
String sql ="SELECT co.CNO from score sc,course co WHERE sc.CNO=co.CNO AND sc.DEGREE>85";
//ִ执行sql语句获取结果集
query=statement.executeQuery(sql);
//遍历结果集
while(query.next()){
//获取对应列(字段)的值
String str = query.getString(1);
System.out.println(str);
}
}
}
查询一个用户(因为JDBC没有提供一个查询单个对象的结果集,所以查询单个对象时也是使用ResultSet对象,取集合中的一个对象即可)
2.2PrepareStatement的应用
2.2.1 两者之间的异同与联系
- 它是扩展了Statement的接口(PreparedStatement本身也是接口)
- 功能比Statement更强大
- 可以动态地提供/接受参数
- 创建PreparedStatement对象 --> conn.prepareStatement(通过Connection对象获取)
- 可以使用占位符(?)来进行数据绑定
- 通过stmt.setInt/String/...( , );绑定参数
- 示例代码
package part02;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import org.junit.Test;
public class JDBCTestdemo01 {
@Test
/**
* 增删改方法
* @throws Exception
*/
public void addData() throws Exception{
//注册驱动
Class.forName("com.mysql.jdbc.Driver");
//获取数据库连接对象
Connection connection = DriverManager.getConnection("jdbc:mysql:///seventest", "root", "4567");
//创建sql语句
String sql="INSERT INTO `USER` VALUES(NULL,?,?,?)";
//对sql语句进行预编译
PreparedStatement prestmt = connection.prepareStatement(sql);
//关闭数据事务自动提交
connection.setAutoCommit(false);
//绑定参数
prestmt.setString(1, "zs1eq146587");
prestmt.setString(2, "wqe220156486");
prestmt.setDate(3, new Date(System.currentTimeMillis()));
//自定义异常用于检验回滚操作
//int i=1/0;
//执行sql语句
int low = prestmt.executeUpdate();
//在事务提交之前主键已经生成,无论提交成功与否都会生成主键,事务提交不成功该对应主键就废掉了(这是数据库的机制,防止多线程下数据不安求安)
//手动提交事务,
connection.commit();
System.out.println(low);
//关闭资源
prestmt.close();
connection.close();
}
}
2.3、分页查询及中文乱码
- MYSQL数据库分页的语法
SELECT * FROM user LIMIT [offset],[max];
- 转换的公式:
- offset=(pageNo-1)*pageSize
MYSQL的SQL语句的语法格式带有两个参数分别是offset和max,而我们前端或者是客户端给后台发送过来的数据为pageNo(当前页)和pageSize(每页显示多少条数),而SQL语句里面的max和我们前端传送过来的pageSize是相同的都是为每页显示的条数。但是offset和pageNo不是相同的所以需要转换。
- 中文乱码
url:jdbc:mysql:///jdbc?characterEncoding=utf-8&useUnicode=true
三、JDBC事务处理
- 概念
jdbc默认情况下每执行完一条SQL就会提交到数据库一次,因为jdbc默认提交事务的方式是自动提交,但是在正常的业务逻辑下,一个业务正常要执行多条sql语句,如果每执行完一条sql都进行事务提交就很容易出现前后数据不一致的问题,所以要保证这一组的sql语句操作都在一个事务管理中,所以我们要取消JDBC的默认事务提交
- 方法
- 使用Connection对象的setAutoCommit()方法关闭他的自动提交
- 手动提交事务调用connection的commit()方法
- 事务回滚调用connection的rollback()方法
- 示例代码
详见其它标题下的示例代码
四、JDBC批量处理数据
- 使用JDBC进行批处理的两个对象及优缺点:
- Statement :Statement可以添加不同的SQL语句INSERT UPDATE DELETE可以同时进行批处理,但是效率相对较差
- PreparedStatement:PrepareStatement执行同一条SQL不同参数的SQL语句,但是效率相对较高
- Statement
①使用Statement对象批量添加要执行的SQL语句,事例如下:
statement.addBatch(sql1);
statement.addBatch(sql2);
statement.addBatch(sql3);
statement.addBatch(sql4);
②执行批处理SQL语句:statement.executeBatch();
③清除批处理命令:statement.clearBatch();
示例代码
Statement statement = connection.createStatement();
//批量准备SQL
String sql1="INSERT INTO user(user_name,price,create_time) VALUES('AA',12.12,NOW())";
String sql2="INSERT INTO user(user_name,price,create_time) VALUES('BB',13.12,NOW())";
String sql3="INSERT INTO user(user_name,price,create_time) VALUES('CC',14.12,NOW())";
String sql4="DELETE FROM user WHERE user_id=100";
//批量添加SQL
statement.addBatch(sql1);
statement.addBatch(sql2);
statement.addBatch(sql3);
statement.addBatch(sql4);
//批量执行
statement.executeBatch();
- PreparedStatement
String sql="INSERT INTO user(user_name,price,create_time) VALUES(?,?,?)";
PreparedStatement prepareStatement = connection.prepareStatement(sql);
//绑定参数1
prepareStatement.setString(1, "AA");
prepareStatement.setDouble(2, 12.12);
prepareStatement.setDate(2, new Date(new java.util.Date().getTime()));
prepareStatement.addBatch();
//绑定参数2
prepareStatement.setString(1, "BB");
prepareStatement.setDouble(2, 12.12);
prepareStatement.setDate(2, new Date(new java.util.Date().getTime()));
prepareStatement.addBatch();
//执行
prepareStatement.executeBatch();