JAVA 基础知识学习20

01JDBC概念和数据库驱动程序

* A: JDBC概念和数据库驱动程序
* a: JDBC概述
* JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，
可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范
* JDBC提供了一种基准,据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。
* JDBC需要连接驱动，驱动是两个设备要进行通信，满足一定通信数据格式，数据格式由设备提供商规定，
设备提供商为设备提供驱动软件，通过软件可以与该设备进行通信。
* 我们使用的是mysql的驱动mysql-connector-java-5.1.39-bin.jar
* b: 总结
* JDBC是java提供给开发人员的一套操作数据库的接口
* 数据库驱动就是实现该接口的实现类

02JDBC原理

* A: JDBC原理
* a: 描述
* Java提供访问数据库规范称为JDBC，而生产厂商提供规范的实现类称为驱动
* DBC是接口，驱动是接口的实现，没有驱动将无法完成数据库连接，从而不能操作数据库！
每个数据库厂商都需要提供自己的驱动，用来连接自己公司的数据库，也就是说驱动一般都由数据库生成厂商提供。
* 图解见day29_source/JDBC实现原理.JPG

03准备数据

* A: 准备数据
* a: 创建数据库和表结构
#创建数据库
create database mybase;
#使用数据库
use mybase;
###创建分类表
create table sort(
sid int PRIMARY KEY AUTO_INCREMENT,
sname varchar(100),
sprice DOUBLE,
sdesc VARCHAR(500)
);

* b: 向表中插入数据
#初始化数据
insert into sort(sname,sprice,sdesc) values('家电',2000, '优惠的促销');
insert into sort(sname,sprice,sdesc) values('家具',8900, '家具价格上调,原材料涨价');
insert into sort(sname,sprice,sdesc) values('儿童玩具',290, '赚家长的钱');
insert into sort(sname,sprice,sdesc) values('生鲜',500.99, '生鲜商品');
insert into sort(sname,sprice,sdesc) values('服装',24000, '换季销售');
insert into sort(sname,sprice,sdesc) values('洗涤',50, '洗发水促销');

04JDBC的开发步骤

* A: JDBC的开发步骤
* a: 步骤介绍
1.注册驱动
告知JVM使用的是哪一个数据库的驱动
2.获得连接
使用JDBC中的类,完成对MySQL数据库的连接
3.获得语句执行平台
通过连接对象获取对SQL语句的执行者对象
4.执行sql语句
使用执行者对象,向数据库执行SQL语句
获取到数据库的执行后的结果
5.处理结果
6.释放资源  一堆close()

05导入mysql数据库驱动程序jar包

* A: 导入mysql数据库驱动程序jar包
* a: 步骤
* 创建lib目录，用于存放当前项目需要的所有jar包
* 选择jar包，右键执行build path / Add to Build Path

06注册数据库驱动程序

* A: 注册数据库驱动程序
* a: 案例代码

public class JDBCDemo {
public static void main(String[] args)throws ClassNotFoundException,SQLException{
//1.注册驱动 反射技术,将驱动类加入到内容
// 使用java.sql.DriverManager类静态方法 registerDriver(Driver driver)
// Diver是一个接口,参数传递,MySQL驱动程序中的实现类
//DriverManager.registerDriver(new Driver());
//驱动类源代码,注册2次驱动程序
Class.forName("com.mysql.jdbc.Driver");
}
}

07获取数据库的连接对象

* A：获取数据库的连接对象
* a: 案例代码

public class JDBCDemo {
public static void main(String[] args)throws ClassNotFoundException,SQLException{
//1.注册驱动 反射技术,将驱动类加入到内容
// 使用java.sql.DriverManager类静态方法 registerDriver(Driver driver)
// Diver是一个接口,参数传递,MySQL驱动程序中的实现类
//DriverManager.registerDriver(new Driver());
//驱动类源代码,注册2次驱动程序
Class.forName("com.mysql.jdbc.Driver");

//2.获得数据库连接  DriverManager类中静态方法
//static Connection getConnection(String url, String user, String password)
//返回值是Connection接口的实现类,在mysql驱动程序
//url: 数据库地址  jdbc:mysql://连接主机IP:端口号//数据库名字
String url = "jdbc:mysql://localhost:3296/mybase";
//用户名和密码用自己的
String username="root";
String password="123";
Connection con = DriverManager.getConnection(url, username, password);
System.out.println(con);
}
}

08获取SQL语句的执行对象对象

* A: 获取SQL语句的执行对象对象
* a: 案例代码

