腾讯云·社区
java核心技术第四篇之JDBC第二篇
01.JDBC连接池_连接池的概念： 1).什么是连接池：对于多用户程序，为每个用户单独创建一个Connection，会使程序降低效率。这时我们可以创建一个"容器"， 这个容器中，先缓存一些Connection对象，有用户请求，就从池中取出一个Connection对象，当用户使用完毕， 再将这个Connection放回到容器中，这个容器就叫：连接池。 2).连接池的作用：先期缓存一些Connection对象，并对这些Connection进行反复的使用，回收，而不需要为每个用户单独创建Connection 对象，从而可以提高程序的运行效率。 3).很多的第三方厂商提供了连接池的实现，Sun公司提出，所有厂商的连接池必须实现：javax.sql.DataSource(接口) 1).DBCP连接池：Apache公司的，commons项目组的成员，免费开源的。Tomcat内部使用的就是这个连接池。 2).C3P0连接池【重要掌握】：开源免费的。整体性能要好于DBCP连接池。Spring、Hibernate框架内部使用这个连接池。 02.JDBC连接池_DBCP连接池的使用： 1).将DBCP的所需jar包复制到项目目录下，并且添加构建路径： commons-dbcp-1.4.jar commons-pool-1.6.jar 2).复制DBCP的配置文件(dbcpcongif.properties)到项目的src目录下； (注意：要会修改配置文件中的四个必须的配置项–driverClassName、url、username、password)
/* dbcpcongif.properties(配置文件) #连接设置--必须设置的 driverClassName=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/hei66_day21 username=root password=1233 #可选设置 #<!-- 初始化连接 --> initialSize=10 #最大连接数量 maxActive=50 #<!-- 最大空闲连接 --> maxIdle=20 #<!-- 最小空闲连接 --> minIdle=5 #<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 --> maxWait=60000 #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] #注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。 connectionProperties=useUnicode=true;characterEncoding=gbk #指定由连接池所创建的连接的自动提交（auto-commit）状态。 defaultAutoCommit=true #driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。 #可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE defaultTransactionIsolation=READ_UNCOMMITTED
*/
/*
3).使用连接池：
1).读取配置文件信息：
Properties pro = new Properties();
pro.load(当前类名.class.getClassLoader().getResourceAsStream("配置文件的名"));//运行时会默认从bin目录下查找资源文件
2).创建连接池对象
BasicDataSource dataSource = (BasicDataSource)BasicDataSourceFactory.createDataSource(pro);
3).从连接池中获取Connection对象：
Connection conn = dataSource.getConnection();
4).发送SQL语句
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from products");
while(rs.next()){
System.out.println(rs.getInt("pid") + "\t" + rs.getString("pname"));
}
rs.close();
stmt.close();
conn.close();//不是关闭，是回收
注意：配置文件中的四项必须配置项中的"键名"不要更改，是固定的名字，由DBCP内部读取。//DBCP连接池的使用 public class Demo { public static void main(String[] args) throws Exception { //1.读取配置文件 Properties pro = new Properties(); pro.load(Demo.class.getClassLoader().getResourceAsStream(“dbcpconfig.properties”));//在src(bin)下找配置文件 //2.创建连接池对象 BasicDataSource dataSource = (BasicDataSource)BasicDataSourceFactory.createDataSource(pro); //3.从连接池中获取连接对象 Connection conn = dataSource.getConnection(); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(“select * from products”); while(rs.next()){ System.out.println(rs.getInt(“pid”) + “\t” + rs.getString(“pname”)); } rs.close(); stmt.close(); conn.close(); } }
03.JDBC连接池_C3P0连接池的使用： 1).将第三方所需的jar包复制到项目目录下： c3p0-0.9.2-pre5.jar mchange-commons-java-0.2.3.jar 2).将c3p0-cinfig.xml配置文件复制到src目录下：文件名不要改，而且必须在src下，C3P0内部会自动去找 (大家要会修改c3p0-config.xml中的四个必须项的配置：driverClass、jdbcUrl、user、password)
*/
/* c3p0-cinfig.xml配置文件 com.mysql.jdbc.Driver jdbc:mysql://127.0.0.1:3306/day31 root root 30000 30 10 30 100 10 200 10 1 0
<!-- 命名的配置 --> <named-config name="baidu"> <!-- 连接数据库的4项基本参数 --> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/day30_db</property> <property name="user">root</property> <property name="password">123</property> <!-- 如果池中数据连接不够时一次增长多少个 --> <property name="acquireIncrement">5</property> <!-- 初始化连接数 --> <property name="initialPoolSize">20</property> <!-- 最小连接数 --> <property name="minPoolSize">10</property> <!-- 最大连接数 --> <property name="maxPoolSize">40</property> <!-- -JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量 --> <property name="maxStatements">0</property> <!-- 连接池内单个连接所拥有的最大缓存statements数 --> <property name="maxStatementsPerConnection">5</property> </named-config> <!-- 命名的配置 --> <named-config name="heima"> <!-- 连接数据库的4项基本参数 --> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/day25_db</property> <property name="user">root</property> <property name="password">123</property> <!-- 如果池中数据连接不够时一次增长多少个 --> <property name="acquireIncrement">5</property> <!-- 初始化连接数 --> <property name="initialPoolSize">20</property> <!-- 最小连接受 --> <property name="minPoolSize">10</property> <!-- 最大连接数 --> <property name="maxPoolSize">40</property> <!-- -JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量 --> <property name="maxStatements">0</property> <!-- 连接池内单个连接所拥有的最大缓存statements数 --> <property name="maxStatementsPerConnection">5</property> </named-config>
*/
/*
3).使用连接池：
1).创建连接池对象：
ComboPooledDataSource dataSource = new ComboPooledDataSource();//寻找配置文件中的默认配置
或者
ComboPooledDataSource dataSource = new ComboPooledDataSource("baidu");//寻找配置文件中的命名配置
2).获取连接对象：
Connection conn = dataSource.getConnection();
3).发送SQL语句：
....
conn.close();//不是关闭，是回收
大家要掌握：
1.jar包位置，添加构建路径；
2.c3p0-config.xml文件的位置，内部的必须项的四项的修改：driverClass、jdbcUrl、user、password
3.ComboPooledDataSource的创建的两种方式；
4.以及后面要讲的DBUtils工具类；//C3P0连接池的使用 public class Demo { public static void main(String[] args) throws Exception { //1.创建C3P0的连接池对象 // ComboPooledDataSource dataSource = new ComboPooledDataSource();//寻找配置文件中的默认配置 ComboPooledDataSource dataSource = new ComboPooledDataSource(“baidu”);//寻找配置文件中的命名配置 //2.获取连接对象 Connection conn = dataSource.getConnection(); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(“select * from products”); while(rs.next()){ System.out.println(rs.getInt(“pid”) + “\t” + rs.getString(“pname”)); } rs.close(); stmt.close(); conn.close(); } }
04.DBUtils工具包_什么是DBUtils: 1.DBUtils工具包：它是数据库相关操作的工具包，内部封装了一些对数据库操作的一些相关方法，以及自动封装结果集的相关方法。 使用它可以简化我们的数据库开发的代码。 它是Apache的项目，免费开源的。
05.DBUtils工具包_自己使用JavaBean封装结果集：
JavaBean就是一个类，在开发中常用于封装数据。具有如下特性 1.需要实现接口：java.io.Serializable ，通常偷懒省略了。 2.提供私有字段：private 类型 字段名; 3.提供getter/setter方法： 4.提供无参构造
......
//遍历结果集
while(rs.next()){//遍历，封装的过程比较繁琐，DBUtils工具包就可以很方便的封装JavaBean
Products pro = new Products();
pro.setPid(rs.getInt("pid"));
pro.setPname(rs.getString("pname"));
pro.setPrice(rs.getInt("price"));
pro.setFlag(rs.getInt("flag"));
pro.setCategory_id(rs.getInt("category_id"));
//将对象添加到集合中
proList.add(pro);
}
.....//使用JavaBean封装结果集 public class Demo { public static void main(String[] args) throws Exception { //1.创建一个C3P0连接池对象 ComboPooledDataSource dataSource = new ComboPooledDataSource(); //2.获取连接对象 Connection conn = dataSource.getConnection();
//3.执行查询
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from products");
//定义集合
List<Products> proList = new ArrayList<>();
//遍历结果集
while(rs.next()){
Products pro = new Products();
pro.setPid(rs.getInt("pid"));
pro.setPname(rs.getString("pname"));
pro.setPrice(rs.getInt("price"));
pro.setFlag(rs.getInt("flag"));
pro.setCategory_id(rs.getInt("category_id"));
//将对象添加到集合中
proList.add(pro);
}
//释放资源
rs.close();
stmt.close();
conn.close();
//遍历集合
for(Products p : proList){
System.out.println(p);
}
}}
06.DBUtils工具包_DBUtils核心类 1).QueryRunner类：主要用于执行SQL语句； 2).ResultSetHandler接口 :有很多的子类，每种子类都表示一种封装结果集的方式。 3).DBUtils工具类：提供了一些跟事务处理相关的方法。 注意：DBUtils工具包，它内部不提供数据库的连接。它只负责发送SQL语句，执行SQL语句，封装结果集。 我们可以提供"连接池"对象，给QueryRunner使用。 07.DBUtils工具包_基本使用： 1).复制jar包到项目目录下； commons-dbutils-1.4.jar 2).由于它需要C3P0连接池，所以要将这个连接池配置好。 3).使用QueryRunner执行SQL语句： //1.添加 public void save() throws Exception{ //1.创建一个QueryRunner对象–使用连接池创建 QueryRunner qr = new QueryRunner(new ComboPooledDataSource()); //2.执行SQL语句–添加 String sql = “insert into products values(?,?,?,?,?)”; int row = qr.update(sql, 12,“索尼电视”,8000,1,1); System.out.println(“添加影响的行数：” + row); }
//2.修改
public void update() throws Exception{
//1.创建QueryRunner对象
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--修改
String sql = "update products set pname = ?,price = ?,flag = ?,category_id = ? where pid = ?";
int row = qr.update(sql,"索尼电视2",8002,0,3,12);
System.out.println("修改影响的行数：" + row);
}
//3.删除
@Test
public void delete() throws Exception{
//1.创建QueryRunner对象
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--删除
String sql = "delete from products where pid = ?";
int row = qr.update(sql,12);
System.out.println("删除影响的行数：" + row);
}08.DBUtils工具包_ResultSetHandler标记各种结果集【重点掌握】： 1).Object[] ArrayHandler : 用于查询一条记录，如果有多条，将结果集中的第一条记录封装到一个Object[]数组中，数组中的每一个元素就是这条记录中的每一个字段的值 如果没有查询结果，返回的是：空数组(0长度数组)，不是空指针 String sql = “select * from products where category_id = 20”; Object[] objArray = qr.query(sql, new ArrayHandler()); for(Object o : objArray){ System.out.println(o); } 2).List<Object[]> ArrayListHandler:用于查询多条记录。将结果集中的每一条记录都封装到一个Object[]数组中，将这些数组在封装到List集合中。 String sql = “select * from products”; List<Object[]> objList = qr.query(sql, new ArrayListHandler()); for(Object[] objArray : objList){//遍历行 for(Object o : objArray){//遍历列 System.out.print(o + “\t”); } System.out.println(); } 3).某个JavaBean BeanHandler:用于查询一条记录，将结果集中第一条记录封装到一个指定的javaBean中。 String sql = “select * from products where pid = 1”; Products pro = qr.query(sql, new BeanHandler(Products.class)); System.out.println(pro); 4).List<某个JavaBean> BeanListHandler:用于查询多条记录 将结果集中每一条记录封装到指定的javaBean中，将这些javaBean在封装到List集合中 String sql = “select * from products”; List proList = qr.query(sql, new BeanListHandler(Products.class)); for(Products p : proList){ System.out.println§; } 5).List ColumnListHandler:查询某个列的数据，将结果集中指定的列的字段值，封装到一个List集合中 String sql = “select pname from products”; List objList = qr.query(sql, new ColumnListHandler()); for(Object o : objList){ System.out.println(o); } 6).Map<Object,Map<String,Object>> KeyedHandler:查询多条记录。将结果集中每一条记录封装到Map<String,Object>,在将这个map集合做为另一个Map的value,另一个Map集合的key是指定的字段的值。 String sql = “select * from products”; Map<Object, Map<String, Object>> map = qr.query(sql, new KeyedHandler()); Set keys = map.keySet(); for(Object k : keys){ System.out.println(k); Map<String,Object> map2 = map.get(k); Set keys2 = map2.keySet(); for(String k2 : keys2){ System.out.println("\t" + k2 + " – " + map2.get(k2)); } } 7).Map<String,Object> MapHandler:用于查询一条记录。将结果集中第一条记录封装到了Map<String,Object>集合中，key就是字段名称，value就是字段值 String sql = “select * from products where pid = 1”; Map<String, Object> map = qr.query(sql, new MapHandler()); Set keys = map.keySet(); for(String k : keys){ System.out.println(“键：” + k + " 值：" + map.get(k)); } 8).List<Map<String,Object> MapListHandler：用于查询多条记录。将结果集中每一条记录封装到了Map<String,Object>集合中，key就是字段名称，value就是字段值，在将这些Map封装到List集合中。 String sql = “select * from products”; List<Map<String, Object>> mapList = qr.query(sql, new MapListHandler()); for(Map<String,Object> map : mapList){ Set keys = map.keySet(); for(String k : keys){ System.out.println(“键：” + k + " 值：" + map.get(k)); } System.out.println("--------------------------------"); } 9).Object ScalarHandler:它是用于单个数据。例如select count(*) from 表操作。 String sql = “select sum(price) from products”; Object result = qr.query(sql, new ScalarHandler()); System.out.println(“结果：” + result);
//DBUtils的基本使用 public class Demo { //1.添加 public void save() throws Exception{ //1.创建一个QueryRunner对象–使用连接池创建 QueryRunner qr = new QueryRunner(new ComboPooledDataSource()); //2.执行SQL语句–添加 String sql = “insert into products values(?,?,?,?,?)”; int row = qr.update(sql, 12,“索尼电视”,8000,1,1); System.out.println(“添加影响的行数：” + row); }
//2.修改
public void update() throws Exception{
//1.创建QueryRunner对象
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--修改
String sql = "update products set pname = ?,price = ?,flag = ?,category_id = ? where pid = ?";
int row = qr.update(sql,"索尼电视2",8002,0,3,12);
System.out.println("修改影响的行数：" + row);
}
//3.删除
public void delete() throws Exception{
//1.创建QueryRunner对象
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--删除
String sql = "delete from products where pid = ?";
int row = qr.update(sql,12);
System.out.println("删除影响的行数：" + row);
}
//4.查询
@Test
public void select() throws Exception{
//1.创建QueryRunner对象
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--查询
//1).ArrayHandler:将结果集中的第一条记录封装到一个Object[]数组中，数组中的每一个元素就是这条记录中的每一个字段的值
/*String sql = "select * from products where category_id = 20";
Object[] objArray = qr.query(sql, new ArrayHandler());
for(Object o : objArray){
System.out.println(o);
}*/
//2).List<Object[]> ArrayListHandler:用于查询多条记录。将结果集中的每一条记录都封装到一个Object[]数组中，将这些数组在封装到List集合中。
/*String sql = "select * from products";
List<Object[]> objList = qr.query(sql, new ArrayListHandler());
for(Object[] objArray : objList){//遍历行
for(Object o : objArray){//遍历列
System.out.print(o + "\t");
}
System.out.println();
}
*/
//3).BeanHandler:将结果集中第一条记录封装到一个指定的javaBean中。
/*String sql = "select * from products where pid = 1";
Products pro = qr.query(sql, new BeanHandler<Products>(Products.class));
System.out.println(pro);*/
//4).BeanListHandler:将结果集中每一条记录封装到指定的javaBean中，将这些javaBean在封装到List集合中
/*String sql = "select * from products";
List<Products> proList = qr.query(sql, new BeanListHandler<Products>(Products.class));
for(Products p : proList){
System.out.println(p);
}*/
//5).ColumnListHandler:查询某个列的数据，将结果集中指定的列的字段值，封装到一个List集合中
/*String sql = "select pname from products";
List<Object> objList = qr.query(sql, new ColumnListHandler());
for(Object o : objList){
System.out.println(o);
}
*/
//6).KeyedHandler:将结果集中每一条记录封装到Map<String,Object>,在将这个map集合做为另一个Map的value,另一个Map集合的key是指定的字段的值。
/*String sql = "select * from products";
Map<Object, Map<String, Object>> map = qr.query(sql, new KeyedHandler());
Set<Object> keys = map.keySet();
for(Object k : keys){
System.out.println(k);
Map<String,Object> map2 = map.get(k);
Set<String> keys2 = map2.keySet();
for(String k2 : keys2){
System.out.println("\t" + k2 + " -- " + map2.get(k2));
}
}*/
//7).MapHandler 将结果集中第一条记录封装到了Map<String,Object>集合中，key就是字段名称，value就是字段值
/*String sql = "select * from products where pid = 1";
Map<String, Object> map = qr.query(sql, new MapHandler());
Set<String> keys = map.keySet();
for(String k : keys){
System.out.println("键：" + k + " 值：" + map.get(k));
}*/
//8).MapListHandler 将结果集中每一条记录封装到了Map<String,Object>集合中，key就是字段名称，value就是字段值，在将这些Map封装到List集合中。
/*String sql = "select * from products";
List<Map<String, Object>> mapList = qr.query(sql, new MapListHandler());
for(Map<String,Object> map : mapList){
Set<String> keys = map.keySet();
for(String k : keys){
System.out.println("键：" + k + " 值：" + map.get(k));
}
System.out.println("--------------------------------");
}/ //9).ScalarHandler 它是用于单个数据。例如select count() from 表操作。 String sql = “select sum(price) from products”; Object result = qr.query(sql, new ScalarHandler()); System.out.println(“结果：” + result); } }
09.DBUtils工具包_QueryRunner的CRUD方法: 见demo05
//自定义工具类实现CRUD; public class JDBCUtils { private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
public static DataSource getDataSource(){
return dataSource;
}}
//自定义工具类实现CRUD (每个都有两种方法) public class Demo4 {
//1.添加
@Test
public void save() throws Exception {
//1.创建一个 QueryRunner对象--使用连接池创建
//核心类
//QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--添加
//String sql = "insert into car values(?,?,?,?,?)";
String sql = "insert into car (id,cname) values (?,?)";
//3.参数
Object[] params = {14,"捷达"};
//int update = qr.update(sql,11,"朗逸","大众","德国",14);
int update = qr.update(sql,params);
System.out.println("添加影响的行数:" + update);
}
//2.修改
@Test
public void update() throws Exception {
//1.创建QueryRunner对象
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
//2.执行SQL语句--修改
String sql = "update car set cname = ?,company = ?,grade = ?,price = ? where id = ?";
//3.参数
Object[] params = {"索纳塔","大众","德国",10,14};
int update = qr.update(sql, params);
//int update = qr.update(sql,"宝来","大众","德国",13,11);
System.out.println("修改影响的行数:" + update);
}
//3.删除
@Test
public void delete() throws Exception {
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
//2.sql
String sql = "delete from car where id = ?";
//3.参数
Object[] parms = {10};
int update = qr.update(sql,parms);
//int update = qr.update(sql,14);
System.out.println("删除影响的行数:" + update);
}
//4.通过ID查询
@Test
public void findById() throws Exception {
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "select * from car where id = ?";
//3.参数
Object[] parms = {8};
Products update = qr.query(sql, new BeanHandler<Products>(Products.class),parms);
//Products query = qr.query(sql, new BeanHandler<Products>(Products.class),9);
System.out.println(update);
}
//5.查询所有
@Test
public void findAll() throws Exception {
/*QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "select * from car";
List<Products> query = qr.query(sql, new BeanListHandler<Products>(Products.class));
for (Products products : query) {
System.out.println(products);
}*/
QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "select * from car";
Object[] parms = {};
List<Products> query = qr.query(sql, new BeanListHandler<Products>(Products.class),parms);
for (Products products : query) {
System.out.println(products);
}
}
//6.查询总记录
@Test
public void count() throws Exception {
/*QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
String sql = "select avg(price) from car";
Object query = qr.query(sql, new ScalarHandler());
System.out.println(query);*/
QueryRunner qr = new QueryRunner(new ComboPooledDataSource());
String sql = "select count(*) from car";
Object[] parms = {};
Object query = qr.query(sql, new ScalarHandler(),parms);
System.out.println(query);
}}
10.通过ResultSet获取列头信息： ResultSet rs = stmt.executeQuery(“select * from products”); ResultSetMetaData metaData = rs.getMetaData();//获取列的信息对象 int count = metaData.getColumnCount();//获取列的数量 System.out.println(“列数：” + count); for(int i = 1 ; i <= count ; i++){ System.out.println(“列名：” + metaData.getColumnName(i));//获取指定索引的列名。索引值从1开始 }
//通过ResultSet获取列头信息 public class Demo { public static void main(String[] args) throws Exception { Connection conn = JDBCUtils.getDataSource().getConnection(); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(“select * from products”); ResultSetMetaData metaData = rs.getMetaData(); int count = metaData.getColumnCount(); System.out.println(“列数：” + count); for(int i = 1 ; i <= count ; i++){ System.out.println(“列名：” + metaData.getColumnName(i)); } } }
============================================================================================================= 学习目标总结： 目标：能够理解连接池的原理 1.连接池就是一个存储了一些Connection对象的容器。可以先期缓存一些Connection对象，当用户使用时取出，当用户使用完毕时回收。 可以对这些Connection对象进行反复的重用，达到提高程序运行效率的目的。
目标：能够使用DBCP连接池 1.复制2个jar包； 2.复制配置文件到src目录下。
3.创建连接池：
1).读取配置文件：
Properties pro = new Properties();
pro.load(当前类名.class.getClassLoader().getResourceAsStream("配置文件名"));
2).通过工厂类获取连接池对象
BasicDataSource dataSource = (BasicDataSource)BasicDataSourceFactory.createDataSource(pro);
3).获取Connection对象
Connection conn = dataSource.getConncetion();
...
conn.close();//不是关闭，是回收目标：能够使用C3P0连接池 1.复制2个jar包； 2.复制配置文件c3p0-config.xml到src目录下； 3.创建连接池对象： 1).创建连接池对象 ComboPooledDataSource dataSource = new ComboPooledDataSource();//读取默认配置 //或者 ComboPooledDataSource dataSource = new ComboPooledDataSource(“baidu”);//读取命名配置 2).获取连接： Connection conn = dataSource.getConnection(); … conn.close();//不是关闭，是回收 目标：能够理解DBUtils工具类 1.对JDBC进行了封装，用于执行增删改查等SQL语句（主要用于查询–可以自动封装结果集） 目标：能够应用QueryRunner类 1.创建对象： QueryRunner qr = new QueryRunner(连接池对象);
2.发送SQL语句： 1).public int update(String sql,Object ... params):用于执行添加、修改、删除语句的。 2).public T query(String sql,ResultSetHandler<T> rsh,Object ... params):用于执行查询语句的。
目标：能够应用ResultSetHandler接口 1.Object[] ArrayHandler:用于查询一条记录；封装第一条记录 2.List<Object[]> ArrayListHandler:用于查询多条记录的。 3.某个Bean类型 BeanHandler : 查询一条，并自动封装JavaBean。 4.List<Bean类型> BeanListHandler:查询多条。 5.List ColumnListHandler : 查询某列的数据。 6.Map<Object , Map<String,Object>> KeyedHandler : 查询多条记录。 7.Map<String,Object> MapHandler : 查询一条记录； 8.List<Map<String,Object>> MapListHandler :查询多条记录 9.Object ScalarHandler : 查询聚合结果。单个数据
//DBCPUtiles工具类：
public class Utils_DBCP { private static DataSource ds; static{ Properties p = new Properties(); try{ p.load(Utils_DBCP.class.getClassLoader().getResourceAsStream(“dbcpconfig.properties”)); ds = BasicDataSourceFactory.createDataSource§; }catch(Exception e){ e.printStackTrace(); } } public static Connection getConnection(){ try{ return ds.getConnection(); }catch(SQLException e){ throw new RuntimeException(“创建连接连接失败！”); } } }
dbcpconfig.properties文件内容： driverClassName=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/test password=root username=root 上面的配置文件中的内容编写的依据是什么？源代码！！！！
测试代码: package DBCPUtils; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import org.junit.Test; public class Test001 { @Test public void demo01(){ //添加：向分类表中添加数据 Connection conn = null; PreparedStatement psmt = null; ResultSet rs = null; try { //1 获得连接 conn = Utils_DBCP.getConnection(); //2 处理sql语句 String sql = “insert into category(cid,cname) values(?,?)”; //3获得预处理对象 psmt = conn.prepareStatement(sql); //4设置实际参数 psmt.setString(1,“c009”); psmt.setString(2,“预处理12”); //5执行 int r = psmt.executeUpdate(); System.out.println®; } catch (Exception e) { throw new RuntimeException(e); } finally{ //6释放资源 //JdbcUtils.closeResource(conn, psmt, rs); } } }
//示例代码 @Test public void method(){ try { //获取QueryRunner对象 QueryRunner qr = new QueryRunner(); //执行SQL语句 String sql = “SELECT * FROM zhangwu”; Object[] params = {}; Connection conn = JDBCUtils.getConnection(); Object[] objArray = qr.query(conn, sql, new ArrayHandler(), params); //结果集的处理 System.out.println( Arrays.toString(objArray) );
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}示例代码： @Test public void method(){ try { //获取QueryRunner对象 QueryRunner qr = new QueryRunner(); //执行SQL语句 String sql = “SELECT * FROM zhangwu WHERE money>?”; Object[] params = {2000}; Connection conn = JDBCUtils.getConnection(); List<Object[]> list = qr.query(conn, sql, new ArrayListHandler(), params); //结果集的处理 for (Object[] objArray : list) { System.out.println( Arrays.toString(objArray) ); }
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}ColumnListHandler什么意思？怎么使用？必须保留一份操作代码！ 示例代码：
@Test public void method(){ try { //获取QueryRunner对象 QueryRunner qr = new QueryRunner(); //执行SQL语句 String sql = “SELECT name FROM zhangwu WHERE money>?”; Object[] params = {2000}; Connection conn = JDBCUtils.getConnection(); List list = qr.query(conn, sql, new ColumnListHandler(), params); //结果集的处理 for (String str : list) { System.out.println(str); }
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}本文参与腾讯云自媒体分享计划，欢迎正在阅读的你也加入，一起分享。
发表于
海仔技术驿站
87 篇文章16 人订阅
扫码关注云+社区
领取腾讯云代金券
我来说两句