标签：dde ons cat 忘记 开发 throw 集合 actor ram
数据库连接池
连接池的概述
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/db3?useSSL=true
username=root
password=root
initialSize=5
maxActive=10
maxWait=3000
public class JDBCUtils {
/**
* 定义数据源
*/
private static DataSource ds;
static {
try {
/**
* 加载配置文件
*/
InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties");
Properties pro = new Properties();
pro.load(is);
/**
* 获取数据源
*/
ds = DruidDataSourceFactory.createDataSource(pro);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 获取数据源
* @return 返回数据源
*/
public static DataSource getDataSource(){
return ds;
}
/**
* 获取连接对象
* @return 返回连接对象
* @throws SQLException 抛出的编译异常
*/
public static Connection getConn() throws SQLException {
return ds.getConnection();
}
/**
* 关闭连接
* @param stmt sql执行对象
* @param conn 数据库连接对象
*/
public static void close(Statement stmt, Connection conn){
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 关闭资源的重载方法
* @param rs 处理结果集的对象
* @param stmt 执行sql语句的对象
* @param conn 连接数据库的对象
*/
public static void close(ResultSet rs, Statement stmt, Connection conn){
if(rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stmt != null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}}
JdbcTemplate
一般用于聚合函数的查询
public class SpringJdbcTemplateTest {
private static JdbcTemplate jdbcTemplate;
@Before
public void init(){
// 1. 导入jar包
// 2. 创建JDBCTemplate对象
jdbcTemplate = new JdbcTemplate(JdbcUtils.getDataSource());
}
@Test
public void testInsert(){
// 创建sql
String sql = "INSERT INTO ACCOUNT VALUES(NULL,?,?)";
// 执行sql,返回影响的行数
int lines = jdbcTemplate.update(sql, "王五", 5000);
System.out.println("影响的行数为：" + lines);
}
@Test
public void testUpdate(){
// 创建sql
String sql = "UPDATE ACCOUNT SET BALANCE = ? WHERE ID = ?";
// 执行sql,返回影响的行数
int lines = jdbcTemplate.update(sql, 3000, 3);
System.out.println("影响的行数为：" + lines);
}
@Test
public void testDelete(){
// 创建sql
String sql = "DELETE FROM ACCOUNT WHERE ID = ?";
// 执行sql,返回影响的行数
int lines = jdbcTemplate.update(sql, 3);
System.out.println("影响的行数为：" + lines);
}
@Test
public void testQueryForMap(){
// 3. 创建sql
String sql = "SELECT * FROM STUDENT WHERE ID = ?";
// 4. 使用查询语句进行查询(变长参数替换占位符)
Map<String, Object> map = jdbcTemplate.queryForMap(sql,7);
System.out.println(map);
}
@Test
public void testQueryForList(){
// 创建sql语句
String sql = "SELECT * FROM STUDENT";
// 执行sql，返回结果
List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);
// 处理结果
for (Map<String, Object> map : list) {
System.out.println(map);
}
}
/**
* queryForMap:将结果封装成Map，只能返回一条结果，
* 列名为Key，对应的值为Value
*/
@Test
public void testQuery(){
// 创建sql
String sql = "SELECT * FROM ACCOUNT";
// 执行sql(使用BeanPropertyRowMapper实现类。可以完成数据到JavaBean的自动封装)
List<Account> accounts = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Account.class));
// 处理结果
for (Account account : accounts) {
System.out.println(account);
}
}
@Test
public void testQueryForObject(){
// 创建sql
String sql = "SELECT COUNT(ID) FROM ACCOUNT";
// 执行sql,一般用于查询聚合函数（）
Long count = jdbcTemplate.queryForObject(sql,Long.class);
System.out.println();
}}
标签：dde ons cat 忘记 开发 throw 集合 actor ram
原文地址：https://www.cnblogs.com/wadmwz/p/9450914.html