public class JDBCDemo {
public static void main(String[] args)throws ClassNotFoundException,SQLException{
//1.注册驱动 反射技术,将驱动类加入到内容
// 使用java.sql.DriverManager类静态方法 registerDriver(Driver driver)
// Diver是一个接口,参数传递,MySQL驱动程序中的实现类
//DriverManager.registerDriver(new Driver());
//驱动类源代码,注册2次驱动程序
Class.forName("com.mysql.jdbc.Driver");

//2.获得数据库连接  DriverManager类中静态方法
//static Connection getConnection(String url, String user, String password)
//返回值是Connection接口的实现类,在mysql驱动程序
//url: 数据库地址  jdbc:mysql://连接主机IP:端口号//数据库名字
String url = "jdbc:mysql://localhost:3296/mybase";
String username="root";
String password="123";
Connection con = DriverManager.getConnection(url, username, password);

//3.获得语句执行平台, 通过数据库连接对象,获取到SQL语句的执行者对象
// con对象调用方法   Statement createStatement() 获取Statement对象,将SQL语句发送到数据库
// 返回值是 Statement接口的实现类对象,,在mysql驱动程序
Statement stat = con.createStatement();
System.out.println(stat);
}
}

09执行insert语句获取结果集

* A: 执行insert语句获取结果集
* a: 案例代码

public class JDBCDemo {
public static void main(String[] args)throws ClassNotFoundException,SQLException{
//1.注册驱动 反射技术,将驱动类加入到内容
// 使用java.sql.DriverManager类静态方法 registerDriver(Driver driver)
// Diver是一个接口,参数传递,MySQL驱动程序中的实现类
//DriverManager.registerDriver(new Driver());
//驱动类源代码,注册2次驱动程序
Class.forName("com.mysql.jdbc.Driver");

//2.获得数据库连接  DriverManager类中静态方法
//static Connection getConnection(String url, String user, String password)
//返回值是Connection接口的实现类,在mysql驱动程序
//url: 数据库地址  jdbc:mysql://连接主机IP:端口号//数据库名字
String url = "jdbc:mysql://localhost:3296/mybase";
String username="root";
String password="123";
Connection con = DriverManager.getConnection(url, username, password);

//3.获得语句执行平台, 通过数据库连接对象,获取到SQL语句的执行者对象
// con对象调用方法   Statement createStatement() 获取Statement对象,将SQL语句发送到数据库
// 返回值是 Statement接口的实现类对象,,在mysql驱动程序
Statement stat = con.createStatement();
//  4.执行sql语句
// 通过执行者对象调用方法执行SQL语句,获取结果
// int executeUpdate(String sql)  执行数据库中的SQL语句, insert delete update
// 返回值int,操作成功数据表多少行
int row = stat.executeUpdate
("INSERT INTO sort(sname,sprice,sdesc) VALUES('汽车用品',50000,'疯狂涨价')");
System.out.println(row);

//6.释放资源  一堆close()
stat.close();
con.close();
}
}

10执行select语句获取结果集

* A: 执行select语句获取结果集
* a: 案例代码

public class JDBCDemo1 {
public static void main(String[] args) throws Exception{
//1. 注册驱动
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接对象
String url = "jdbc:mysql://localhost:3296/mybase";
String username="root";
String password="123";
Connection con = DriverManager.getConnection(url, username, password);
//3 .获取执行SQL 语句对象
Statement stat = con.createStatement();
// 拼写查询的SQL
String sql = "SELECT * FROM sort";
//4. 调用执行者对象方法,执行SQL语句获取结果集
// ResultSet executeQuery(String sql)  执行SQL语句中的select查询
// 返回值ResultSet接口的实现类对象,实现类在mysql驱动中
ResultSet rs = stat.executeQuery(sql);
//5 .处理结果集
// ResultSet接口方法 boolean next() 返回true,有结果集,返回false没有结果集
while(rs.next()){
//获取每列数据,使用是ResultSet接口的方法 getXX方法参数中,建议写String列名
System.out.println(rs.getInt("sid")+"   "+rs.getString("sname")+
"   "+rs.getDouble("sprice")+"   "+rs.getString("sdesc"));
}

rs.close();
stat.close();
con.close();
}
}

11SQL注入攻击

* A: SQL注入攻击
* a: 注入问题
* 假设有登录案例SQL语句如下:
* SELECT * FROM 用户表 WHERE NAME = 用户输入的用户名 AND PASSWORD = 用户输的密码;
* 此时，当用户输入正确的账号与密码后，查询到了信息则让用户登录。
但是当用户输入的账号为XXX 密码为：XXX’  OR ‘a’=’a时，则真正执行的代码变为：
* SELECT * FROM 用户表 WHERE NAME = ‘XXX’ AND PASSWORD =’ XXX’  OR ’a’=’a’;
* 此时，上述查询语句时永远可以查询出结果的。那么用户就直接登录成功了，显然我们不希望看到这样的结果，这便是SQL注入问题。
* b: 案例演示

CREATE TABLE users(
id INT PRIMARY KEY AUTO_INCREMENT,
username VARCHAR(100),
PASSWORD VARCHAR(100)
);

INSERT INTO users (username,PASSWORD) VALUES ('a','1'),('b','2');

