精品课程云网站建设,ui培训的机构,win2003建设网站,用jsp做网站的技术路线JDBC引入
JDBC概念#xff1a;
JDBC是使用Java语言操作关系型数据库的一套API。全称#xff1a;#xff08;Java DataBase Connectivity#xff09;Java数据库连接
JDBC的本质#xff1a;
官方定义的一套操作所有关系型数据库的规则#xff0c;即接口。
各个数据库厂…JDBC引入
JDBC概念
JDBC是使用Java语言操作关系型数据库的一套API。全称Java DataBase ConnectivityJava数据库连接
JDBC的本质
官方定义的一套操作所有关系型数据库的规则即接口。
各个数据库厂商去实现这套接口即提供实现类这些实现类也叫做驱动 厂商提供的是相应的数据库驱动jar包。我们可以使用这套接口JDBC编程真正执行的是驱动jar包中的实现类。
JDBC的好处
各数据库厂商使用相同的接口Java代码不需要针对不同的数据库分别开发。可随时替换底层数据库访问数据库的Java代码基本不变。
JDBC的使用步骤
有七步如代码所示
package JDBC学习;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;public class test1 {public static void main(String[] args) {Connection conn null;Statement sta null;try {//1 注册驱动Class.forName(com.mysql.cj.jdbc.Driver);//2 获取连接String url jdbc:mysql://127.0.0.1:3306/limingmao;String username liergou;String password liergou070509;conn DriverManager.getConnection(url, username, password);//3 定义SQLString sql_1 UPDATE emp1 SET salary 20000 WHERE name Tom;//4 获取执行sql的对象Statementsta conn.createStatement();//5 执行sqlint i sta.executeUpdate(sql_1);//i为受影响的行数//6 处理结果System.out.println(i);} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();} finally {//7 释放资源try {sta.close();} catch (SQLException e) {e.printStackTrace();}try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}
注mysql5.0之后可以省略注册驱动一步。
JDBC API详解
DiverManager
DiverManager驱动管理类作用
注册驱动获取数据库连接
关于DiverManager中的静态方法static Connection getConnection(String url,String user,String password)
参数 url连接路径 user用户名password密码 Connection
Connection数据库连接对象作用 获取执行SQL的对象管理事务 获取执行SQL的对象 普通执行SQL对象 Statement createStatement() 预编译SQL的执行SQL对象防止SQL注入 PreparedStatement preparedStatement(sql) 执行存储变量的对象 CallableStatement prepareCall(sql) 事务管理 可以利用JDBC的三个方法来管理事务
package JDBC学习;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;public class test2 {public static void main(String[] args) {Connection conn null;Statement sta null;try {//1 注册驱动//Class.forName(com.mysql.cj.jdbc.Driver);//2 获取连接String url jdbc:mysql://127.0.0.1:3306/limingmao;String username liergou;String password liergou070509;conn DriverManager.getConnection(url, username, password);//3 定义SQLString sql_1 UPDATE emp1 SET salary 20000 WHERE name Tom;String sql_2 UPDATE emp1 SET salary 20000 WHERE name 丘丘人;//4 获取执行sql的对象Statementsta conn.createStatement();//开启事务conn.setAutoCommit(false);//5 执行sqlint i sta.executeUpdate(sql_1);//i为受影响的行数int j sta.executeUpdate(sql_2);//i为受影响的行数//6 处理结果System.out.println(i);System.out.println(j);//提交事务conn.commit();} /*catch (ClassNotFoundException e) {e.printStackTrace();} */catch (SQLException e) {//回滚事务try {conn.rollback();} catch (SQLException ex) {e.printStackTrace();}e.printStackTrace();} finally {//7 释放资源try {sta.close();} catch (SQLException e) {e.printStackTrace();}try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}
先设置MySQL不自动提交事务在try中末尾处加上提交事务的操作。如果出现异常说明此异常操作的事务不应该提交要回滚事务。将回滚事务的操作放在catch中随着和对异常的处理操作一起进行回滚操作。
Statement
Statement作用
执行SQL语句。
执行SQL语句 int executeUpdate(sql)执行DML、DDL语句 返回值①DML语句影响的行数 ②DDL语句执行后执行成功也可能返回0 ResultSet executeQuery(sql)执行DQL语句 返回值ResultSet结果集对象 ResultSet
Result结果集对象作用
封装了DQL查询语句的结果 ResultSet executeQuery(sql)执行DQL语句 返回值ResultSet结果集对象 获取查询结果 boolean next()①将指针从当前位置移动到下一行 ②判断当前行是否为有效行 返回值true有效行当前行有数据false无效行当前行没有数据。 xxx getXxx(参数)获取数据 xxx数据类型。如int getInt()、String getString(参数) 参数int列的编号从1开始。String列的名称。 使用 使用时通常会用上while循环 while(…….next()){ …… …….getXxx(参数); } 例查询员工表emp1中的数据并打印。
Test
void test3() {Connection conn null;Statement sta null;ResultSet rs null;try {//获取连接注册驱动已省略String url jdbc:mysql:///limingmao;String username liergou;String password liergou070509;conn DriverManager.getConnection(url,username,password);//定义SQL语句String sql_1 select * from emp1;//获取statement对象sta conn.createStatement();//执行sqlrs sta.executeQuery(sql_1);//处理结果遍历查询的所有结果while(rs.next()){int id rs.getInt(id);String name rs.getString(2);Date date rs.getDate(3);double salary rs.getDouble(salary);System.out.print(id \t);System.out.print(name \t);System.out.print(date \t);System.out.print(salary \t);System.out.println();}} catch (SQLException e) {e.printStackTrace();} finally {//释放资源try {rs.close();sta.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}
}
还可以使用其查询数据做Java代码的处理例将员工的sal添加到一个Arraylist中。
Test
void test4() {Connection conn null;Statement sta null;ResultSet rs null;try {//获取连接注册驱动已省略String url jdbc:mysql:///limingmao;String username liergou;String password liergou070509;conn DriverManager.getConnection(url,username,password);//定义SQL语句String sql_1 select salary from emp1;//获取statement对象sta conn.createStatement();//执行sqlrs sta.executeQuery(sql_1);//处理结果遍历查询的所有结果ArrayListDouble sal new ArrayList();while(rs.next()){double salary rs.getDouble(salary);sal.add(salary);}Iterator ii sal.iterator();while (ii.hasNext()){System.out.println(ii.next());}} catch (SQLException e) {e.printStackTrace();} finally {//释放资源try {rs.close();sta.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}
}
例将员工的信息添加到一个Arraylist中。
Test
void test5() {Connection conn null;Statement sta null;ResultSet rs null;try {//获取连接注册驱动已省略String url jdbc:mysql:///limingmao;String username liergou;String password liergou070509;conn DriverManager.getConnection(url,username,password);//定义SQL语句String sql_1 select * from emp1;//获取statement对象sta conn.createStatement();//执行sqlrs sta.executeQuery(sql_1);//处理结果遍历查询的所有结果ArrayListEmployee employees new ArrayList();while(rs.next()){int id rs.getInt(1);String name rs.getString(name);Date date rs.getDate(3);double salary rs.getDouble(salary);employees.add(new Employee(id,name,date,salary));}Iterator ii employees.iterator();while (ii.hasNext()){System.out.println(ii.next());}} catch (SQLException e) {e.printStackTrace();} finally {//释放资源try {rs.close();sta.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}
}
PreparedStatement
PreparedStatement作用
预编译SQL语句并执行预防SQL注入问题
SQL注入
即利用SQL语句的语法在填入时强制查询结果为true。
操作
①获取PrepareStatement对象
//SQL语句中的参数值使用?占位符替代
String sql SELECCT * FROM user WHERE username ? AND password ?;//通过Connection对象获取并传入相应的SQL语句。
PreparedStatement psta conn.prepareStatement(sql);
②设置参数值
PreparedStatement对象setXxx(参数1参数2)给?赋值
Xxx指的是数据类型参数1是?的顺序编号从一开始。参数2是?的具体的值。
③执行SQL
使用executeUpdate()/executeQuery()不需要再传入SQL语句。
例
Test
void test7()
{Connection conn null;PreparedStatement psta null;ResultSet rs null;try {//获取连接String url jdbc:mysql:///limingmao;String username liergou;String password liergou070509;conn DriverManager.getConnection(url,username,password);//接收用户输入的用户名和密码String uname 张三;String pwd 1234;//定义SQLString sql SELECT * FROM tb_user WHERE username ? AND password ?;//获取psta对象psta conn.prepareStatement(sql);//设置?的值psta.setString(1,uname);psta.setString(2,pwd);//执行SQL语句rs psta.executeQuery();//判断是否成功if(rs.next()) {System.out.println(登录成功);}else {System.out.println(登录失败);}} catch (SQLException e) {e.printStackTrace();} finally {try {//释放资源rs.close();psta.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}
}
PreparedStatement原理
在获取PreparedStatement对象时将SQL语句发送给MySQL服务器进行检查、编译执行时就不用再进行这些步骤了速度更快如果SQL模板一样则只需要进行一次检查、编译
PreparedStatement好处
预编译SQL性能更高防止SQL注入将敏感字符进行转义
开启预编译功能
userServerPrepStmtstrue将此参数键值对放到url的参数键值对处。
数据库连接池
简介 数据库连接池是个容器负责分配、管理数据库连接Connection 它允许应用程序重复使用一个现有的数据库连接而不是再重新建立一个 释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏 好处 资源重用提升系统响应速度避免数据库连接遗漏 数据库连接池实现
标准接口DataSource
官方提供的数据库连接池标准接口由第三方组织实现此接口。
功能获取连接 Connection getConnection() 常见的数据库连接池
DBCPC3P0Druid
Druid德鲁伊
Druid连接池是阿里巴巴开源的数据库连接池项目
功能强大性能优秀是Java语言最好的数据库连接池之一
使用步骤以及代码实现如下
public class test_druid {public static void main(String[] args){try {//加载配置文件Properties prop new Properties();prop.load(new FileInputStream(D:\\李明茂\\Java学习\\JDBC\\src\\druid.properties));//获取连接池对象DataSource dataSource DruidDataSourceFactory.createDataSource(prop);//获取数据库连接ConnectionConnection conn dataSource.getConnection();System.out.println(conn);} catch (Exception e) {e.printStackTrace();}}
}
JDBC练习实现品牌列表的增删查改
要求使用数据库连接池德鲁伊使用预编译防SQL注入的PreparedStatement
题目准备
数据库准备
CREATE TABLE tb_brand(
id INT PRIMARY KEY AUTO_INCREMENT,
brand_name VARCHAR(20),-- 品牌名称
company_name VARCHAR(20),-- 企业名称
ordered INT,-- 排序字段
description VARCHAR(100),-- 描述信息
status INT-- 状态 0表示禁用1表示启用
);INSERT INTO tb_brand(brand_name,company_name,ordered,description,status)
VALUES(金坷拉,金坷垃股份有限公司,5,要种庄稼必须要有金坷垃,0),
(米哈游,米哈游技术有限公司,100,技术宅拯救世界,1),
(腾讯,腾讯技术有限公司,50,下元梦之心,1);SELECT * FROM tb_brand;DESC tb_brand;
Java中Brand类的准备
public class Brand {
private Integer id;
private String brandName;
private String companyName;
private Integer ordered;
private String description;
private Integer status;public Brand() {}public Brand(Integer id, String brandName, String companyName, Integer ordered, String description, Integer status) {this.id id;this.brandName brandName;this.companyName companyName;this.ordered ordered;this.description description;this.status status;}public Integer getId() {return id;}public void setId(Integer id) {this.id id;}public String getBrandName() {return brandName;}public void setBrandName(String brandName) {this.brandName brandName;}public String getCompanyName() {return companyName;}public void setCompanyName(String companyName) {this.companyName companyName;}public Integer getOrdered() {return ordered;}public void setOrdered(Integer ordered) {this.ordered ordered;}public String getDescription() {return description;}public void setDescription(String description) {this.description description;}public Integer getStatus() {return status;}public void setStatus(Integer status) {this.status status;}Overridepublic String toString() {return Brand{ id id , brandName brandName \ , companyName companyName \ , ordered ordered , description description \ , status status };}
}
开始练习
查所有数据单元测试方法中实现下同
/*** 查询所有* SQL语句SELECT * FROM tb_brand;* 参数不需要* 结果ListBrand*/Testpublic void testSelectAll(){Connection conn null;PreparedStatement pstmt null;ResultSet rs null;try {//加载配置文件Properties prop new Properties();prop.load(new FileInputStream(D:\\李明茂\\Java学习\\JDBC\\src\\druid.properties));//获取连接池对象DataSource dataSource DruidDataSourceFactory.createDataSource(prop);//获取数据库连接Connectionconn dataSource.getConnection();//定义SQL语句String sql SELECT * FROM tb_brand;//获取PreparedStatement对象pstmt conn.prepareStatement(sql);//执行SQL语句rs pstmt.executeQuery();//处理结果ListBrand brands new ArrayList();while(rs.next()){brands.add(new Brand(rs.getInt(id),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getString(description),rs.getInt(6)));}Iterator ii brands.iterator();while (ii.hasNext()){System.out.println(ii.next());}} catch (Exception e) {e.printStackTrace();} finally {try {rs.close();pstmt.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}
增
/*** 添加* SQL语句* INSERT INTO tb_brand(brand_name,company_name,ordered,description,status) VALUES(?,?,?,?,?);* 参数需要除了id之外的所有参数共五个。*/Testpublic void testAdd(){Connection conn null;PreparedStatement pstmt null;//假设接受到的添加的信息如下String brandName 网易;String companyName 网易技术有限公司;Integer ordered 1;String description 下蛋仔派对;Integer status 1;try {//加载配置文件Properties prop new Properties();prop.load(new FileInputStream(D:\\李明茂\\Java学习\\JDBC\\src\\druid.properties));//获取连接池对象DataSource dataSource DruidDataSourceFactory.createDataSource(prop);//获取数据库连接Connectionconn dataSource.getConnection();//定义SQL语句String sql INSERT INTO tb_brand(brand_name,company_name,ordered,description,status) VALUES(?,?,?,?,?);;//获取PreparedStatement对象pstmt conn.prepareStatement(sql);//设置参数pstmt.setString(1,brandName);pstmt.setString(2,companyName);pstmt.setInt(3,ordered);pstmt.setString(4,description);pstmt.setInt(5,status);//执行SQL语句int count pstmt.executeUpdate();//处理结果System.out.println(count 0);} catch (Exception e) {e.printStackTrace();} finally {try {pstmt.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}
改
/*** 修改* SQL语句UPDATE tb_brand SET brand_name ?,company_name ?,ordered ?,description ?,status ? WHERE id ?;*/Testpublic void testUpdate(){Connection conn null;PreparedStatement pstmt null;//假设接受到的添加的信息如下String brandName 网易;String companyName 网易技术有限公司;Integer ordered 1;String description 66666;Integer status 1;Integer id 4;try {//加载配置文件Properties prop new Properties();prop.load(new FileInputStream(D:\\李明茂\\Java学习\\JDBC\\src\\druid.properties));//获取连接池对象DataSource dataSource DruidDataSourceFactory.createDataSource(prop);//获取数据库连接Connectionconn dataSource.getConnection();//定义SQL语句String sql UPDATE tb_brand SET brand_name ?,company_name ?,ordered ?,description ?,status ? WHERE id ?;;//获取PreparedStatement对象pstmt conn.prepareStatement(sql);//设置参数pstmt.setString(1,brandName);pstmt.setString(2,companyName);pstmt.setInt(3,ordered);pstmt.setString(4,description);pstmt.setInt(5,status);pstmt.setInt(6,id);//执行SQL语句int count pstmt.executeUpdate();//处理结果System.out.println(count 0);} catch (Exception e) {e.printStackTrace();} finally {try {pstmt.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}
删
/*** 删除* SQL语句DELETE FROM tb_brand WHERE id ?;*/Testpublic void testDelete(){Connection conn null;PreparedStatement pstmt null;//假设接受到的添加的信息如下Integer id 4;try {//加载配置文件Properties prop new Properties();prop.load(new FileInputStream(D:\\李明茂\\Java学习\\JDBC\\src\\druid.properties));//获取连接池对象DataSource dataSource DruidDataSourceFactory.createDataSource(prop);//获取数据库连接Connectionconn dataSource.getConnection();//定义SQL语句String sql DELETE FROM tb_brand WHERE id ?;;//获取PreparedStatement对象pstmt conn.prepareStatement(sql);//设置参数pstmt.setInt(1,id);//执行SQL语句int count pstmt.executeUpdate();//处理结果System.out.println(count 0);} catch (Exception e) {e.printStackTrace();} finally {try {pstmt.close();conn.close();} catch (SQLException e) {e.printStackTrace();}}}
