参考资料1. JDBC概述
1.1 概念1.2 本质1.3 JDBC好处 2. JDBC快速入门
2.1 编写代码步骤2.2 具体操作 3. JDBC API详解
3.1 DriverManager3.2 Connection
1. 获取执行sql对象2. 事务管理 3.3 Statement
1. 概述 3.4. ResultSet3.5 案例3.6 PreparedStatement
1. SQL注入2. PreparedStatement概述3. 使用PreparedStatement改进4. PreparedStatement原理
通过查询日志来看一下原理。 4. 数据库连接池
4.1. 数据库连接池简介4.2 数据库连接池实现4.3 Driud使用 5. JDBC练习
5.1 需求5.2 案例实现
1. 数据准备2. 查询3. 添加数据4. 修改数据5. 删除数据
参考资料- https://www.bilibili.com/video/BV1Qf4y1T7Hx?p=30&spm_id_from=pageDriver
本笔记是基于黑马程序员的课件以及视频资料所做。所涉及的资料可在下面的度盘链接找到：
1. JDBC概述 1.1 概念链接：https://pan.baidu.com/s/1g9vV_zmS9l-f0NYw8xevAQ
提取码：3ze7
复制这段内容后打开百度网盘手机App，操作更方便哦
在开发中我们使用的是java语言，那么势必要通过java语言操作数据库中的数据。这就是接下来要学习的JDBC。
JDBC 就是使用Java语言操作关系型数据库的一套API。全称：( Java Database Connectivity ) Java 数据库连接
我们开发的同一套Java代码是无法操作不同的关系型数据库，因为每一个关系型数据库的底层实现细节都不一样。如果这样，问题就很大了，在公司中可以在开发阶段使用的是MySQL数据库，而上线时公司最终选用oracle数据库，我们就需要对代码进行大批量修改，这显然并不是我们想看到的。我们要做到的是同一套Java代码操作不同的关系型数据库，而此时sun公司就指定了一套标准接口（JDBC），JDBC中定义了所有操作关系型数据库的规则。众所周知接口是无法直接使用的，我们需要使用**接口的实现类，而这套实现类（称之为：驱动）**就由各自的数据库厂商给出。
1.2 本质官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口各个数据库厂商去实现这套接口，提供数据库驱动jar包我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类 1.3 JDBC好处
各数据库厂商使用相同的接口，Java代码不需要针对不同数据库分别开发可随时替换底层数据库，访问数据库的Java代码基本不变
以后编写操作数据库的代码只需要面向JDBC（接口），操作哪个关系型数据库就需要导入该数据库的驱动包，如需要操作MySQL数据库，就需要在项目中导入MySQL数据库的驱动包。如下图就是MySQL驱动包
2. JDBC快速入门先来看看通过Java操作数据库的流程
第一步：编写Java代码
第二步：Java代码将SQL发送到MySQL服务端
第三步：MySQL服务端接收到SQL语句并执行该SQL语句
第四步：将SQL语句执行的结果返回给Java代码
2.1 编写代码步骤
创建工程，导入驱动jar包
注册驱动
Class.forName("com.mysql.jdbc.Driver");
获取连接
Connection conn = DriverManager.getConnection(url, username, password);
Java代码需要发送SQL给MySQL服务端，就需要先建立连接
定义SQL语句
String sql = “update…” ;
获取执行SQL对象
执行SQL语句需要SQL执行对象，而这个执行对象就是Statement对象
Statement stmt = conn.createStatement();
执行SQL
stmt.executeUpdate(sql);
处理返回结果
释放资源
2.2 具体操作
创建新的项目、模块
导入驱动包，将mysql的驱动包放在模块下的lib目录（随意命名）下，并将该jar包添加为库文件
在添加为库文件的时候，有如下三个选项
Global Library ： 全局有效Project Library : 项目有效Module Library ： 模块有效
设为模块有效即可。
创建类，编写代码：
public class JdbcDemo {
public static void main(String[] args) throws Exception {
//1. 注册驱动 mysql5.0后可省略
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接,testtable为要连接的数据库
String url = "jdbc:mysql://127.0.0.1:3306/testtable";
String username = "root";
String password = "5213";
Connection conn = DriverManager.getConnection(url, username, password);
//3. 定义sql
String sql = "update account set money = 2000 where id = 1";
//4. 获取执行sql的对象 Statement
Statement stmt = conn.createStatement();
//5. 执行sql
int count = stmt.executeUpdate(sql);//受影响的行数
//6. 处理结果
System.out.println(count);
//7. 释放资源
stmt.close();
conn.close();
}
}
运行测试即可。
account表格创建很简单
create table account
(
id int auto_increment comment '主键ID'
primary key,
name varchar(10) null comment '姓名',
money int null comment '余额'
)
comment '账户表';
3. JDBC API详解
3.1 DriverManager
DriverManager（驱动管理类）作用：
注册驱动
registerDriver方法是用于注册驱动的，但之前做的入门案例是如下实现
Class.forName("com.mysql.jdbc.Driver");
我们查询MySQL提供的Driver类，源码如下：
在该类中的静态代码块中已经执行了 DriverManager 对象的 registerDriver() 方法进行驱动的注册了，那么我们只需要加载 Driver 类，该静态代码块就会执行。而 Class.forName("com.mysql.jdbc.Driver"); 就可以加载 Driver 类。
提示：
MySQL 5之后的驱动包，可以省略注册驱动的步骤自动加载jar包中meta-INF/services/java.sql.Driver文件中的驱动类
获取数据库连接
Connection conn = DriverManager.getConnection(url, username, password);
参数说明：
url ： 连接路径
语法：jdbc:mysql://ip地址(域名):端口号/数据库名称?参数键值对1&参数键值对2…
示例：jdbc:mysql://127.0.0.1:3306/testtable
细节：
如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为：jdbc:mysql:///数据库名称?参数键值对
jdbc:mysql:///testtable配置 useSSL=false 参数，禁用安全连接方式，解决警告提示
user ：用户名
poassword ：密码
3.2 ConnectionConnection（数据库连接对象）作用：
获取执行 SQL 的对象管理事务 1. 获取执行sql对象
普通执行SQL对象
Statement stmt = conn.createStatement();
入门案例中就是通过该方法获取的执行对象。
预编译SQL的执行SQL对象：防止SQL注入
PreparedStatement preparedStatement = conn.prepareStatement(sql);
通过这种方式获取的 PreparedStatement SQL语句执行对象是我们一会重点要进行讲解的，它可以防止SQL注入。
执行存储过程的对象
CallableStatement prepareCall = conn.prepareCall(sql);
通过这种方式获取的 CallableStatement 执行对象是用来执行存储过程的，而存储过程在MySQL中不常用，所以这个我们将不进行讲解。
2. 事务管理MySQL事务管理的操作：
开启事务 ： BEGIN; 或者 START TRANSACTION;提交事务 ： COMMIT;回滚事务 ： ROLLBACK;
MySQL默认是自动提交事务
Connection接口中定义了3个对应的方法：
开启事务
connection.setAutoCommit(false);
参与autoCommit 表示是否自动提交事务，true表示自动提交事务，false表示手动提交事务。而开启事务需要将该参数设为为false。
提交事务
connection.commit();
回滚事务
connection.rollback();
完整代码：
package pers.chh3213.jdbc_demo;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Stack;
public class JdbcCommit {
public static void main(String[] args) throws Exception {
String url = "jdbc:mysql:///testtable";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
// 定义sql语句
String sql1 = "update account set money = 3000 where id = 1";
String sql2 = "update account set money = 3002 where id = 2";
Statement statement = connection.createStatement();
try {
connection.setAutoCommit(false);
int c1 = statement.executeUpdate(sql1);
int c2 = statement.executeUpdate(sql2);
//int x = 3/0; //异常
System.out.println(c1);
System.out.println(c2);
connection.commit();
} catch (SQLException e) {
connection.rollback();
e.printStackTrace();
}finally {
statement.close();
connection.close();
}
}
}
3.3 Statement
1. 概述
Statement对象的作用就是用来执行SQL语句。而针对不同类型的SQL语句使用的方法也不一样。
执行DDL、DML语句
执行DQL语句
该方法涉及到了 ResultSet 对象，而这个对象我们还没有学习，一会再重点讲解。
示例：
public class DDL_DML_Demo {
@Test
public void testDML() throws SQLException {
String url = "jdbc:mysql:///testtable";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
String sql1 = "insert account values(3,"tom",500);";
Statement statement = connection.createStatement();
// DML语句，返回表格中受影响的行数
int cnt = statement.executeUpdate(sql1);
System.out.println(cnt);
statement.close();
connection.close();
}
@Test
public void testDDL() throws SQLException {
String url = "jdbc:mysql:///testtable";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
Statement statement = connection.createStatement();
String sql2 = "create database db4";
int cnt2 = statement.executeUpdate(sql2);
System.out.println(cnt2);
statement.close();
connection.close();
}
}
注意：
以后开发很少使用java代码操作DDL语句 3.4. ResultSet
ResultSet（结果集对象）作用：
封装了SQL查询语句的结果。
而执行了DQL语句后就会返回该对象，对应执行DQL语句的方法如下：
ResultSet executeQuery(sql)：执行DQL 语句，返回 ResultSet 对象
那么我们就需要从 ResultSet 对象中获取我们想要的数据。ResultSet 对象提供了操作查询结果数据的方法，如下：
boolean next()
将光标从当前位置向前移动一行判断当前行是否为有效行
方法返回值说明：
true ： 有效行，当前行有数据false ： 无效行，当前行没有数据
xxx getXxx(参数)：获取数据
xxx : 数据类型；如： int getInt(参数) ；String getString(参数)参数
int类型的参数：列的编号，从1开始String类型的参数： 列的名称
如下图为执行SQL语句后的结果
一开始光标指定于第一行前，如图所示红色箭头指向于表头行。当我们调用了 next() 方法后，光标就下移到第一行数据，并且方法返回true，此时就可以通过 getInt("id") 获取当前行id字段的值，也可以通过 getString("name") 获取当前行name字段的值。如果想获取下一行的数据，继续调用 next() 方法，以此类推。
示例
package pers.chh3213.jdbc_demo;
import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class TestExecuteQuery {
@Test
public void test() throws Exception {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql:///testtable?useSSL=false";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
Statement statement = connection.createStatement();
String sql = "select * from account";
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()){
int id = resultSet.getInt("id");
//String name = resultSet.getString(2);
String name = resultSet.getString("name");
int money = resultSet.getInt("money");
System.out.printf("%d ,%s,%d",id,name,money);
System.out.println();
}
resultSet.close();
statement.close();
connection.close();
}
3.5 案例
需求：查询account账户表数据，将每条数据封装为Account对象，并且存储到ArrayList集合中.
Account类：
package pers.chh3213.pojo;
public class Account {
private int id;
private String name;
private int money;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getMoney() {
return money;
}
public void setMoney(int money) {
this.money = money;
}
public void setAll(int id,String name, int money){
this.id = id;
this.name = name;
this.money = money;
}
@Override
public String toString() {
return "Account{" +
"id=" + id +
", name='" + name + ''' +
", money=" + money +
'}';
}
}
操作类：
package pers.chh3213.pojo;
import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Arrays;
public class AccountDemo {
@Test
public void test() throws Exception {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql:///testtable?useSSL=false";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
Statement statement = connection.createStatement();
String sql = "select * from account";
ResultSet resultSet = statement.executeQuery(sql);
ArrayList arrayList = new ArrayList<>();
while (resultSet.next()){
Account account = new Account();
int id = resultSet.getInt("id");
// 以下两者等价
//String name = resultSet.getString(2);
String name = resultSet.getString("name");
int money = resultSet.getInt("money");
account.setAll(id,name,money);
arrayList.add(account);
}
System.out.println(arrayList);
resultSet.close();
statement.close();
connection.close();
}
}
3.6 PreparedStatement
PreparedStatement作用：
预编译SQL语句并执行：预防SQL注入问题
对上面的作用中SQL注入问题大家肯定不理解。那我们先对SQL注入进行说明.。
1. SQL注入SQL注入是通过操作输入来修改事先定义好的SQL语句，用以达到执行代码对服务器进行攻击的方法。
示例
先创建一个简单的表格
package pers.chh3213.prepare_statement;
import org.junit.Test;
import java.sql.*;
public class InjectTest {
@Test
public void testLogin() throws Exception {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql:///testtable?useSSL=false";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
Statement statement = connection.createStatement();
String name = "tomds";
//String password = "1234";
// 注入操作
String password = "'or '1'='1";
String sql = "select * from tb_users where username = '"+name+"' and password = '"+password+"'";
ResultSet resultSet = statement.executeQuery(sql);
if(resultSet.next()){
System.out.println("login success");
}else{
System.out.println("login failed");
}
resultSet.close();
statement.close();
connection.close();
}
}
上面代码是将用户名和密码拼接到sql语句中，拼接后的sql语句如下
select * from tb_users where username = 'tomds' and password = ''or '1' = '1'
从上面语句可以看出条件 username = 'tomds' and password = '' 不管是否满足，而 or 后面的 '1' = '1' 是始终满足的，最终条件是成立的，就可以正常的进行登陆了。
2. PreparedStatement概述PreparedStatement作用：
预编译SQL语句并执行：预防SQL注入问题
获取 PreparedStatement 对象
// SQL语句中的参数值，使用？占位符替代 String sql = "select * from user where username = ? and password = ?"; // 通过Connection对象获取，并传入对应的sql语句 PreparedStatement pstmt = conn.prepareStatement(sql);
设置参数值
上面的sql语句中参数使用 ? 进行占位，在之前之前肯定要设置这些? 的值。
PreparedStatement对象：setXxx(参数1，参数2)：给 ? 赋值
Xxx：数据类型 ； 如 setInt (参数1，参数2)
参数：
参数1： ？的位置编号，从1 开始
参数2： ？的值
执行SQL语句
3. 使用PreparedStatement改进executeUpdate(); 执行DDL语句和DML语句
executeQuery(); 执行DQL语句
注意：
调用这两个方法时不需要传递SQL语句，因为获取SQL语句执行对象时已经对SQL语句进行预编译了。
package pers.chh3213.prepare_statement;
import org.junit.Test;
import java.sql.*;
public class TestPreparedStatement {
@Test
public void test() throws Exception {
//Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql:///testtable?useSSL=false";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
String name = "tom";
//String password = "1234";
// 注入操作
String password = "'or '1'='1";
//设置preparedStatement
String sql = "select * from tb_users where username =? and password=?";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1,name);
preparedStatement.setString(2,password);
ResultSet resultSet = preparedStatement.executeQuery();
if(resultSet.next()){
System.out.println("login success");
}else{
System.out.println("login failed");
}
resultSet.close();
preparedStatement.close();
connection.close();
}
}
执行上面语句就可以发现不会出现SQL注入漏洞问题了。那么PreparedStatement又是如何解决的呢？它是将特殊字符进行了转义(加反斜杠)，转义的SQL如下：
select * from tb_users where username = 'tom' and password = ''or '1' = '1'4. PreparedStatement原理
PreparedStatement 好处：
预编译SQL，性能更高。在代码中编写url时需要加上以下参数开启预编译功能：useServerPrepStmts=true防止SQL注入：将敏感字符进行转义
Java代码操作数据库流程如图所示：
将sql语句发送到MySQL服务器端
MySQL服务端会对sql语句进行如下操作
检查SQL语句
检查SQL语句的语法是否正确。
编译SQL语句。将SQL语句编译成可执行的函数。
检查SQL和编译SQL花费的时间比执行SQL的时间还要长。如果我们只是重新设置参数，那么检查SQL语句和编译SQL语句将不需要重复执行。这样就提高了性能。
执行SQL语句
通过查询日志来看一下原理。
开启预编译功能
在代码中编写url时需要加上以下参数。而我们之前根本就没有开启预编译功能，只是解决了SQL注入漏洞。
useServerPrepStmts=true
配置MySQL执行日志（重启mysql服务后生效）
在mysql配置文件（my.ini）中添加如下配置
log-output=FILE general-log=1 general_log_file="D:mysql.log" slow-query-log=1 slow_query_log_file="D:mysql_slow.log" long_query_time=2
java测试代码如下：
package pers.chh3213.prepare_statement;
import org.junit.Test;
import java.sql.*;
public class TestPreparedStatement {
@Test
public void test() throws Exception {
//Class.forName("com.mysql.jdbc.Driver");
// 加上useServerPrepStmts=true开启预编译功能
String url = "jdbc:mysql:///testtable?useSSL=false&useServerPrepStmts=true";
String user = "root";
String pwd = "5213";
Connection connection = DriverManager.getConnection(url, user, pwd);
String name = "tom";
//String password = "1234";
// 注入操作
String password = "'or '1'='1";
String sql = "select * from tb_users where username =? and password=?";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1,name);
preparedStatement.setString(2,password);
Thread.sleep(10000);
ResultSet resultSet = preparedStatement.executeQuery();
if(resultSet.next()){
System.out.println("login success");
}else{
System.out.println("login failed");
}
resultSet.close();
preparedStatement.close();
connection.close();
}
}
执行SQL语句，查看 D:mysql.log 日志。
小结：
在获取PreparedStatement对象时，将sql语句发送给mysql服务器进行检查，编译（这些步骤很耗时）执行时就不用再进行这些步骤了，速度更快如果sql模板一样，则只需要进行一次检查、编译 4. 数据库连接池 4.1. 数据库连接池简介
数据库连接池是个容器，负责分配、管理数据库连接(Connection)
它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个；
释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏
好处
资源重用提升系统响应速度避免数据库连接遗漏
之前我们代码中使用连接时是创建一个Connection对象，使用完毕就会将其销毁。这样重复创建销毁的过程是特别耗费计算机的性能的及消耗时间的。
而数据库使用了数据库连接池后，就能达到Connection对象的复用，如下图
连接池是在一开始就创建好了一些连接（Connection）对象存储起来。用户需要连接数据库时，不需要自己创建连接，而只需要从连接池中获取一个连接进行使用，使用完毕后再将连接对象归还给连接池；这样就可以起到资源重用，也节省了频繁创建连接销毁连接所花费的时间，从而提升了系统响应的速度。
4.2 数据库连接池实现
标准接口：DataSource
官方(SUN) 提供的数据库连接池标准接口，由第三方组织实现此接口。该接口提供了获取连接的功能：
Connection getConnection()
那么以后就不需要通过 DriverManager 对象获取 Connection 对象，而是通过连接池（DataSource）获取 Connection 对象。
常见的数据库连接池
DBCPC3P0Druid
我们现在使用更多的是Druid，它的性能比其他两个会好一些。
Druid（德鲁伊）
Druid连接池是阿里巴巴开源的数据库连接池项目
功能强大，性能优秀，是Java语言最好的数据库连接池之一
4.3 Driud使用步骤：
导入jar包 druid-1.1.12.jar定义配置文件加载配置文件获取数据库连接池对象获取连接
首先需要先将druid的jar包放到项目下的lib下并添加为库文件
编写配置文件druid.properties
driverClassName=com.mysql.jdbc.Driver # 配置url，用户名和密码 url=jdbc:mysql:///testtable?useSSL=false&useServerPrepStmts=true username=root password=5213 # 初始化连接数量 initialSize=5 # 最大连接数 maxActive=10 # 最大等待时间 maxWait=3000
加载配置文件、获取数据库连接池对象、获取连接
package pers.chh3213.druid;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.junit.Test;
import javax.sql.DataSource;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
public class DruidTest {
@Test
public void test() throws Exception {
//1.导入jar包
//2.定义配置文件
//3. 加载配置文件
Properties properties = new Properties();
// 通过这种方式获取当前文件的所在路径
System.out.println(System.getProperty("user.dir"));
properties.load(new FileInputStream("src/pers/chh3213/druid/druid.properties")
);
//4. 获取连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//5. 获取数据库连接 Connection
Connection connection = dataSource.getConnection();
System.out.println(connection);
// 后面就是之前的常规操作了···
Statement statement = connection.createStatement();
String sql = "select * from account";
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()){
int id = resultSet.getInt("id");
// 以下两者等价
//String name = resultSet.getString(2);
String name = resultSet.getString("name");
int money = resultSet.getInt("money");
System.out.printf("%d ,%s,%d",id,name,money);
System.out.println();
}
resultSet.close();
statement.close();
connection.close();
}
}
完成商品品牌数据的增删改查操作
查询：查询所有数据添加：添加品牌修改：根据id修改删除：根据id删除
5.2 案例实现 1. 数据准备查询所有数据时，可以将每行表格数据存入Brand对象中，然后将Brand对象存入list中，然后打印整个list
数据库表 tb_brand
-- 删除tb_brand表
drop table if exists tb_brand;
-- 创建tb_brand表
create table tb_brand (
-- id 主键
id int primary key auto_increment,
-- 品牌名称
brand_name varchar(20),
-- 企业名称
company_name varchar(20),
-- 排序字段
ordered int,
-- 描述信息
description varchar(100),
-- 状态：0：禁用 1：启用
status int
);
-- 添加数据
insert into tb_brand (brand_name, company_name, ordered, description, status)
values ('三只松鼠', '三只松鼠股份有限公司', 5, '好吃不上火', 0),
('华为', '华为技术有限公司', 100, '华为致力于把数字世界带入每个人、每个家庭、每个组织，构建万物互联的智能世界', 1),
('小米', '小米科技有限公司', 50, 'are you ok', 1);
实现Brand类
package pers.chh3213.exercise;
public class Brand {
private int id;
private String brand_name;
private String company_name;
private int ordered;
private String description;
private int status;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getBrand_name() {
return brand_name;
}
public void setBrand_name(String brand_name) {
this.brand_name = brand_name;
}
public String getCompany_name() {
return company_name;
}
public void setCompany_name(String company_name) {
this.company_name = company_name;
}
public int getOrdered() {
return ordered;
}
public void setOrdered(int ordered) {
this.ordered = ordered;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public int getStatus() {
return status;
}
public void setStatus(int status) {
this.status = status;
}
@Override
public String toString() {
return "Brand{" +
"id=" + id +
", brand_name='" + brand_name + ''' +
", company_name='" + company_name + ''' +
", ordered=" + ordered +
", description='" + description + ''' +
", status=" + status +
'}';
}
}
2. 查询
public void testSelect() throws Exception {
//1.导入jar包
//2.定义配置文件
//3. 加载配置文件
Properties properties = new Properties();
// 通过这种方式获取当前文件的所在路径
System.out.println(System.getProperty("user.dir"));
properties.load(new FileInputStream("src/pers/chh3213/druid/druid.properties")
);
//4. 获取连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//5. 获取数据库连接 Connection
Connection connection = dataSource.getConnection();
//System.out.println(connection);
String sql = "select * from tb_brand";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
ResultSet resultSet = preparedStatement.executeQuery();
ArrayList brandArrayList = new ArrayList<>();
while (resultSet.next()){
int id = resultSet.getInt(1);
String brand_name = resultSet.getString("brand_name");
String company_name = resultSet.getString("company_name");
int order = resultSet.getInt("ordered");
String description = resultSet.getString("description");
int status = resultSet.getInt("status");
Brand brand = new Brand();
brand.setall(id,brand_name,company_name,order,description,status);
brandArrayList.add(brand);
}
System.out.println(brandArrayList);
resultSet.close();
preparedStatement.close();
connection.close();
}
3. 添加数据
@Test
public void testAdd() throws Exception {
String brandName = "香飘飘";
String company_name = "香飘飘";
int ordered = 1;
String description = "绕地球一圈";
int status = 1;
//1.导入jar包
//2.定义配置文件
//3. 加载配置文件
Properties properties = new Properties();
// 通过这种方式获取当前文件的所在路径
System.out.println(System.getProperty("user.dir"));
properties.load(new FileInputStream("src/pers/chh3213/druid/druid.properties")
);
//4. 获取连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//5. 获取数据库连接 Connection
Connection connection = dataSource.getConnection();
//System.out.println(connection);
String sql = "insert into tb_brand(brand_name, company_name, ordered, description, status) values(?,?,?,?,?);";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1,brandName);
preparedStatement.setString(2,company_name);
preparedStatement.setInt(3,ordered);
preparedStatement.setString(4,description);
preparedStatement.setInt(5,status);
preparedStatement.executeUpdate();
preparedStatement.close();
connection.close();
}
4. 修改数据
@Test
public void testUpdate() throws Exception {
String brandName = "香飘飘";
String company_name = "香飘飘";
int ordered = 1;
String description = "绕地球一圈";
int status = 1;
//1.导入jar包
//2.定义配置文件
//3. 加载配置文件
Properties properties = new Properties();
// 通过这种方式获取当前文件的所在路径
System.out.println(System.getProperty("user.dir"));
properties.load(new FileInputStream("src/pers/chh3213/druid/druid.properties")
);
//4. 获取连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//5. 获取数据库连接 Connection
Connection connection = dataSource.getConnection();
//System.out.println(connection);
String sql = " update tb_brandn" +
" set brand_name = ?,n" +
" company_name= ?,n" +
" ordered = ?,n" +
" description = ?,n" +
" status = ?n" +
" where id = ?";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1,brandName);
preparedStatement.setString(2,company_name);
preparedStatement.setInt(3,ordered);
preparedStatement.setString(4,description);
preparedStatement.setInt(5,status);
preparedStatement.setInt(6,2);
preparedStatement.executeUpdate();
preparedStatement.close();
connection.close();
}
5. 删除数据
@Test
public void testDelete() throws Exception {
//1.导入jar包
//2.定义配置文件
//3. 加载配置文件
Properties properties = new Properties();
// 通过这种方式获取当前文件的所在路径
System.out.println(System.getProperty("user.dir"));
properties.load(new FileInputStream("src/pers/chh3213/druid/druid.properties")
);
//4. 获取连接池对象
DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
//5. 获取数据库连接 Connection
Connection connection = dataSource.getConnection();
//System.out.println(connection);
String sql = " delete from tb_brand where id = ?";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1,2);
preparedStatement.executeUpdate();
preparedStatement.close();
connection.close();
}
完整程序请参考gitee仓库