SELECT * FROM users;

-- 登录查询
SELECT * FROM users WHERE username='dsfsdfd' AND PASSWORD='wrethiyu'1
OR 1=1

SELECT * FROM users WHERE username='a' AND PASSWORD='1'OR'1=1'
键盘录入：
1
1'OR' 1=1

12SQL注入攻击用户登录案例

* A: SQL注入攻击用户登录案例
* a: 案例代码

public class JDBCDemo2 {
public static void main(String[] args)throws Exception {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3296/mybase";
String username = "root";
String password = "123";
Connection con = DriverManager.getConnection(url, username, password);
Statement stat = con.createStatement();

Scanner sc = new Scanner(System.in);
String user = sc.nextLine();
String pass = sc.nextLine();

//执行SQL语句,数据表,查询用户名和密码,如果存在,登录成功,不存在登录失败
//      String sql = "SELECT * FROM users WHERE username='dsfsdfd' AND PASSWORD='wrethiyu' OR 1=1";
String sql = "SELECT * FROM users WHERE username='"+user+"' AND PASSWORD='"+pass+"'";
System.out.println(sql);
ResultSet rs = stat.executeQuery(sql);
while(rs.next()){
System.out.println(rs.getString("username")+"   "+rs.getString("password"));
}

rs.close();
stat.close();
con.close();
}
}

13PrepareStatement接口预编译SQL语句

* A: PrepareStatement接口预编译SQL语句
* a: 预处理对象
* 使用PreparedStatement预处理对象时，建议每条sql语句所有的实际参数，都使用逗号分隔。
* String sql = "insert into sort(sid,sname) values(?,?)";;
* PreparedStatement预处理对象代码：
* PreparedStatement psmt = conn.prepareStatement(sql)

* b: 执行SQL语句的方法介绍
* int executeUpdate(); --执行insert update delete语句.
* ResultSet executeQuery(); --执行select语句.
* boolean execute(); --执行select返回true 执行其他的语句返回false.
* c: 设置实际参数
* void setXxx(int index, Xxx xx) 将指定参数设置为给定Java的xx值。在将此值发送到数据库时，驱动程序将它转换成一个 SQL Xxx类型值。
* 例如：
* setString(2, "家用电器") 把SQL语句中第2个位置的占位符？ 替换成实际参数 "家用电器"
* d: 案例代码

/*
*  Java程序实现用户登录,用户名和密码,数据库检查
*  防止注入攻击
*  Statement接口实现类,作用执行SQL语句,返回结果集
*  有一个子接口PreparedStatement  (SQL预编译存储,多次高效的执行SQL)
*  PreparedStatement的实现类数据库的驱动中,如何获取接口的实现类
*
*  是Connection数据库连接对象的方法
*  PreparedStatement prepareStatement(String sql)

*/
public class JDBCDemo3 {
public static void main(String[] args)throws Exception {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3296/mybase";
String username = "root";
String password = "123";
Connection con = DriverManager.getConnection(url, username, password);
Scanner sc = new Scanner(System.in);
String user = sc.nextLine();
String pass = sc.nextLine();

//执行SQL语句,数据表,查询用户名和密码,如果存在,登录成功,不存在登录失败
String sql = "SELECT * FROM users WHERE username=? AND PASSWORD=?";
//调用Connection接口的方法prepareStatement,获取PrepareStatement接口的实现类
//方法中参数,SQL语句中的参数全部采用问号占位符
PreparedStatement pst =  con.prepareStatement(sql);
System.out.println(pst);
//调用pst对象set方法,设置问号占位符上的参数
pst.setObject(1, user);
pst.setObject(2, pass);

//调用方法,执行SQL,获取结果集
ResultSet rs = pst.executeQuery();
while(rs.next()){
System.out.println(rs.getString("username")+"   "+rs.getString("password"));
}

rs.close();
pst.close();
con.close();
}
}

14PrepareStatement接口预编译SQL语句执行修改

* A: PrepareStatement接口预编译SQL语句执行修改
* 案例代码

/*
*  使用PrepareStatement接口,实现数据表的更新操作
*/
public class JDBCDemo {
public static void main(String[] args) throws Exception{
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3296/mybase";
String username="root";
String password="123";
Connection con = DriverManager.getConnection(url, username, password);

//拼写修改的SQL语句,参数采用?占位
String sql = "UPDATE sort SET sname=?,sprice=? WHERE sid=?";
//调用数据库连接对象con的方法prepareStatement获取SQL语句的预编译对象
PreparedStatement pst = con.prepareStatement(sql);
//调用pst的方法setXXX设置?占位
pst.setObject(1, "汽车美容");
pst.setObject(2, 49988);
pst.setObject(3, 7);
//调用pst方法执行SQL语句
pst.executeUpdate();

pst.close();
con.close();
}
}

