4.3、⭐Statement
Statement对象的作用就是用来执行SQL语句。而针对不同类型的SQL语句使用的方法也不一样。
(excute执行 quary查询)
方法 |
说明 |
|
执行DDL、DML语句 |
int executeUpdate(String sql) |
执行给定的SQL语句，这可能是INSERT， UPDATE，或 DELETE语句，或者不返回任何内容，如SQL中的DDL语句 |
执行DQL语句 |
ResultSet excuteQuery(String sql) |
执行给定的SQL语句，该语句返回单个 Resultset对象。 |
在开发中很少使用java代码操作DDL语句，原因如下：
- 数据库结构定义通常由数据库管理员负责，而不是开发人员。
- Java代码不是操作DDL语句最方便的方式，使用数据库管理工具(如MySQL Workbench)通常更方便。
- DDL语句很少需要在运行时进行更改，因此不太需要通过Java代码来操作。
- Java代码主要用于查询和更新数据，而不是定义数据结构。
4.4、ResultSet
JDBC步骤六：执行SQL：
方式一：->int executeUpdate(String sql)
方式二：->ResultSet excuteQuery(String sql)
ResultSet（结果集对象）作用： 封装了SQL查询语句的结果，执行了DQL语句后就会返回该对象
4.4.1、⭐⭐内部方法
ResultSet 对象提供了操作查询结果数据的方法：
①boolean next()
②xxx getXxx(参数)：获取数据
4.4.1.1、boolean next()
作用：将光标从当前位置向前移动一行，判断当前行是否为有效行
方法返回值说明：
true ： 有效行，当前行有数据
false ： 无效行，当前行没有数据
一开始光标指定于第一行前，指向于表头行。
当我们调用了 next() 方法后，光标就下移到第一行数据，并且方法返回true
4.4.1.2、xxx getXxx(参数)：获取数据
xxx : 数据类型；如： int getInt(参数) ；String getString(参数)
两种参数 ：
①int类型的参数：列的编号，从1开始，第一列为1，第二列为2…
String name = resultSet.getString("1");
②String类型的参数： 列的名称
String name = resultSet.getString("name");
4.4.1.3、⭐代码实现
需求：遍历得到数据库表单stu中的数据
stu：
1. package com.xzl; 2. 3. public class stu { 4. private String name; 5. private Integer math; 6. private String gender; 7. 8. public stu() { } 9. 10. public stu(String name, Integer math, String gender) { 11. this.name = name; 12. this.math = math; 13. this.gender = gender; 14. } 15. 16. public String getName() { 17. return name; 18. } 19. 20. public void setName(String name) { 21. this.name = name; 22. } 23. 24. public Integer getMath() { 25. return math; 26. } 27. 28. public void setMath(Integer math) { 29. this.math = math; 30. } 31. 32. public String getGender() { 33. return gender; 34. } 35. 36. public void setGender(String gender) { 37. this.gender = gender; 38. } 39. 40. @Override 41. public String toString() { 42. return "stu{" + 43. "name='" + name + '\'' + 44. ", math=" + math + 45. ", gender='" + gender + '\'' + 46. '}'; 47. } 48. }
jbdc：
1. package com.xzl; 2. 3. import java.sql.Connection; 4. import java.sql.DriverManager; 5. import java.sql.ResultSet; 6. import java.sql.Statement; 7. import java.util.ArrayList; 8. import java.util.Arrays; 9. import java.util.List; 10. 11. public class jdbc { 12. public static void main(String[] args) throws Exception { 13. //1、注册驱动 14. Class.forName("com.mysql.jdbc.Driver"); 15. //2、获取连接 16. String url = "jdbc:mysql://127.0.0.1:3306/student?useSSL=false"; 17. String username = "root"; 18. String password_P = "xzlXZGK680"; 19. Connection connection = DriverManager.getConnection(url,username,password); 20. //3、定义sql 21. // String sql1 = "insert into stu(name,math,gender) values('张三',85,'男')"; 22. // String sql2 = "insert into stu(name,math,gender) values('李四',75,'男')"; 23. // String sql3 = "insert into stu(name,math,gender) values('王五',90,'男')"; 24. String sql_dql = "select * from stu"; 25. //4. 获取执行sql的对象Statement 26. Statement statement = connection.createStatement(); 27. //创建集合存放接下来得到的表单数据 28. List<stu> list = new ArrayList<>(); 29. //此时需要开启事务之后再执行 30. try { 31. //禁用自动提交模式：false 32. connection.setAutoCommit(false); 33. //5、执行SQL->此处需要开启事务之后再执行 34. // int count1 = statement.executeUpdate(sql1); 35. // int count2 = statement.executeUpdate(sql2); 36. // int count3 = statement.executeUpdate(sql3); 37. ResultSet resultSet = statement.executeQuery(sql_dql); 38. 39. //6、处理结果（此处demo遍历得到stu中的所有数据并存放于集合） 40. while (resultSet.next()){ 41. //创建stu对象 42. stu student = new stu(); 43. String name = resultSet.getString("1"); 44. Integer math = resultSet.getInt(2); 45. String gender = resultSet.getString(3); 46. student.setName(name); 47. student.setMath(math); 48. student.setGender(gender); 49. //存入list集合 50. list.add(student); 51. 52. } 53. // ============提交事务========== 54. //程序运行到此处，说明没有出现任何问题，则需提交事务 55. connection.commit(); 56. }catch (Exception e){ 57. //事务程序出错，回滚事务 58. connection.rollback(); 59. e.printStackTrace(); 60. }finally { 61. //7、释放资源 62. statement.close(); 63. connection.close(); 64. } 65. System.out.println(Arrays.toString(list.toArray())); 66. } 67. }
5、数据库连接池
5.1、简介
数据库连接池是个容器，负责分配、管理数据库连接(Connection)。
它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个；
释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏
优点：
①资源重用
②提升系统响应速度
③避免数据库连接遗漏
之前的代码中使用连接是不管有没有使用都创建一个Connection对象，使用完毕就会将其销毁。
这样重复创建销毁的过程是特别耗费计算机的性能的及消耗时间。
而数据库使用了数据库连接池后，就能达到Connection对象的复用！
连接池是在一开始就创建好了一些连接（Connection）对象存储起来。
用户需要连接数据库时，不需要自己创建连接，而只需要从连接池中获取一个连接进行使用，使用完毕后再将连接对象归还给连接池；这样就可以起到资源重用，也节省了频繁创建连接销毁连接所花费的时间，从而提升了系统响应的速度
5.2、连接池的实现
标准接口：DataSource-> 官方(SUN) 提供的数据库连接池标准接口，由第三方组织实现此接口。
该接口提供了获取连接的功能，以后就不需要通过 DriverManager 对象获取Connection对象，而是通过连接池(DataSource)获取Connection对象。
5.2.1、⭐常见的数据库连接池
- DBCP:Apache基金会提供的数据库连接池实现，具有简单易用、性能稳定等优点。
- C3P0:开源的数据库连接池实现，支持自动回收空闲连接、自动重新获取失效连接等功能。
- Druid
- HikariCP：一款高性能的数据库连接池实现，支持多种数据库，具有轻量级、高效率、可靠稳定等特点。
- BoneCP：一款高性能的数据库连接池实现，支持多种数据库，具有高并发能力、可靠稳定等特点。
现在使用更多的是Druid.
Druid是阿里巴巴开源的一款高性能、稳定、安全的数据库连接池实现。
它支持多种数据库，具有以下特点：
- 高性能：采用高效的缓存机制，提高数据库连接的利用率，提升数据库性能。
- 稳定可靠：支持连接池、防止攻击、SQL监控等功能，保证数据库的安全性和稳定性。
- 实时监控：提供实时的数据监控、性能分析和数据统计功能，方便用户对数据库性能进行诊断和优化。
- 易用易扩展：提供丰富的API和扩展接口，方便用户定制和扩展功能，同时易于集成到各种应用系统中。
Druid是一款优秀的数据库连接池实现，适用于各种数据库应用场景，推荐使用。
5.3、🔺Druid的使用->IDEA
步骤：
①导入jar包 druid-1.1.12.jar
②定义配置文件
③加载配置文件
④获取数据库连接池对象
⑤获取连接
5.3.1、导jar包
放在lib目录下，并添加到项目依赖：
5.3.2、定义配置文件
配置文件可以从外部导入，也可以自己新建编写，此处是自己编写。
配置文件要放在src目录下
5.3.2.1、 🔺⭐druid.properties
Druid的配置文件druid.properties是Druid数据库连接池的主要配置文件，它包含了Druid数据库连接池的各项配置参数，控制Druid运行的行为。
下面是druid.properties文件的常见配置项：
- 驱动相关配置：
- driverClassName：指定数据库驱动类名；
- url：指定数据库连接地址；
- username：指定数据库用户名；
- password：指定数据库密码。
- 连接池相关配置：
- initialSize：初始连接数；
- maxActive：最大连接数；
- minIdle：最小空闲连接数；
- maxWait：获取连接的最大等待时间。
- 监控相关配置(后面再详细学习)：
- filters：指定Druid监控的拦截器；
- connectionProperties：指定连接的其他属性；
- stat：是否开启Druid监控。
示例：
1. #驱动相关配置 2. driverClassName=com.mysql.jdbc.Driver 3. url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8 4. username=root 5. password=root 6. 7. #连接池相关配置 8. initialSize=10 9. maxActive=20 10. minIdle=5 11. maxWait=60000 12. 13. #监控相关配置 14. filters=stat,wall 15. connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000 16. stat=true
5.3.2.1.1、监控相关配置
druid的监控相关配置一般是写在properties文件中，也就是druid.properties文件中。这样做的好处是可以随时修改配置文件来更改druid的配置，而不需要重新编译客户端代码。
当然，也可以通过客户端代码的方式来配置druid的监控相关配置。具体的方法是使用DruidDataSource类来配置监控相关配置。
以下是常用的监控配置的Java代码示例：
1. DruidDataSource dataSource = new DruidDataSource(); 2. 3. // 设置是否合并SQL 4. dataSource.setConnectionProperties("druid.stat.mergeSql=true"); 5. 6. // 设置统计慢SQL的时间 7. dataSource.setConnectionProperties("druid.stat.slowSqlMillis=5000"); 8. 9. // 设置是否打印慢SQL日志 10. dataSource.setConnectionProperties("druid.stat.logSlowSql=true"); 11. 12. // 设置是否开启Web统计页面 13. dataSource.setConnectionProperties("druid.web.stat.enabled=true"); 14. 15. // 设置访问监控页面的用户名 16. dataSource.setConnectionProperties("druid.web.stat.loginUsername=druid"); 17. 18. // 设置访问监控页面的密码 19. dataSource.setConnectionProperties("druid.web.stat.loginPassword=druid");
下面是druid.properties中常见的监控相关配置项：
- 配置监控控制台：
druid.stat.mergeSql=true
druid.stat.logSlowSql=true
druid.web.stat.enabled=true
druid.web.stat.urlPattern=/*
druid.web.stat.resetEnable=false
druid.web.stat.sessionStatEnable=false
druid.web.stat.sessionStatMaxCount=1000
druid.web.stat.principalSessionName=user
druid.web.stat.principalCookieName=user
druid.web.stat.profileEnable=false
- 配置监控数据源：
druid.monitor.log.enabled=false
druid.monitor.log.intervalSeconds=30
注意：上面的配置仅仅是druid.properties监控相关配置的常见配置项，详细配置请参考druid官方文档。
5.3.2.2、简单demo代码
1. driverClassName=com.mysql.jdbc.Driver 2. url=jdbc:mysql://127.0.0.1:3306/student?useSSL=false&useServePrepStmts=true 3. username=root 4. password=xzlXZGK680 5. initialSize=5 6. maxActive=15 7. minIdle=5 8. maxWait=3000
5.3.3、使用Druid
1. import com.alibaba.druid.pool.DruidDataSourceFactory; 2. 3. import javax.sql.DataSource; 4. import java.io.FileInputStream; 5. import java.sql.Connection; 6. import java.util.Properties; 7. 8. public class DruidDemo { 9. public static void main(String[] args) throws Exception { 10. //1.导入jar包 11. //2.定义配置文件 12. //3. 加载配置文件 13. Properties properties = new Properties(); 14. properties.load(new FileInputStream("src/druid.properties")); 15. //4、获取连接池对象 16. DataSource dataSource = DruidDataSourceFactory.createDataSource(properties); 17. //5、获取数据库连接Connection 18. Connection connection = dataSource.getConnection(); 19. System.out.println(connection); 20. //获取到数据库连接之后就可以继续进行其他操作了 21. } 22. }
