当前位置:   article > 正文

mysql数据库(工具类、DBUtils(应用)、数据库连接池、密码处理)_mysql语句执行工具类dbutil

mysql语句执行工具类dbutil

前情回顾

增删改查的工具类

操作数据库常用的执行方法:
execute()可以进行增删改查
executeUpdate() 可以执行增删改 但是不能执行查询
exeuctQuery():只可以执行查询
我们在封装这个工具类的时候,只需要封装两种:一种用来执行增删改操作,一种用来执行查询操作。
一般我们会将数据库中的表封装成一个类,那么表中的一条记录就对应这一个对象,字段就是类的属性。
因此一般我们也将与数据库直接交互的这一层代码称之为DAO层(Database access Object)

反射和泛型:
泛型:参数化类型 用在类上 方法上 接口上
反射:通过Class对象获得类中的属性,方法 ,构造方法
可以通过反射来创建对象,调用方法 ,访问属性或者为属性赋值

// 增删改查的工具类
public class CRUDTemplate {
/**
* 增删改操作
* @param sql sql语句
* @param params sql语句中的参数
* @return
*/
public static int executeUpdate(String sql,Object ... params){
Connection conn = null;
PreparedStatement pstmt = null;
int rows = 0;
try {
// 获取连接
conn = JDBCUtil.getConnection();
//获取sql语句的预编译对象
pstmt = conn.prepareStatement(sql);
//给占位符赋值
for (int i= 0 ;i <params.length;i++){
pstmt.setObject(i +1,params[i]);
}
// 执行sql
rows = pstmt.executeUpdate();
} catch (SQLException e) {
throw new RuntimeException(e);
}finally {
JDBCUtil.releaseSource(null,pstmt,conn);
}
return rows;
}
/**
* 查询操作
* @param sql
* @param handler
* @param params
* @return
* @param <T>
*/
public static <T> T executQuery(String sql,IResultSetHandler<T> handler, Object
... params){
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try{
conn = JDBCUtil.getConnection();
pstmt = conn.prepareStatement(sql);
for(int i = 0 ; i < params.length;i++){
pstmt.setObject(0 + 1,params[i]);
}
//执行sql 返回结果集
rs = pstmt.executeQuery();
//调用专门的结果集处理接口来处理结果集 至于返回的是什么类型的结果 有结果集处理器决定
return handler.handle(rs);
} catch (SQLException e) {
throw new RuntimeException(e);
}finally {
JDBCUtil.releaseSource(rs,pstmt,conn);
}
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60

这是一个数据库操作工具类,提供了增删改查的方法,其中:
executeUpdate()方法用于执行增删改操作,接收一个SQL语句和参数列表,返回受
影响的行数。
executQuery()方法用于执行查询操作,接收一个SQL语句、一个结果集处理器和参
数列表,返回处理后的结果。
该工具类中使用了JDBCUtil类提供的getConnection()和releaseSource()方法获取
和释放数据库连接。
该工具类中还使用了一个IResultSetHandler接口,用于处理查询结果集并返回指定
类型的结果。

//返回单个对象
public class BeanHandler<T> implements IResultSetHandler<T>{
private Class<T> clazz;
public BeanHandler(Class<T> clazz){
this.clazz = clazz;
}
@Override
public List<T> handle(ResultSet rs) throws SQLException, InstantiationException,
IllegalAccessException, IntrospectionException, InvocationTargetException {
List<T> list = new ArrayList<>();
if (rs.next()){
T obj = clazz.newInstance();//创建一个实例对象
// 获取字节码信息 拿到该类的属性 方法 等信息封装成BeanInfo
BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
// 获取所有的属性信息 获取所有的属性名称
PropertyDescriptor[] pds = beanInfo.getPropertyDescriptors();
for (PropertyDescriptor pd : pds){// 对每一个属性 依次读取数据库中的字段对应的值
并进行赋值操作
// 获取字段名称 将来在创建实体类的时候 要求属性名必须和字段名一致
Object o = rs.getObject(pd.getName());
//执行当前方法并传入参数
pd.getWriteMethod().invoke(obj,o);
}
list.add(obj);
if (list.size()>0)
return list;
}
return null;
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
public class BeanListHandler<T> implements IResultSetHandler<T>{
private Class<T> clazz;
public BeanListHandler(Class<T> clazz){
this.clazz = clazz;
}
@Override
public List<T> handle(ResultSet rs) throws SQLException, InstantiationException,
IllegalAccessException, IntrospectionException, InvocationTargetException {
// 获取字节码信息
BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
// 获取指定的属性信息
PropertyDescriptor[] pds = beanInfo.getPropertyDescriptors();
List<T> list = new ArrayList<>();
while(rs.next()){
T obj = clazz.newInstance();
for (PropertyDescriptor pd :pds){
// 获取字段名=属性名
Object o = rs.getObject(pd.getName());
pd.getWriteMethod().invoke(obj,o);
}
list.add(obj);
}
return list;
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
//把jdbc返回的结果集封装成特定类型
public interface IResultSetHandler<T> {
//专门用来处理结果集
// T handle(ResultSet rs) throws SQLException, InstantiationException,
IllegalAccessException, IntrospectionException, InvocationTargetException;
List<T> handle(ResultSet rs) throws SQLException, InstantiationException,
IllegalAccessException, IntrospectionException, InvocationTargetException;;
}



public class CRUDTemplateTest {
public static void main(String[] args) {
String sql = "select * from users ";
List<User> users = CRUDTemplate.executQuery(sql,new BeanListHandler<User>
(User. class));
System.out.println(users.size());
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19

CRUD的工具类

//返回单个对象
public class BeanHandler<T> implements IResultSetHandler<T>{
private Class<T> clazz;
public BeanHandler(Class<T> clazz){
this.clazz = clazz;
}
@Override
public T handle(ResultSet rs) throws SQLException, InstantiationException,
IllegalAccessException, IntrospectionException, InvocationTargetException {
if (rs.next()){
T obj = clazz.newInstance();//创建一个实例对象
// 获取字节码信息 拿到该类的属性 方法 等信息封装成BeanInfo
BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
// 获取所有的属性信息 获取所有的属性名称
PropertyDescriptor[] pds = beanInfo.getPropertyDescriptors();
for (PropertyDescriptor pd : pds){// 对每一个属性 依次读取数据库中的字段对应的值
并进行赋值操作
// 获取字段名称 将来在创建实体类的时候 要求属性名必须和字段名一致
Object o = rs.getObject(pd.getName());
//执行当前方法并传入参数
pd.getWriteMethod().invoke(obj,o);
}
return obj;
}
return null;
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
public class BeanListHandler<T> implements IResultSetHandler<List<T>>{
private Class<T> clazz;
public BeanListHandler(Class<T> clazz){
this.clazz = clazz;
}
@Override
public List<T> handle(ResultSet rs) throws SQLException, InstantiationException,
IllegalAccessException, IntrospectionException, InvocationTargetException {
// 获取字节码信息
BeanInfo beanInfo = Introspector.getBeanInfo(clazz, Object.class);
// 获取指定的属性信息
PropertyDescriptor[] pds = beanInfo.getPropertyDescriptors();
List<T> list = new ArrayList<>();
while(rs.next()){
T obj = clazz.newInstance();
for (PropertyDescriptor pd :pds){
// 获取字段名=属性名
Object o = rs.getObject(pd.getName());
pd.getWriteMethod().invoke(obj,o);
}
list.add(obj);
}
return list;
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25

DBUtils(应用)

DButils是一个为做一些准备如关闭连接,装载驱动 获得连接 提交事务 回滚事务 所有的方法都是静
态的
QueryRunner 简化了sql查询,CRUD
ResultSetHandler 接口 结果集的处理接口

public class DBUtilsTest {
@Test
public void insertData() throws SQLException {
Connection conn = JDBCUtil.getConnection();
//创建sql执行工具
QueryRunner qr = new QueryRunner();
String sql = "insert into tb_user(name,age,status,gender)values(?,?,?,?)";
int rows = qr.update(conn,sql,"张三",22,1,"男");
System.out.println(rows);
DbUtils.closeQuietly(conn);
}
@Test
public void updateData() throws SQLException {
Connection conn = JDBCUtil.getConnection();
//创建sql执行工具
QueryRunner qr = new QueryRunner();
String sql = "update tb_user set name =? where id=?";
int rows = qr.update(conn,sql,"李四",4);
System.out.println(rows);
DbUtils.closeQuietly(conn);
}
@Test
public void deleteData() throws SQLException {
Connection conn = JDBCUtil.getConnection();
//创建sql执行工具
QueryRunner qr = new QueryRunner();
String sql = "delete from tb_user where id=?";
int rows = qr.update(conn,sql,4);
System.out.println(rows);
DbUtils.closeQuietly(conn);
}
@Test
public void selectOneData() throws SQLException {
Connection conn = JDBCUtil.getConnection();
//创建sql执行工具
QueryRunner qr = new QueryRunner();
String sql = "select * from tb_user where id=?";
User user = qr.query(conn,sql, new BeanHandler<>(User.class),1);
System.out.println(user);
DbUtils.closeQuietly(conn);
}
@Test
public void selectAllData() throws SQLException {
Connection conn = JDBCUtil.getConnection();
//创建sql执行工具
QueryRunner qr = new QueryRunner();
String sql = "select * from tb_user ";
List<User> users = qr.query(conn,sql, new BeanListHandler<>(User.class));
System.out.println(users);
DbUtils.closeQuietly(conn);
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52

DBUtils对于事务的支持

/**
* 数据访问层
*/
public class BankDao {
/**
* 加钱的方法
* @param account 被转账的账户
* @param money 转账的金额
* @return
*/
public int addMoney(Connection conn,String account, int money) throws
SQLException {
String sql = "update account set money = money+? where aname=?";
QueryRunner qr = new QueryRunner();
int rows = qr.update(conn,sql,account,money);
return rows;
}
/**
* 减钱的方法
* @param account 转账的账户
* @param money 转账的金额
* @return
*/
public int subMoney(Connection conn,String account,int money) throws
SQLException {
String sql = "update account set money = money-? where aname=?";
QueryRunner qr = new QueryRunner();
int rows = qr.update(conn,sql,money,account);
return rows;
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
/**
* 业务类 实现转账操作
*/
public class BankService {
private BankDao dao = new BankDao();
public void transfer(String addAccount,String subAccount,double money){
Connection conn = JDBCUtil.getConnection();
// 开启事务(关闭自动提交)
try {
conn.setAutoCommit(false);
int i = dao.addMoney(conn,addAccount,money);
System.out.println(i);
System.out.println(10/0);
int a = dao.subMoney(conn,subAccount,money);
System.out.println(a);
DbUtils.commitAndClose(conn);
} catch (SQLException e) {
DbUtils.rollbackAndCloseQuietly(conn);
}
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21

当字段名和属性名不一致的时候

在查询的时候,给字段起别名 这样就可以结局不一致的问题。但是别名应该和属性名一致

@Test
public void selectOneData() throws SQLException {
Connection conn = JDBCUtil.getConnection();
//创建sql执行工具
QueryRunner qr = new QueryRunner();
String sql = "select id, name username,age userAge,status,gender from
tb_user where id=?";
User user = qr.query(conn,sql, new BeanHandler<>(User.class),1);
System.out.println(user);
DbUtils.closeQuietly(conn);
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11

当使用dbutils进行查询的时候,要么实体的属性名和字段名一致,要么给字段起别名 ,别名和属性名一致。
在这里插入图片描述
如果数据库中的字段名由多个单词组成,中间以下划线分隔。此时属性名应该遵循小驼峰命名法进行命名,
在查询数据看的时候,使用别名解决

数据库连接池技术

网址
常用的数据库连接池:DBCP、C3p0 国货之光 druid
JDBC的数据库连接池使用javax.sql.DataSource接口进行规范。

Druid数据库连接池的使用

通过硬编码的方式 得到连接池对象 从中获得连接

public class DruidTest {
@Test
public void druidTest() throws SQLException {
DruidDataSource dds = new DruidDataSource();
dds.setDriverClassName("com.mysql.cj.jdbc.Driver");
dds.setUrl("jdbc:mysql://localhost:3306/studydb");
dds.setUsername("root");
dds.setPassword("root");
// 获取连接
Connection conn = dds.getConnection();
System.out.println(conn);
conn.close();//释放连接 释放连接池
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14

通过外部配置:

//通过配置文件的方式得到Datasources
@Test
public void druidTest1() throws Exception {
Properties prop = new Properties();
InputStream in =
DruidTest.class.getClassLoader().getResourceAsStream("jdbc.properties");
prop.load(in);
DataSource ds = DruidDataSourceFactory.createDataSource(prop);
System.out.println(ds.getConnection());
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10

其他配置

driverClassName = com.mysql.cj.jdbc.Driver
url= jdbc:mysql://localhost:3306/studydb
username=root
password=root
#初始化连接数
initialSize=1
# 最小的空闲的连接数
minIdle=2
#最大的连接数
maxActive =5
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10

密码的处理

常见的加密方式:Base64加密算法,MD5加密,对称加密算 ,非对称加密算法,数字签名算法,数字整
数,CA认真等。
加密方式的使用场景:

  • Base64:图片的转码(发送邮件,img标签,http加密)
  • MD5加密:密码加密,文件的校验
  • 非对称加密:应用在互联网电商 订单付款,银行业务

MD5加密

基本的加密算法的底层原理

public class MD5Test {
public static void main(String[] args) {
String str = "123456";
// 生成普通的MD5的密码
MessageDigest md5 = null;
try {
//创建加密对象 同时指定加密算法为md5
md5 = MessageDigest.getInstance("MD5");
} catch (NoSuchAlgorithmException e) {
throw new RuntimeException(e);
}
char[] charArray = str.toCharArray();
byte[] byteArray = new byte[charArray.length];
for (int i = 0; i < charArray.length; i++) {
byteArray[i] = (byte) charArray[i];
}
byte[] md5Bytes = md5.digest(byteArray);
StringBuffer hexValue = new StringBuffer();
for (int j = 0; j < md5Bytes.length; j++) {
int val = (int) md5Bytes[j] & 0xff;
if (val < 16) {
hexValue.append("0");
} else {
hexValue.append(Integer.toHexString(val));
}
}
System.out.println(hexValue.toString());
}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29

使用工具类
Apache Commons Codec 1.15

public static void main(String[] args) {
String encode = DigestUtils.md5Hex("abc123456");
System.out.println(encode);
}
}
  • 1
  • 2
  • 3
  • 4
  • 5

加严加密:

public static void main(String[] args) {
//普通加密
String encode = DigestUtils.md5Hex("abc123456");
System.out.println(encode);
//加盐加密
String encode2 = Md5Crypt.apr1Crypt("abc123456","sxjzit");
System.out.println(encode2);
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

密码的校验:
MD5加密是不可逆的,在校验的时候 应该是对用户输入的密码在此加密,并且应该使用相同的盐。这样才能
保证两次加密的密文字符串相同。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小桥流水78/article/detail/1006283
推荐阅读
相关标签
  

闽ICP备14008679号