###15PrepareStatement接口预编译SQL语句执行查询
* A: PrepareStatement接口预编译SQL语句执行查询
* a: 案例代码
/*
*  PrepareStatement接口实现数据表的查询操作
*/
public class JDBCDemo1 {
public static void main(String[] args) throws Exception{
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3296/mybase";
String username="root";
String password="123";
Connection con = DriverManager.getConnection(url, username, password);

String sql = "SELECT * FROM sort";

PreparedStatement pst = con.prepareStatement(sql);

//调用pst对象的方法,执行查询语句,Select
ResultSet rs=pst.executeQuery();
while(rs.next()){
System.out.println(rs.getString("sid")+"  "+rs.getString("sname")+"  "+rs.getString("sprice")+"  "+rs.getString("sdesc"));
}
rs.close();
pst.close();
con.close();
}
}

16JDBC的工具类和测试

* A: JDBC的工具类和测试
* a: 案例代码

//JDBCUtils工具类代码
public class JDBCUtils {
private JDBCUtils(){}
private static Connection con ;

static{
try{
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3296/mybase";
String username="root";
String password="123";
con = DriverManager.getConnection(url, username, password);
}catch(Exception ex){
throw new RuntimeException(ex+"数据库连接失败");
}
}

/*
* 定义静态方法,返回数据库的连接对象
*/
public static Connection getConnection(){
return con;
}

public static void close(Connection con,Statement stat){

if(stat!=null){
try{
stat.close();
}catch(SQLException ex){}
}

if(con!=null){
try{
con.close();
}catch(SQLException ex){}
}

}

public static void close(Connection con,Statement stat , ResultSet rs){
if(rs!=null){
try{
rs.close();
}catch(SQLException ex){}
}

if(stat!=null){
try{
stat.close();
}catch(SQLException ex){}
}

if(con!=null){
try{
con.close();
}catch(SQLException ex){}
}

}
}
//测试JDBCUtils工具类的代码
public class TestJDBCUtils {
public static void main(String[] args)throws Exception {
Connection con = JDBCUtils.getConnection();
PreparedStatement pst = con.prepareStatement("SELECT sname FROM sort");
ResultSet rs = pst.executeQuery();
while(rs.next()){
System.out.println(rs.getString("sname"));
}
JDBCUtils.close(con, pst, rs);
}
}

17数据表数据存储对象

* A: 数据表数据存储对象
* a: 准备工作
* 导入jar包
* 拷贝day32定义的工具类JDBCUtils

* b: 案例代码
//定义实体类Sort

public class Sort {
private int sid;
private String sname;
private double sprice;
private String sdesc;
public Sort(int sid, String sname, double sprice, String sdesc) {
this.sid = sid;
this.sname = sname;
this.sprice = sprice;
this.sdesc = sdesc;
}
public Sort(){}
public int getSid() {
return sid;
}
public void setSid(int sid) {
this.sid = sid;
}
public String getSname() {
return sname;
}
public void setSname(String sname) {
this.sname = sname;
}
public double getSprice() {
return sprice;
}
public void setSprice(double sprice) {
this.sprice = sprice;
}
public String getSdesc() {
return sdesc;
}
public void setSdesc(String sdesc) {
this.sdesc = sdesc;
}
@Override
public String toString() {
return "Sort [sid=" + sid + ", sname=" + sname + ", sprice=" + sprice + ", sdesc=" + sdesc + "]";
}
}

/*
*  JDBC读取数据表sort,每行数据封装到Sort类的对象中
*  很多个Sort类对象,存储到List集合中
*/
public class JDBCDemo {
public static void main(String[] args) throws Exception{
//使用JDBC工具类,直接获取数据库连接对象
Connection con = JDBCUtils.getConnection();
//连接获取数据库SQL语句执行者对象
PreparedStatement pst = con.prepareStatement("SELECT * FROM sort");
//调用查询方法,获取结果集
ResultSet rs = pst.executeQuery();
//创建集合对象
List<Sort> list = new ArrayList<Sort>();
while(rs.next()){
//获取到每个列数据,封装到Sort对象中
Sort s = new Sort(rs.getInt("sid"),rs.getString("sname"),rs.getDouble("sprice"),rs.getString("sdesc"));
//封装的Sort对象,存储到集合中
list.add(s);
}
JDBCUtils.close(con, pst, rs);
//遍历List集合
for(Sort s : list){
System.out.println(s);
}
}
}

18properties配置文件

* A: properties配置文件
* a: 相关介绍
* 开发中获得连接的4个参数（驱动、URL、用户名、密码）通常都存在配置文件中，方便后期维护，程序如果需要更换数据库，
只需要修改配置文件即可。
* 通常情况下，我们习惯使用properties文件，此文件我们将做如下要求：
1.  文件位置：任意，建议src下
2.  文件名称：任意，扩展名为properties
3.  文件内容：一行一组数据，格式是“key=value”.
a)  key命名自定义，如果是多个单词，习惯使用点分隔。例如：jdbc.driver
b)  value值不支持中文，如果需要使用非英文字符，将进行unicode转换。

