-
其实就是一个容器（集合），存放数据库连接的容器。
- 当系统初始化好后，容器被创建，容器中会申请一些数据库连接对象，当用户来访问数据库时，从容器中获取连接对象，用户访问完数据库后回将连接归还给容器。
- 节约资源
- 用户访问高效
- 标准接口:DataSource java.sql包下的
- 方法
- 获取连接：getConnection()
- 归还连接：Connection.close().如果Connection是从连接池中获取的，那么close()方法，则不会关闭连接。而是归还连接
- 地址连接:Mchange Commons Java,C3P0
-
名称：c3p0.properties或者c3p0-config.xml
com.mysql.jdbc.Driver jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC root root 10 100 3000 com.mysql.jdbc.Driver jdbc:mysql://localhost:3306/bookstore root xxxx 10 30 100 10 -
路径：直接放在src目录下。
- 创建对象ComboPooledDataSource()
- 获取对象ds.getConnection()
package com.sql.one;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class C3P0Demo {
public static void main(String[] args) throws SQLException {
//创建数据库连接池对象
DataSource ds=new ComboPooledDataSource();
//获取连接对象
Connection conn=ds.getConnection();
//3.打印连接
System.out.println(conn);
}
}
package com.sql.one;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class C3P0Demo {
public static void main(String[] args) throws SQLException {
//创建数据库连接池对象，参数可以传入xml配置文件中的name使用其他廉价
DataSource ds=new ComboPooledDataSource();
//获取连接对象
// Connection conn=ds.getConnection();
//3.打印连接
for(int i=1;i<=10;i++){
Connection conns=ds.getConnection();
System.out.println(i+":"+conns);
if(i==5){
conns.close();//归还连接不是关闭
}
}
}
}
2.3 Druid 数据库连接池
1.依赖jar包
地址：https://mvnrepository.com/artifact/com.alibaba/druid
2.定义配置文件# 驱动加载 driverClassName=com.mysql.jdbc.Driver # 注册驱动 url=jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC # user username=root # password password=password123 # 初始化时池中建立的物理连接个数。 initialSize=2 # 最大的可活跃的连接池数量 maxActive=50 # 最长等待时间单位毫秒，60*1000 =1分钟 maxWait=60000
- 可以叫任意名称，可以放在任意目录下
-
通过工厂类来获取DruidDataSourceFactory
-
package com.sql.one; import com.alibaba.druid.pool.DruidDataSourceFactory; import javax.sql.DataSource; import java.io.InputStream; import java.util.Properties; import java.sql.Connection; public class DruidDemo { public static void main(String[] args)throws Exception{ //1.导入jar包 //2.加载配置文件 Properties pro =new Properties(); InputStream is =DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties"); pro.load(is); //4.获取连接池对象，使用工厂模式 DataSource ds= DruidDataSourceFactory.createDataSource(pro); //5.获取连接 Connection conn= ds.getConnection(); System.out.println(conn); } }
-
定义一个类JDBCUtils
-
提供静态代码块加载配置文件，初始化连接池对象
-
提供方法
- 获取连接方法：通过对数据库连接池获取连接
- 释放资源
- 获取连接池的方法
package com.sql.one;
import com.sql.jdbcutils.JDBCUtils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class DuridDemo2 {
public static void main(String[] args) {
try {
Connection conn= JDBCUtils.getConnection();
String sql="insert into t1 values(null,?,?)";
PreparedStatement pstmt= conn.prepareStatement(sql);
//给SQL中的？赋值
pstmt.setString(1,"逻辑");
pstmt.setInt(2,30);
int count=pstmt.executeUpdate();
System.out.println(count);
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
}
4.Spring JDBC
4.1 概述
调用JdbcTemplate的方法来完成CRUD操作
-
update():执行DML语句。增、删、改语句。
-
queryForMap():查询结果，将结果集封装为map集合
-
queryForList():查询结果封装为list集合
-
query():查询结果返回为JavaBean对象
-
queryForObject:查询结果，将结果封装为对象。
-
导入相关jar包
-
简单使用，但前提是要有数据库连接池DataSource
-
package com.sql.jdbctemplate; import com.sql.jdbcutils.JDBCUtils; import org.springframework.jdbc.core.JdbcTemplate; public class JDBCTemplate { public static void main(String[] args) { //1.导入jar包 //2.创建JDBCTemplate对象 JdbcTemplate template =new JdbcTemplate(JDBCUtils.getDataSource()); //3.调用方法 String sqlstr="insert into t1 values(null,?,?)"; int count = template.update(sqlstr, "史强", 30); System.out.println("插入"+count+"条数据成功"); } }
-
在函数名上加上注解@Test，则改函数可以独立执行，不依赖主方法。
- 返回插入数据库的条数。
package com.sql.jdbctemplate;
import com.sql.jdbcutils.JDBCUtils;
import org.testng.annotations.Test;
import org.springframework.jdbc.core.JdbcTemplate;
public class JdbcTemplateDemo2 {
//实例化JdbcTemplate
JdbcTemplate template= new JdbcTemplate(JDBCUtils.getDataSource());
//Junit 单元测试，可以让方法独立执行，使用@Test注解,
@Test
public void test1(){
String sqlstr="insert into t1 values(null,?,?)";
int count = template.update(sqlstr, "艾AA", 30);
System.out.println("插入"+count+"条数据成功");
//System.out.println("我被执行了");
}
}
2. queryForMap () 方法
-
返回map集合，只能有一个结果。
-
@Test public void test2(){ String sqlstr="select * from t1 where id=1"; Map -
两条返回结果就报错。因为map的键具有唯一性。
-
没有返回的结果也会报错。
-
查询结果封装为list集合，其中每条记录都会被封装在map集合，在封装在list中。
-
@Test public void test3(){ String sqlstr="select * from t1"; List
-
该方法最为常用。
-
new BeanPropertyRowMapper<类>(类.class)
-
-
返回JavaBean封装的对象。
-
首先创建好对应的类
package com.sql.jdbctemplate; public class Role { private Integer id; private String username; private Integer age;//使用引用的数据类型防止出现数据库中存在空值(null)的数据情况 public Role(Integer id, String username, Integer age) { this.id = id; this.username = username; this.age = age; } public Role() { } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } @Override public String toString() { return "Role{" + "id=" + id + ", username='" + username + ''' + ", age=" + age + '}'; } } -
第一种方法（比较繁琐，不建议使用）。
-
第二种方法
@Test public void test4(){ String sqlstr="select * from t1"; //使用泛型和反射将对应的JavaBean加载进内存进行使用 Listlist= template.query(sqlstr,new BeanPropertyRowMapper (Role.class)); for(Role r : list){ System.out.println(r); } } -
**注：**如果字段和bean中的字段不匹配，可以在SQL语句中起别名。
-
一般用来执行聚合函数的sql语句，例如count,sum,avg
-
@Test public void test5(){ String sqlstr="select count(1) from t1"; //除了SQL语句还要传入返回值的类型,返回值用指定的类型进行接收 Long count=template.queryForObject(sqlstr,Long.class); System.out.println(count); }
- 返回值：idea中ctrl+Alt+V快速生成返回值。
- for循环：iter增强for循环，fori普通for循环。
继续努力，终成大器！
