网站建设 开发人一丶一一人一一,正在建设中的网站可算违规,微信 绑定网站,男女激烈做羞羞事网站第4章 操作BLOB类型字段
4.1 MySQL BLOB类型 MySQL中#xff0c;BLOB是一个二进制大型对象#xff0c;是一个可以存储大量数据的容器#xff0c;它能容纳不同大小的数据。 插入BLOB类型的数据必须使用PreparedStatement#xff0c;因为BLOB类型的数据无法使用字符串拼接写…第4章 操作BLOB类型字段
4.1 MySQL BLOB类型 MySQL中BLOB是一个二进制大型对象是一个可以存储大量数据的容器它能容纳不同大小的数据。 插入BLOB类型的数据必须使用PreparedStatement因为BLOB类型的数据无法使用字符串拼接写的。 MySQL的四种BLOB类型(除了在存储的最大信息量上不同外他们是等同的) 实际使用中根据需要存入的数据大小定义不同的BLOB类型。需要注意的是如果存储的文件过大数据库的性能会下降。如果在指定了相关的Blob类型以后还报错xxx too large那么在mysql的安装目录下找my.ini文件加上如下的配置参数 max_allowed_packet16M。同时注意修改了my.ini文件之后需要重新启动mysql服务。
代码结构 4.2 向数据表中插入大数据类型
BlobTest.java //向数据表customers中插入Blob类型的字段Testpublic void testInsert() throws Exception{Connection conn JDBCUtils.getConnection();String sql insert into customers(name,email,birth,photo)values(?,?,?,?);PreparedStatement ps conn.prepareStatement(sql);ps.setObject(1,袁浩);ps.setObject(2, yuanqq.com);ps.setObject(3,1992-09-08);FileInputStream is new FileInputStream(new File(girl.jpg));ps.setBlob(4, is);ps.execute();JDBCUtils.closeResource(conn, ps);}4.3 修改数据表中的Blob类型字段
Connection conn JDBCUtils.getConnection();
String sql update customers set photo ? where id ?;
PreparedStatement ps conn.prepareStatement(sql);// 填充占位符
// 操作Blob类型的变量
FileInputStream fis new FileInputStream(coffee.png);
ps.setBlob(1, fis);
ps.setInt(2, 25);ps.execute();fis.close();
JDBCUtils.closeResource(conn, ps);4.4 从数据表中读取大数据类型
String sql SELECT id, name, email, birth, photo FROM customer WHERE id ?;
conn getConnection();
ps conn.prepareStatement(sql);ps.setInt(1, 8);
rs ps.executeQuery();
if(rs.next()){Integer id rs.getInt(1);String name rs.getString(2);String email rs.getString(3);Date birth rs.getDate(4);Customer cust new Customer(id, name, email, birth);System.out.println(cust); //读取Blob类型的字段Blob photo rs.getBlob(5);InputStream is photo.getBinaryStream();OutputStream os new FileOutputStream(c.jpg);byte [] buffer new byte[1024];int len 0;while((len is.read(buffer)) ! -1){os.write(buffer, 0, len);}JDBCUtils.closeResource(conn, ps, rs);if(is ! null){is.close();}if(os ! null){os.close();}}第5章 批量插入
5.1 批量执行SQL语句
当需要成批插入或者更新记录时可以采用Java的批量更新机制这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率
JDBC的批量处理语句包括下面三个方法
addBatch(String)添加需要批量处理的SQL语句或是参数executeBatch()执行批量处理语句clearBatch():清空缓存的数据
通常我们会遇到两种批量执行SQL语句的情况
多条SQL语句的批量处理一个SQL语句的批量传参
5.2 高效的批量插入
举例向数据表中插入20000条数据
数据库中提供一个goods表
CREATE TABLE goods(
id INT PRIMARY KEY AUTO_INCREMENT,
NAME VARCHAR(20)
);5.2.1 实现一使用Statement
InsertTest.java
Connection conn JDBCUtils.getConnection();
Statement st conn.createStatement();
for(int i 1;i 20000;i){String sql insert into goods(name) values(name_ i );st.executeUpdate(sql);
}5.2.2 实现二使用PreparedStatement
long start System.currentTimeMillis();Connection conn JDBCUtils.getConnection();String sql insert into goods(name)values(?);
PreparedStatement ps conn.prepareStatement(sql);
for(int i 1;i 20000;i){ps.setString(1, name_ i);ps.executeUpdate();
}long end System.currentTimeMillis();
System.out.println(花费的时间为 (end - start));//82340JDBCUtils.closeResource(conn, ps);5.2.3 实现三
/** 修改1 使用 addBatch() / executeBatch() / clearBatch()* 修改2mysql服务器默认是关闭批处理的我们需要通过一个参数让mysql开启批处理的支持。* ?rewriteBatchedStatementstrue 写在配置文件的url后面* 修改3使用更新的mysql 驱动mysql-connector-java-5.1.37-bin.jar* */
Test
public void testInsert1() throws Exception{long start System.currentTimeMillis();Connection conn JDBCUtils.getConnection();String sql insert into goods(name)values(?);PreparedStatement ps conn.prepareStatement(sql);for(int i 1;i 1000000;i){ps.setString(1, name_ i);//1.“攒”sqlps.addBatch();if(i % 500 0){//2.执行ps.executeBatch();//3.清空ps.clearBatch();}}long end System.currentTimeMillis();System.out.println(花费的时间为 (end - start));//20000条625 //1000000条:14733 JDBCUtils.closeResource(conn, ps);
}5.2.4 实现四
/*
* 层次四在层次三的基础上操作
* 使用Connection 的 setAutoCommit(false) / commit()
*/
Test
public void testInsert2() throws Exception{long start System.currentTimeMillis();Connection conn JDBCUtils.getConnection();//1.设置为不自动提交数据conn.setAutoCommit(false);String sql insert into goods(name)values(?);PreparedStatement ps conn.prepareStatement(sql);for(int i 1;i 1000000;i){ps.setString(1, name_ i);//1.“攒”sqlps.addBatch();if(i % 500 0){//2.执行ps.executeBatch();//3.清空ps.clearBatch();}}//2.提交数据conn.commit();long end System.currentTimeMillis();System.out.println(花费的时间为 (end - start));//1000000条:4978 JDBCUtils.closeResource(conn, ps);
}第6章DAO及相关实现类
DAOData Access Object访问数据信息的类和接口包括了对数据的CRUDCreate、Retrival、Update、Delete而不包含任何业务相关的信息。有时也称作BaseDAO作用为了实现功能的模块化更有利于代码的维护和升级。下面是尚硅谷JavaWeb阶段书城项目中DAO使用的体现 层次结构 BaseDAO.java
package com.atguigu.bookstore.dao;import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;/*** 定义一个用来被继承的对数据库进行基本操作的Dao* * author HanYanBing** param T*/
public abstract class BaseDaoT {private QueryRunner queryRunner new QueryRunner();// 定义一个变量来接收泛型的类型private ClassT type;// 获取T的Class对象获取泛型的类型泛型是在被子类继承时才确定public BaseDao() {// 获取子类的类型Class clazz this.getClass();// 获取父类的类型// getGenericSuperclass()用来获取当前类的父类的类型// ParameterizedType表示的是带泛型的类型ParameterizedType parameterizedType (ParameterizedType) clazz.getGenericSuperclass();// 获取具体的泛型类型 getActualTypeArguments获取具体的泛型的类型// 这个方法会返回一个Type的数组Type[] types parameterizedType.getActualTypeArguments();// 获取具体的泛型的类型·this.type (ClassT) types[0];}/*** 通用的增删改操作* * param sql* param params* return*/public int update(Connection conn,String sql, Object... params) {int count 0;try {count queryRunner.update(conn, sql, params);} catch (SQLException e) {e.printStackTrace();} return count;}/*** 获取一个对象* * param sql* param params* return*/public T getBean(Connection conn,String sql, Object... params) {T t null;try {t queryRunner.query(conn, sql, new BeanHandlerT(type), params);} catch (SQLException e) {e.printStackTrace();} return t;}/*** 获取所有对象* * param sql* param params* return*/public ListT getBeanList(Connection conn,String sql, Object... params) {ListT list null;try {list queryRunner.query(conn, sql, new BeanListHandlerT(type), params);} catch (SQLException e) {e.printStackTrace();} return list;}/*** 获取一个但一值得方法专门用来执行像 select count(*)...这样的sql语句* * param sql* param params* return*/public Object getValue(Connection conn,String sql, Object... params) {Object count null;try {// 调用queryRunner的query方法获取一个单一的值count queryRunner.query(conn, sql, new ScalarHandler(), params);} catch (SQLException e) {e.printStackTrace();} return count;}
}BookDAO.java
package com.atguigu.bookstore.dao;import java.sql.Connection;
import java.util.List;import com.atguigu.bookstore.beans.Book;
import com.atguigu.bookstore.beans.Page;public interface BookDao {/*** 从数据库中查询出所有的记录* * return*/ListBook getBooks(Connection conn);/*** 向数据库中插入一条记录* * param book*/void saveBook(Connection conn,Book book);/*** 从数据库中根据图书的id删除一条记录* * param bookId*/void deleteBookById(Connection conn,String bookId);/*** 根据图书的id从数据库中查询出一条记录* * param bookId* return*/Book getBookById(Connection conn,String bookId);/*** 根据图书的id从数据库中更新一条记录* * param book*/void updateBook(Connection conn,Book book);/*** 获取带分页的图书信息* * param page是只包含了用户输入的pageNo属性的page对象* return 返回的Page对象是包含了所有属性的Page对象*/PageBook getPageBooks(Connection conn,PageBook page);/*** 获取带分页和价格范围的图书信息* * param page是只包含了用户输入的pageNo属性的page对象* return 返回的Page对象是包含了所有属性的Page对象*/PageBook getPageBooksByPrice(Connection conn,PageBook page, double minPrice, double maxPrice);}UserDAO.java
package com.atguigu.bookstore.dao;import java.sql.Connection;import com.atguigu.bookstore.beans.User;public interface UserDao {/*** 根据User对象中的用户名和密码从数据库中获取一条记录* * param user* return User 数据库中有记录 null 数据库中无此记录*/User getUser(Connection conn,User user);/*** 根据User对象中的用户名从数据库中获取一条记录* * param user* return true 数据库中有记录 false 数据库中无此记录*/boolean checkUsername(Connection conn,User user);/*** 向数据库中插入User对象* * param user*/void saveUser(Connection conn,User user);
}BookDaoImpl.java
package com.atguigu.bookstore.dao.impl;import java.sql.Connection;
import java.util.List;import com.atguigu.bookstore.beans.Book;
import com.atguigu.bookstore.beans.Page;
import com.atguigu.bookstore.dao.BaseDao;
import com.atguigu.bookstore.dao.BookDao;public class BookDaoImpl extends BaseDaoBook implements BookDao {Overridepublic ListBook getBooks(Connection conn) {// 调用BaseDao中得到一个List的方法ListBook beanList null;// 写sql语句String sql select id,title,author,price,sales,stock,img_path imgPath from books;beanList getBeanList(conn,sql);return beanList;}Overridepublic void saveBook(Connection conn,Book book) {// 写sql语句String sql insert into books(title,author,price,sales,stock,img_path) values(?,?,?,?,?,?);// 调用BaseDao中通用的增删改的方法update(conn,sql, book.getTitle(), book.getAuthor(), book.getPrice(), book.getSales(), book.getStock(),book.getImgPath());}Overridepublic void deleteBookById(Connection conn,String bookId) {// 写sql语句String sql DELETE FROM books WHERE id ?;// 调用BaseDao中通用增删改的方法update(conn,sql, bookId);}Overridepublic Book getBookById(Connection conn,String bookId) {// 调用BaseDao中获取一个对象的方法Book book null;// 写sql语句String sql select id,title,author,price,sales,stock,img_path imgPath from books where id ?;book getBean(conn,sql, bookId);return book;}Overridepublic void updateBook(Connection conn,Book book) {// 写sql语句String sql update books set title ? , author ? , price ? , sales ? , stock ? where id ?;// 调用BaseDao中通用的增删改的方法update(conn,sql, book.getTitle(), book.getAuthor(), book.getPrice(), book.getSales(), book.getStock(), book.getId());}Overridepublic PageBook getPageBooks(Connection conn,PageBook page) {// 获取数据库中图书的总记录数String sql select count(*) from books;// 调用BaseDao中获取一个单一值的方法long totalRecord (long) getValue(conn,sql);// 将总记录数设置都page对象中page.setTotalRecord((int) totalRecord);// 获取当前页中的记录存放的ListString sql2 select id,title,author,price,sales,stock,img_path imgPath from books limit ?,?;// 调用BaseDao中获取一个集合的方法ListBook beanList getBeanList(conn,sql2, (page.getPageNo() - 1) * Page.PAGE_SIZE, Page.PAGE_SIZE);// 将这个List设置到page对象中page.setList(beanList);return page;}Overridepublic PageBook getPageBooksByPrice(Connection conn,PageBook page, double minPrice, double maxPrice) {// 获取数据库中图书的总记录数String sql select count(*) from books where price between ? and ?;// 调用BaseDao中获取一个单一值的方法long totalRecord (long) getValue(conn,sql,minPrice,maxPrice);// 将总记录数设置都page对象中page.setTotalRecord((int) totalRecord);// 获取当前页中的记录存放的ListString sql2 select id,title,author,price,sales,stock,img_path imgPath from books where price between ? and ? limit ?,?;// 调用BaseDao中获取一个集合的方法ListBook beanList getBeanList(conn,sql2, minPrice , maxPrice , (page.getPageNo() - 1) * Page.PAGE_SIZE, Page.PAGE_SIZE);// 将这个List设置到page对象中page.setList(beanList);return page;}}UserDaoImpl.java
package com.atguigu.bookstore.dao.impl;import java.sql.Connection;import com.atguigu.bookstore.beans.User;
import com.atguigu.bookstore.dao.BaseDao;
import com.atguigu.bookstore.dao.UserDao;public class UserDaoImpl extends BaseDaoUser implements UserDao {Overridepublic User getUser(Connection conn,User user) {// 调用BaseDao中获取一个对象的方法User bean null;// 写sql语句String sql select id,username,password,email from users where username ? and password ?;bean getBean(conn,sql, user.getUsername(), user.getPassword());return bean;}Overridepublic boolean checkUsername(Connection conn,User user) {// 调用BaseDao中获取一个对象的方法User bean null;// 写sql语句String sql select id,username,password,email from users where username ?;bean getBean(conn,sql, user.getUsername());return bean ! null;}Overridepublic void saveUser(Connection conn,User user) {//写sql语句String sql insert into users(username,password,email) values(?,?,?);//调用BaseDao中通用的增删改的方法update(conn,sql, user.getUsername(),user.getPassword(),user.getEmail());}}Book.java
package com.atguigu.bookstore.beans;
/*** 图书类* author songhongkang**/
public class Book {private Integer id;private String title; // 书名private String author; // 作者private double price; // 价格private Integer sales; // 销量private Integer stock; // 库存private String imgPath static/img/default.jpg; // 封面图片的路径//构造器get()set()toString()方法略
}Page.java
package com.atguigu.bookstore.beans;import java.util.List;
/*** 页码类* author songhongkang**/
public class PageT {private ListT list; // 每页查到的记录存放的集合public static final int PAGE_SIZE 4; // 每页显示的记录数private int pageNo; // 当前页
// private int totalPageNo; // 总页数通过计算得到private int totalRecord; // 总记录数通过查询数据库得到
}User.java
package com.atguigu.bookstore.beans;
/*** 用户类* author songhongkang**/
public class User {private Integer id;private String username;private String password;private String email;
}第7章数据库连接池
普通的JDBC数据库连接使用 DriverManager 来获取每次向数据库建立连接的时候都要将 Connection 加载到内存中再验证用户名和密码(得花费0.05s1s的时间)。需要数据库连接的时候就向数据库要求一个执行完成后再断开连接。这样的方式将会消耗大量的资源和时间。**数据库的连接资源并没有得到很好的重复利用。**若同时有几百人甚至几千人在线频繁的进行数据库连接操作将占用很多的系统资源严重的甚至会造成服务器的崩溃。
这种开发不能控制被创建的连接对象数系统资源会被毫无顾及的分配出去如连接过多也可能导致内存泄漏服务器崩溃。
7.1 数据库连接池技术 为解决传统开发中的数据库连接问题可以采用数据库连接池技术。 数据库连接池的基本思想就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接当需要建立数据库连接时只需从“缓冲池”中取出一个使用完毕之后再放回去。 数据库连接池负责分配、管理和释放数据库连接它允许应用程序重复使用一个现有的数据库连接而不是重新建立一个。 数据库连接池在初始化时将创建一定数量的数据库连接放到连接池中这些数据库连接的数量是由最小数据库连接数来设定的。无论这些数据库连接是否被使用连接池都将一直保证至少拥有这么多的连接数量。连接池的最大数据库连接数量限定了这个连接池能占有的最大连接数当应用程序向连接池请求的连接数超过最大连接数量时这些请求将被加入到等待队列中。 工作原理 数据库连接池技术的优点 1. 资源重用 由于数据库连接得以重用避免了频繁创建释放连接引起的大量性能开销。在减少系统消耗的基础上另一方面也增加了系统运行环境的平稳性。 2. 更快的系统反应速度 数据库连接池在初始化过程中往往已经创建了若干数据库连接置于连接池中备用。此时连接的初始化工作均已完成。对于业务请求处理而言直接利用现有可用连接避免了数据库连接初始化和释放过程的时间开销从而减少了系统的响应时间 3. 新的资源分配手段 对于多应用共享同一数据库的系统而言可在应用层通过数据库连接池的配置实现某一应用最大可用数据库连接数的限制避免某一应用独占所有的数据库资源 4. 统一的连接管理避免数据库连接泄漏 在较为完善的数据库连接池实现中可根据预先的占用超时设定强制回收被占用连接从而避免了常规数据库连接操作中可能出现的资源泄露
7.2 多种开源的数据库连接池
JDBC 的数据库连接池使用 javax.sql.DataSource 来表示DataSource 只是一个接口该接口通常由服务器(Weblogic, WebSphere, Tomcat)提供实现也有一些开源组织提供实现 DBCP 是Apache提供的数据库连接池。tomcat 服务器自带dbcp数据库连接池。速度相对c3p0较快但因自身存在BUGHibernate3已不再提供支持。C3P0 是一个开源组织提供的一个数据库连接池**速度相对较慢稳定性还可以。**hibernate官方推荐使用Proxool 是sourceforge下的一个开源项目数据库连接池有监控连接池状态的功能稳定性较c3p0差一点BoneCP 是一个开源组织提供的数据库连接池速度快Druid 是阿里提供的数据库连接池据说是集DBCP 、C3P0 、Proxool 优点于一身的数据库连接池但是速度不确定是否有BoneCP快 DataSource 通常被称为数据源它包含连接池和连接池管理两个部分习惯上也经常把 DataSource 称为连接池DataSource用来取代DriverManager来获取Connection获取速度快同时可以大幅度提高数据库访问速度。特别注意 数据源和数据库连接不同数据源无需创建多个它是产生数据库连接的工厂因此整个应用只需要一个数据源即可。当数据库访问结束后程序还是像以前一样关闭数据库连接conn.close(); 但conn.close()并没有关闭数据库的物理连接它仅仅把数据库连接释放归还给了数据库连接池。
7.2.1 C3P0数据库连接池
代码结构如下 获取连接方式一
C3P0Test.java
package com.atguigu4.connection;import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;import org.junit.Test;import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.mchange.v2.c3p0.DataSources;public class C3P0Test {//方式一Testpublic void testGetConnection() throws Exception{//获取c3p0数据库连接池ComboPooledDataSource cpds new ComboPooledDataSource();cpds.setDriverClass( com.mysql.jdbc.Driver ); cpds.setJdbcUrl( jdbc:mysql://localhost:3306/myDB );cpds.setUser(root); cpds.setPassword(root);//通过设置相关的参数对数据库连接池进行管理//设置初始时数据库连接池中的连接数cpds.setInitialPoolSize(10);Connection conn cpds.getConnection();System.out.println(conn);//销毁c3p0数据库连接池
// DataSources.destroy( cpds );}
}获取连接方式二
//使用C3P0数据库连接池的配置文件方式获取数据库的连接推荐
private static DataSource cpds new ComboPooledDataSource(helloc3p0);
public static Connection getConnection2() throws SQLException{Connection conn cpds.getConnection();return conn;
}c3p0-config.xml
?xml version1.0 encodingUTF-8?
c3p0-confignamed-config namehelloc3p0!-- 获取连接的4个基本信息 --property nameuserroot/propertyproperty namepasswordabc123/propertyproperty namejdbcUrljdbc:mysql:///test/propertyproperty namedriverClasscom.mysql.jdbc.Driver/property!-- 涉及到数据库连接池的管理的相关属性的设置 --!-- 若数据库中连接数不足时, 一次向数据库服务器申请多少个连接 --property nameacquireIncrement5/property!-- 初始化数据库连接池时连接的数量 --property nameinitialPoolSize5/property!-- 数据库连接池中的最小的数据库连接数 --property nameminPoolSize5/property!-- 数据库连接池中的最大的数据库连接数 --property namemaxPoolSize10/property!-- C3P0 数据库连接池可以维护的 Statement 的个数 --property namemaxStatements20/property!-- 每个连接同时可以使用的 Statement 对象的个数 --property namemaxStatementsPerConnection5/property/named-config
/c3p0-config连接成功 7.2.2 DBCP数据库连接池
DBCP 是 Apache 软件基金组织下的开源连接池实现该连接池依赖该组织下的另一个开源系统Common-pool。如需使用该连接池实现应在系统中增加如下两个 jar 文件 Commons-dbcp.jar连接池的实现Commons-pool.jar连接池实现的依赖库 **Tomcat 的连接池正是采用该连接池来实现的。**该数据库连接池既可以与应用服务器整合使用也可由应用程序独立使用。数据源和数据库连接不同数据源无需创建多个它是产生数据库连接的工厂因此整个应用只需要一个数据源即可。当数据库访问结束后程序还是像以前一样关闭数据库连接conn.close(); 但上面的代码并没有关闭数据库的物理连接它仅仅把数据库连接释放归还给了数据库连接池。配置属性说明
属性默认值说明initialSize0连接池启动时创建的初始化连接数量maxActive8连接池中可同时连接的最大的连接数maxIdle8连接池中最大的空闲的连接数超过的空闲连接将被释放如果设置为负数表示不限制minIdle0连接池中最小的空闲的连接数低于这个数量会被创建新的连接。该参数越接近maxIdle性能越好因为连接的创建和销毁都是需要消耗资源的但是不能太大。maxWait无限制最大等待时间当没有可用连接时连接池等待连接释放的最大时间超过该时间限制会抛出异常如果设置-1表示无限等待poolPreparedStatementsfalse开启池的Statement是否preparedmaxOpenPreparedStatements无限制开启池的prepared 后的同时最大连接数minEvictableIdleTimeMillis连接池中连接在时间段内一直空闲 被逐出连接池的时间removeAbandonedTimeout300超过时间限制回收没有用(废弃)的连接removeAbandonedfalse超过removeAbandonedTimeout时间后是否进 行没用连接废弃的回收
DBCPTest.java
获取连接方式一 Testpublic void testGetConnection() throws SQLException{//创建了DBCP的数据库连接池BasicDataSource source new BasicDataSource();//设置基本信息source.setDriverClassName(com.mysql.jdbc.Driver);source.setUrl(jdbc:mysql:///myDB);source.setUsername(root);source.setPassword(root);//还可以设置其他涉及数据库连接池管理的相关属性source.setInitialSize(10);source.setMaxActive(10);//。。。Connection conn source.getConnection();System.out.println(conn);}获取连接方式二 Testpublic void testGetConnection1() throws Exception{Properties pros new Properties();//方式1
// InputStream is ClassLoader.getSystemClassLoader().getResourceAsStream(dbcp.properties);//方式2FileInputStream is new FileInputStream(new File(src/dbcp.properties));pros.load(is);DataSource source BasicDataSourceFactory.createDataSource(pros);Connection conn source.getConnection();System.out.println(conn);}dbcp.properties
driverClassNamecom.mysql.jdbc.Driver
urljdbc:mysql://localhost:3306/test?rewriteBatchedStatementstrueuseServerPrepStmtsfalse
usernameroot
passwordabc123initialSize10
#...7.2.3 Druid德鲁伊数据库连接池
Druid是阿里巴巴开源平台上一个数据库连接池实现它结合了C3P0、DBCP、Proxool等DB池的优点同时加入了日志监控可以很好的监控DB池连接和SQL的执行情况可以说是针对监控而生的DB连接池可以说是目前最好的连接池之一。
package com.atguigu4.connection;import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;import javax.sql.DataSource;import org.junit.Test;import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;public class DruidTest {Testpublic void getConnection() throws Exception{Properties pros new Properties();InputStream is ClassLoader.getSystemClassLoader().getResourceAsStream(druid.properties);pros.load(is);DataSource source DruidDataSourceFactory.createDataSource(pros);Connection conn source.getConnection();System.out.println(conn);}
}druid.properties
urljdbc:mysql://localhost:3306/test?rewriteBatchedStatementstrue
usernameroot
password123456
driverClassNamecom.mysql.jdbc.DriverinitialSize10
maxActive20
maxWait1000
filterswall详细配置参数
配置缺省说明name配置这个属性的意义在于如果存在多个数据源监控的时候可以通过名字来区分开来。 如果没有配置将会生成一个名字格式是”DataSource-” System.identityHashCode(this)url连接数据库的url不同数据库不一样。例如mysql : jdbc:mysql://10.20.153.104:3306/druid2 oracle : jdbc:oracle:thin:10.20.149.85:1521:ocnautousername连接数据库的用户名password连接数据库的密码。如果你不希望密码直接写在配置文件中可以使用ConfigFilter。详细看这里https://github.com/alibaba/druid/wiki/使用ConfigFilterdriverClassName根据url自动识别 这一项可配可不配如果不配置druid会根据url自动识别dbType然后选择相应的driverClassName(建议配置下)initialSize0初始化时建立物理连接的个数。初始化发生在显示调用init方法或者第一次getConnection时maxActive8最大连接池数量maxIdle8已经不再使用配置了也没效果minIdle最小连接池数量maxWait获取连接时最大等待时间单位毫秒。配置了maxWait之后缺省启用公平锁并发效率会有所下降如果需要可以通过配置useUnfairLock属性为true使用非公平锁。poolPreparedStatementsfalse是否缓存preparedStatement也就是PSCache。PSCache对支持游标的数据库性能提升巨大比如说oracle。在mysql下建议关闭。maxOpenPreparedStatements-1要启用PSCache必须配置大于0当大于0时poolPreparedStatements自动触发修改为true。在Druid中不会存在Oracle下PSCache占用内存过多的问题可以把这个数值配置大一些比如说100validationQuery用来检测连接是否有效的sql要求是一个查询语句。如果validationQuery为nulltestOnBorrow、testOnReturn、testWhileIdle都不会其作用。testOnBorrowtrue申请连接时执行validationQuery检测连接是否有效做了这个配置会降低性能。testOnReturnfalse归还连接时执行validationQuery检测连接是否有效做了这个配置会降低性能testWhileIdlefalse建议配置为true不影响性能并且保证安全性。申请连接的时候检测如果空闲时间大于timeBetweenEvictionRunsMillis执行validationQuery检测连接是否有效。timeBetweenEvictionRunsMillis有两个含义 1)Destroy线程会检测连接的间隔时间2)testWhileIdle的判断依据详细看testWhileIdle属性的说明numTestsPerEvictionRun不再使用一个DruidDataSource只支持一个EvictionRunminEvictableIdleTimeMillisconnectionInitSqls物理连接初始化的时候执行的sqlexceptionSorter根据dbType自动识别 当数据库抛出一些不可恢复的异常时抛弃连接filters属性类型是字符串通过别名的方式配置扩展插件常用的插件有 监控统计用的filter:stat日志用的filter:log4j防御sql注入的filter:wallproxyFilters类型是List如果同时配置了filters和proxyFilters是组合关系并非替换关系
第8章Apache-DBUtils实现CRUD操作
8.1 Apache-DBUtils简介 commons-dbutils 是 Apache 组织提供的一个开源 JDBC工具类库它是对JDBC的简单封装学习成本极低并且使用dbutils能极大简化jdbc编码的工作量同时也不会影响程序的性能。 API介绍 org.apache.commons.dbutils.QueryRunnerorg.apache.commons.dbutils.ResultSetHandler工具类org.apache.commons.dbutils.DbUtils
8.2 主要API的使用
8.2.1 DbUtils
DbUtils 提供如关闭连接、装载JDBC驱动程序等常规工作的工具类里面的所有方法都是静态的。主要方法如下 public static void close(…) throws java.sql.SQLException DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL如果不是的话它们就关闭Connection、Statement和ResultSet。public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭还能隐藏一些在程序中抛出的SQLEeception。public static void commitAndClose(Connection conn)throws SQLException 用来提交连接的事务然后关闭连接public static void commitAndCloseQuietly(Connection conn) 用来提交连接然后关闭连接并且在关闭连接时不抛出SQL异常。public static void rollback(Connection conn)throws SQLException允许conn为null因为方法内部做了判断public static void rollbackAndClose(Connection conn)throws SQLExceptionrollbackAndCloseQuietly(Connection)public static boolean loadDriver(java.lang.String driverClassName)这一方装载并注册JDBC驱动程序如果成功就返回true。使用该方法你不需要捕捉这个异常ClassNotFoundException。
8.2.2 QueryRunner类 该类简单化了SQL查询它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作能够大大减少编码量。 QueryRunner类提供了两个构造器 默认的构造器需要一个 javax.sql.DataSource 来作参数的构造器 QueryRunner类的主要方法 更新 public int update(Connection conn, String sql, Object… params) throws SQLException:用来执行一个更新插入、更新或删除操作。… 插入 public T insert(Connection conn,String sql,ResultSetHandler rsh, Object… params) throws SQLException只支持INSERT语句其中 rsh - The handler used to create the result object from the ResultSet of auto-generated keys. 返回值: An object generated by the handler.即自动生成的键值… 批处理 public int[] batch(Connection conn,String sql,Object[][] params)throws SQLException INSERT, UPDATE, or DELETE语句public T insertBatch(Connection conn,String sql,ResultSetHandler rsh,Object[][] params)throws SQLException只支持INSERT语句… 查询 public Object query(Connection conn, String sql, ResultSetHandler rsh,Object… params) throws SQLException执行一个查询操作在这个查询中对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。… 测试
// 测试添加
Test
public void testInsert() throws Exception {QueryRunner runner new QueryRunner();Connection conn JDBCUtils.getConnection3();String sql insert into customers(name,email,birth)values(?,?,?);int count runner.update(conn, sql, 何成飞, heqq.com, 1992-09-08);System.out.println(添加了 count 条记录);JDBCUtils.closeResource(conn, null);
}// 测试删除
Test
public void testDelete() throws Exception {QueryRunner runner new QueryRunner();Connection conn JDBCUtils.getConnection3();String sql delete from customers where id ?;int count runner.update(conn, sql,3);System.out.println(删除了 count 条记录);JDBCUtils.closeResource(conn, null);}8.2.3 ResultSetHandler接口及实现类 该接口用于处理 java.sql.ResultSet将数据按要求转换为另一种形式。 ResultSetHandler 接口提供了一个单独的方法Object handle (java.sql.ResultSet .rs)。 接口的主要实现类 ArrayHandler把结果集中的第一行数据转成对象数组。 ArrayListHandler把结果集中的每一行数据都转成一个数组再存放到List中。 **BeanHandler**将结果集中的第一行数据封装到一个对应的JavaBean实例中。 **BeanListHandler**将结果集中的每一行数据都封装到一个对应的JavaBean实例中存放到List里。 ColumnListHandler将结果集中某一列的数据存放到List中。 KeyedHandler(name)将结果集中的每一行数据都封装到一个Map里再把这些map再存到一个map里其key为指定的key。 **MapHandler**将结果集中的第一行数据封装到一个Map里key是列名value就是对应的值。 **MapListHandler**将结果集中的每一行数据都封装到一个Map里然后再存放到List **ScalarHandler**查询单个值对象 测试
/** 测试查询:查询一条记录* * 使用ResultSetHandler的实现类BeanHandler*/
Test
public void testQueryInstance() throws Exception{QueryRunner runner new QueryRunner();Connection conn JDBCUtils.getConnection3();String sql select id,name,email,birth from customers where id ?;//BeanHandlerCustomer handler new BeanHandler(Customer.class);Customer customer runner.query(conn, sql, handler, 23);System.out.println(customer); JDBCUtils.closeResource(conn, null);
}/** 测试查询:查询多条记录构成的集合* * 使用ResultSetHandler的实现类BeanListHandler*/
Test
public void testQueryList() throws Exception{QueryRunner runner new QueryRunner();Connection conn JDBCUtils.getConnection3();String sql select id,name,email,birth from customers where id ?;//BeanListHandlerCustomer handler new BeanListHandler(Customer.class);ListCustomer list runner.query(conn, sql, handler, 23);list.forEach(System.out::println);JDBCUtils.closeResource(conn, null);
}/** 自定义ResultSetHandler的实现类*/
Test
public void testQueryInstance1() throws Exception{QueryRunner runner new QueryRunner();Connection conn JDBCUtils.getConnection3();String sql select id,name,email,birth from customers where id ?;ResultSetHandlerCustomer handler new ResultSetHandlerCustomer() {Overridepublic Customer handle(ResultSet rs) throws SQLException {System.out.println(handle);
// return new Customer(1,Tom,tom126.com,new Date(123323432L));if(rs.next()){int id rs.getInt(id);String name rs.getString(name);String email rs.getString(email);Date birth rs.getDate(birth);return new Customer(id, name, email, birth);}return null;}};Customer customer runner.query(conn, sql, handler, 23);System.out.println(customer);JDBCUtils.closeResource(conn, null);
}/** 如何查询类似于最大的最小的平均的总和个数相关的数据* 使用ScalarHandler* */
Test
public void testQueryValue() throws Exception{QueryRunner runner new QueryRunner();Connection conn JDBCUtils.getConnection3();//测试一
// String sql select count(*) from customers where id ?;
// ScalarHandler handler new ScalarHandler();
// long count (long) runner.query(conn, sql, handler, 20);
// System.out.println(count);//测试二String sql select max(birth) from customers;ScalarHandler handler new ScalarHandler();Date birth (Date) runner.query(conn, sql, handler);System.out.println(birth);JDBCUtils.closeResource(conn, null);
}