19properties文件的创建和编写

* A: properties文件的创建和编写
* a: properties文件的创建
* src路径下建立database.properties(其实就是一个文本文件)
* b: properties文件的编写(内容如下)
driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3296/mybase
username=root
password=123

20加载配置文件

* A: 加载配置文件
* a: 案例代码

/*
*  加载properties配置文件
*  IO读取文件,键值对存储到集合
*  从集合中以键值对方式获取数据库的连接信息,完成数据库的连接
*/
public class PropertiesDemo {
public static void main(String[] args) throws Exception{
FileInputStream fis = new FileInputStream("database.properties");
System.out.println(fis);
//使用类的加载器
InputStream in = PropertiesDemo.class.getClassLoader().getResourceAsStream("database.properties");
System.out.println(in);
Properties pro = new Properties();
pro.load(in);
System.out.println(in);
}
}

###21通过配置文件连接数据库
* A: 通过配置文件连接数据库
* a: 案例代码
/*
*  加载properties配置文件
*  IO读取文件,键值对存储到集合
*  从集合中以键值对方式获取数据库的连接信息,完成数据库的连接
*/
public class PropertiesDemo {
public static void main(String[] args) throws Exception{
FileInputStream fis = new FileInputStream("database.properties");
System.out.println(fis);
//使用类的加载器
InputStream in = PropertiesDemo.class.getClassLoader().getResourceAsStream("database.properties");
System.out.println(in);
Properties pro = new Properties();
pro.load(in);
//获取集合中的键值对
String driverClass=pro.getProperty("driverClass");
String url = pro.getProperty("url");
String username = pro.getProperty("username");
String password = pro.getProperty("password");
Class.forName(driverClass);
Connection con = DriverManager.getConnection(url, username, password);
System.out.println(con);

}
}

22读取配置文件的工具类

* A: 读取配置文件的工具类
* a: 案例代码

/*
*  编写数据库连接的工具类,JDBC工具类
*  获取连接对象采用读取配置文件方式
*  读取文件获取连接,执行一次,static{}
*/
public class JDBCUtilsConfig {
private static Connection con ;
private static String driverClass;
private static String url;
private static String username;
private static String password;

static{
try{
readConfig();
Class.forName(driverClass);
con = DriverManager.getConnection(url, username, password);
}catch(Exception ex){
throw new RuntimeException("数据库连接失败");
}
}

private static void readConfig()throws Exception{
InputStream in = JDBCUtilsConfig.class.getClassLoader().getResourceAsStream("database.properties");
Properties pro = new Properties();
pro.load(in);
driverClass=pro.getProperty("driverClass");
url = pro.getProperty("url");
username = pro.getProperty("username");
password = pro.getProperty("password");
}

public static Connection getConnection(){
return con;
}

}

###23测试工具类
* A: 测试工具类
* a: 案例代码
public class TestJDBCUtils {
public static void main(String[] args) {
Connection con = JDBCUtilsConfig.getConnection();
System.out.println(con);
}
}

01DButils工具类的介绍个三个核心类

* A: DButils工具类的介绍个三个核心类
* a: 概述
* DBUtils是java编程中的数据库操作实用工具，小巧简单实用。
* DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。
* DBUtils就是JDBC的简化开发工具包。需要项目导入commons-dbutils-1.6.jar才能够正常使用DBUtils工具。
* b: Dbutils三个核心功能介绍
* QueryRunner中提供对sql语句操作的API.
* update(Connection conn, String sql, Object... params) ，用来完成表数据的增加、删除、更新操作
* query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) ，用来完成表数据的查询操作
* ResultSetHandler接口，用于定义select操作后，怎样封装结果集.
* DbUtils类，它就是一个工具类,定义了关闭资源与事务处理的方法

02事务的简单介绍(此知识点简单了解，难度较大，就业班会详细 讲解)

* A: 事务的简单介绍
* a: 见day32/day32_source/事务.jgp

03QueryRunner类的update方法介绍

* A：QueryRunner类的update方法介绍
* a: 方法介绍
* update(Connection conn, String sql, Object... params) ，用来完成表数据的增加、删除、更新操作
*  使用QueryRunner类,实现对数据表的insert delete update
*  调用QueryRunner类的方法 update (Connection con,String sql,Object...param)
*  Object...param 可变参数,Object类型,SQL语句会出现?占位符
*  数据库连接对象,自定义的工具类传递

04QueryRunner类实现insert添加数据

* A: QueryRunner类实现insert添加数据
* a: 案例代码

public class QueryRunnerDemo {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args)throws SQLException {
insert();
}
/*
* 定义方法,使用QueryRunner类的方法update向数据表中,添加数据
*/
public static void insert()throws SQLException{
//创建QueryRunner类对象
QueryRunner qr = new QueryRunner();
String sql = "INSERT INTO sort (sname,sprice,sdesc)VALUES(?,?,?)";
//将三个?占位符的实际参数,写在数组中
Object[] params = {"体育用品",289.32,"购买体育用品"};
//调用QueryRunner类的方法update执行SQL语句
int row = qr.update(con, sql, params);
System.out.println(row);
DbUtils.closeQuietly(con);
}
}

05QueryRunner类实现update修改数据

* A: QueryRunner类实现update修改数据
* a: 案例代码

public class QueryRunnerDemo {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args)throws SQLException {
update();
}
/*
*  定义方法,使用QueryRunner类的方法update将数据表的数据修改
*/
public static void update()throws SQLException{
//创建QueryRunner类对象
QueryRunner qr = new QueryRunner();
//写修改数据的SQL语句
String sql = "UPDATE sort SET sname=?,sprice=?,sdesc=? WHERE sid=?";
//定义Object数组,存储?中的参数
Object[] params = {"花卉",100.88,"情人节玫瑰花",4};
//调用QueryRunner方法update
int row = qr.update(con, sql, params);
System.out.println(row);
DbUtils.closeQuietly(con);
}
}

06QueryRunner类实现delete删除数据

* A: QueryRunner类实现delete删除数据
* a: 案例代码

public class QueryRunnerDemo {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args)throws SQLException {
delete();
}
/*
*  定义方法,使用QueryRunner类的方法delete将数据表的数据删除
*/
public static void delete()throws SQLException{
//创建QueryRunner类对象
QueryRunner qr = new QueryRunner();
//写删除的SQL语句
String sql = "DELETE FROM sort WHERE sid=?";
//调用QueryRunner方法update
int row = qr.update(con, sql, 8);
System.out.println(row);
/*
*  判断insert,update,delete执行是否成功
*  对返回值row判断
*  if(row>0) 执行成功
*/
DbUtils.closeQuietly(con);
}
}

07JavaBean类

* A: JavaBean类
* a: 概念
* JavaBean就是一个类，在开发中常用封装数据。具有如下特性
1.  需要实现接口：java.io.Serializable ，通常实现接口这步骤省略了，不会影响程序。
2.  提供私有字段：private 类型 字段名;
3.  提供getter/setter方法：
4.  提供无参构造

08DBUtils工具类结果集处理的方式

* A: DBUtils工具类结果集处理的方式
* a: QueryRunner实现查询操作
*   query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params) ，用来完成表数据的查询操作
* b: ResultSetHandler结果集处理类
* ArrayHandler  将结果集中的第一条记录封装到一个Object[]数组中，数组中的每一个元素就是这条记录中的每一个字段的值
* ArrayListHandler  将结果集中的每一条记录都封装到一个Object[]数组中，将这些数组在封装到List集合中。
* BeanHandler   将结果集中第一条记录封装到一个指定的javaBean中。
* BeanListHandler   将结果集中每一条记录封装到指定的javaBean中，将这些javaBean在封装到List集合中
* ColumnListHandler 将结果集中指定的列的字段值，封装到一个List集合中
* ScalarHandler 它是用于单数据。例如select count(*) from 表操作。
* MapHandler    将结果集第一行封装到Map集合中,Key 列名, Value 该列数据
* MapListHandler    将结果集第一行封装到Map集合中,Key 列名, Value 该列数据,Map集合存储到List集合

09QueryRunner类的方法query

* A: QueryRunner类的方法query
* a: QueryRunner数据查询操作
* 调用QueryRunner类方法query(Connection con,String sql,ResultSetHandler r, Object..params)
*  ResultSetHandler r 结果集的处理方式,传递ResultSetHandler接口实现类
*  Object..params SQL语句中的?占位符
*  注意: query方法返回值,返回的是T 泛型, 具体返回值类型,跟随结果集处理方式变化
* b: 案例代码
public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
}

10结果集处理ArrayHandler

* A: 结果集处理ArrayHandler
* 案例代码

public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
arrayHandler();
}
/*
*  结果集第一种处理方法, ArrayHandler
*  将结果集的第一行存储到对象数组中  Object[]
*/
public static void arrayHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT * FROM sort";
//调用方法query执行查询,传递连接对象,SQL语句,结果集处理方式的实现类
//返回对象数组
Object[] result = qr.query(con, sql, new ArrayHandler());
for(Object obj : result){
System.out.print(obj);
}
}
}

11结果集处理ArrayListHandler

* A: 结果集处理ArrayListHandler
* a: 案例代码

public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
arrayListHandler();
}
/*
*  结果集第二种处理方法,ArrayListHandler
*  将结果集的每一行,封装到对象数组中, 出现很多对象数组
*  对象数组存储到List集合
*/
public static void arrayListHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT * FROM sort";
//调用query方法,结果集处理的参数上,传递实现类ArrayListHandler
//方法返回值 每行是一个对象数组,存储到List
List<Object[]> result=  qr.query(con, sql, new ArrayListHandler());

//集合的遍历
for( Object[] objs  : result){
//遍历对象数组
for(Object obj : objs){
System.out.print(obj+"  ");
}
System.out.println();
}
}
}

12结果集处理BeanHandler

* A: 结果集处理BeanHandler
* a: 案例代码

public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
beanHandler();
}
/*
*  结果集第三种处理方法,BeanHandler
*  将结果集的第一行数据,封装成JavaBean对象
*  注意: 被封装成数据到JavaBean对象, Sort类必须有空参数构造
*/
public static void beanHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT * FROM sort ";
//调用方法,传递结果集实现类BeanHandler
//BeanHandler(Class<T> type)
Sort s = qr.query(con, sql, new BeanHandler<Sort>(Sort.class));
System.out.println(s);
}
}

13结果集处理BeanListHandler

* A: 结果集处理BeanListHandler
* a: 案例代码

public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
beanListHander();
}
/*
*  结果集第四种处理方法, BeanListHandler
*  结果集每一行数据,封装JavaBean对象
*  多个JavaBean对象,存储到List集合
*/
public static void beanListHander()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT * FROM sort ";
//调用方法query,传递结果集处理实现类BeanListHandler
List<Sort> list = qr.query(con, sql, new BeanListHandler<Sort>(Sort.class));
for(Sort s : list){
System.out.println(s);
}
}
}

###14结果集处理ColumnListHandler
* A: 结果集处理ColumnListHandler
* a: 案例代码
public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
columnListHandler();
}
/*
*  结果集第五种处理方法,ColumnListHandler
*  结果集,指定列的数据,存储到List集合
*  List<Object> 每个列数据类型不同
*/
public static void columnListHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT * FROM sort ";
//调用方法 query,传递结果集实现类ColumnListHandler
//实现类构造方法中,使用字符串的列名
List<Object> list = qr.query(con, sql, new ColumnListHandler<Object>("sname"));
for(Object obj : list){
System.out.println(obj);
}
}
}

15结果集处理ScalarHandler

* A: 结果集处理ScalarHandler
* a: 案例代码

public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
scalarHandler();
}
/*
*  结果集第六种处理方法,ScalarHandler
*  对于查询后,只有1个结果
*/
public static void scalarHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT COUNT(*) FROM sort";
//调用方法query,传递结果集处理实现类ScalarHandler
long count = qr.query(con, sql, new ScalarHandler<Long>());
System.out.println(count);
}
}

16结果集处理MapHandler

* A: 结果集处理MapHandler
* a: 案例代码

public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
mapHandler();
}
/*
*  结果集第七种处理方法,MapHandler
*  将结果集第一行数据,封装到Map集合中
*  Map<键,值> 键:列名  值:这列的数据
*/
public static void mapHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT  * FROM sort";
//调用方法query,传递结果集实现类MapHandler
//返回值: Map集合,Map接口实现类, 泛型
Map<String,Object> map = qr.query(con, sql, new MapHandler());
//遍历Map集合
for(String key : map.keySet()){
System.out.println(key+".."+map.get(key));
}
}
}

###17结果集处理MapListHandler
* A: 结果集处理MapListHandlerr
* a: 案例代码
public class QueryRunnerDemo1 {
private static Connection con = JDBCUtilsConfig.getConnection();
public static void main(String[] args) throws SQLException{
mapListHandler();
}
/*
*  结果集第八种处理方法,MapListHandler
*  将结果集每一行存储到Map集合,键:列名,值:数据
*  Map集合过多,存储到List集合
*/
public static void mapListHandler()throws SQLException{
QueryRunner qr = new QueryRunner();
String sql = "SELECT  * FROM sort";
//调用方法query,传递结果集实现类MapListHandler
//返回值List集合, 存储的是Map集合
List<Map<String,Object>> list = qr.query(con, sql, new MapListHandler());
//遍历集合list
for( Map<String,Object> map : list ){
for(String key : map.keySet()){
System.out.print(key+"..."+map.get(key));
}
System.out.println();
}

}
}

18连接池介绍

* A: 连接池介绍
* a: 连接池介绍
* 实际上就是存放连接的池子(容器)
* 在开发中“获得连接”或“释放资源”是非常消耗系统资源的两个过程
* 为了解决此类性能问题，通常情况我们采用连接池技术，来共享连接Connection。
* 这样我们就不需要每次都创建连接、释放连接了，这些操作都交给了连接池

19连接池概念规范和DataSource接口

* A: 连接池概念规范和DataSource接口
* a: 连接池概念规范
* 用池来管理Connection，这样可以重复使用Connection。
* 不用自己来创建Connection，而是通过池来获取Connection对象
* 使用完Connection后，调用Connection的close()方法也不会真的关闭Connection，而是把Connection“归还”给池
* 连接池技术可以完成Connection对象的再次利用
* b: DataSource接口
* Java为数据库连接池提供了公共的接口：javax.sql.DataSource
* 各个厂商需要让自己的连接池实现这个接口。这样应用程序可以方便的切换不同厂商的连接池
* 常见的连接池：DBCP、C3P0

20DBCP连接池介绍

* A: DBCP连接池介绍
* a: DBCP连接池介绍
* DBCP也是一个开源的连接池，是Apache Common成员之一，在企业开发中也比较常见，tomcat内置的连接池
* tomcat服务器简单介绍

21导入jar包

* A: 导入jar包
* a: jar包介绍
* mysql-connector-java-5.1.37-bin.jar：数据库驱动
* commons-dbutils-1.6.jar：提供QueryRunner类方便进行增删改查操作
* commons-dbcp-1.4.jar：
* commons-pool-1.5.6.jar：提供高效的数据库连接池技术
* b: 导入jar包
* 在项目根路径下建立文件夹lib
* 拷贝以上jar包，选定拷贝的jar包/右键/Build Path/Add to Build Path

22BasicDataSource类的使用

* A: BasicDataSource类的使用
* a: 案例代码

/*
*  连接池jar包中,定义好一个类 BasicDataSource
*  实现类数据源的规范接口 javax.sql.DataSource
*/
public class DataSoruceDemo {
public static void main(String[] args) {
//创建DataSource接口的实现类对象
//实现类, org.apache.commons.dbcp
BasicDataSource dataSource = new BasicDataSource();
//连接数据库的4个最基本信息,通过对象方法setXXX设置进来
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/mybase");
dataSource.setUsername("root");
dataSource.setPassword("123");

try{
//调用对象方法getConnection获取数据库的连接
Connection con = dataSource.getConnection();
System.out.println(con);
}catch(SQLException ex){
//          System.out.println(ex);
ex.printStackTrace();
throw new RuntimeException("数据库连接失败");
}
}
}

23BasicDataSource类的常见配置

* A: BasicDataSource类的常见配置
* a: 常见配置
分类  属性          描述
必须项
driverClassName 数据库驱动名称
url             数据库的地址
username        用户名
password        密码
基本项（扩展）
maxActive       最大连接数量
minIdle         最小空闲连接
maxIdle         最大空闲连接
initialSize     初始化连接

24实现数据库连接池工具类

* A: 实现数据库连接池工具类
* a: 案例代码

/*
*  使用DBCP实现数据库的连接池
*  连接池配置,自定义类,
*  最基本四项完整
*  对于数据库连接池其他配置,自定义
*/

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;
public class JDBCUtils{
//创建出BasicDataSource类对象
private static BasicDataSource datasource = new BasicDataSource();

//静态代码块,对象BasicDataSource对象中的配置,自定义
static{
//数据库连接信息,必须的
datasource.setDriverClassName("com.mysql.jdbc.Driver");
datasource.setUrl("jdbc:mysql://localhost:3306/day33_user");
datasource.setUsername("root");
datasource.setPassword("123");
//对象连接池中的连接数量配置,可选的
datasource.setInitialSize(10);//初始化的连接数
datasource.setMaxActive(8);//最大连接数量
datasource.setMaxIdle(5);//最大空闲数
datasource.setMinIdle(1);//最小空闲
}

//定义静态方法,返回BasicDataSource类的对象
public static DataSource getDataSource(){
return datasource;
}
}

25工具类的测试

* A: 工具类的测试
* a: 案例代码

/*
*  测试写好的工具类,
*  提供的是一个DataSource接口的数据源
*  QueryRunner类构造方法,接收DataSource接口的实现类
*  后面,调用方法update,query,无需传递他们Connection连接对象
*/

import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayListHandler;

import cn.itcast.jdbcutils.JDBCUtils;
public class QueryRunnerDemo{
public static void main(String[] args) {
select();
}
//定义2个方法,实现数据表的添加,数据表查询
//QueryRunner类对象,写在类成员位置
private static QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());

//数据表查询
public static void select(){
String sql = "SELECT * FROM sort";
try{
List<Object[]> list = qr.query(sql, new ArrayListHandler());
for(Object[] objs : list){
for(Object obj : objs){
System.out.print(obj+"\t");
}
System.out.println();
}
}catch(SQLException ex){
throw new RuntimeException("数据查询失败");
}
}

//数据表添加数据
public static void insert(){
String sql = "INSERT INTO sort (sname,sprice,sdesc)VALUES(?,?,?)";
Object[] params = {"水果",100.12,"刚刚上市的核桃"};
try{
int row = qr.update(sql, params);
System.out.println(row);
}catch(SQLException ex){
throw new RuntimeException("数据添加失败");
}
}

}