概述
操作数据库
1基本语法
1.创建
CREATE DATABASE IF NOT EXISTS School
如果School数据库不存在，则创建一个叫School的数据库。
2.删除
DROP DATABASE IF EXISTS school ;
如果School数据库存在，则删除一个叫School的数据库。
3特殊字符
如果你的表明或者字段名字是一个特殊字符则使用
` `
`school`
查看数据库
SHOW DATABASES;
2数据库的字段属性
1 Unsigned
无符号的整数
声明了该列不能声明为负数
2 zerofill
3 0填充
不足的位数，使用0来填充 int(3) 5—005
4 自增 通常理解为自增，自动在上一条记录的基础上 + 1（默认）
通常用来设计唯一的主键~ index，必须是整数类型
可以自定义设计主键自增的起始值和步长
5 非空NULL not null
必须赋值
6默认
设置默认的值如果不指定则为默认值
创建数据库表
CREATE TABLE IF NOT EXISTS `school`(
id INT (4) NOT NULL AUTO_INCREMENT COMMENT'学号',
`name` VARCHAR (30)NOT NULL DEFAULT '填写名字'COMMENT'名字',
`sex`VARCHAR (30) NOT NULL DEFAULT '男'COMMENT'性别',
`password` INT (20) NOT NULL COMMENT'密码',
PRIMARY KEY(`id`)
)ENGINE=INNODB DEFAULT CHARSET=utf8
格式
CREATE TABLE [IF NOT EXISTS] `表名`(
'字段名' 列类型 [属性] [索引] [注释],
'字段名' 列类型 [属性] [索引] [注释],
......
'字段名' 列类型 [属性] [索引] [注释] )[表类型][字符集设置][注释]
常用命令
SHOW CREATE DATABASE school -- 查看创建数据库的语句
SHOW CREATE TABLE student -- 查看student数据表的定义语句
DESC student -- 显示表的结构
修改删除表
-- 修改表名 ： ALTER TABLE 旧表名 RENAME AS 新表名
ALTER TABLE teacher RENAME AS teacher1
-- 增加表的字段 ： ALTER TABLE 表名 ADD 字段名 列属性
ALTER TABLE teacher1 ADD age INT(11)
-- 修改表的字段 （重命名，修改约束!）
-- ALTER TABLE 表名 MODIFY 字段名 列属性[]
ALTER TABLE teacher1 MODIFY age VARCHAR(11) -- 修改约束
-- ALTER TABLE 表名 CHANGE 旧名字 新名字 列属性[]
ALTER TABLE teacher1 CHANGE age age1 INT(1) -- 字段重名名
-- 删除表的字段： ALTER TABLE 表名 DROP 字段名
ALTER TABLE teacher1 DROP age1
3DML语言
添加insert
语法：
insert into 表名([字段名1,字段2,字段3])values(‘值1’),(‘值2’),(‘值3’，…)
例子
INSERT `school` (`name`,`sex`,`password`)VALUES('新的名字','女',123456)
注意事项：
注意事项：
- 字段和字段之间使用 英文逗号 隔开
- 字段是可以省略的，但是后面的值必须要要一一对应，不能少
- 可以同时插入多条数据，VALUES 后面的值，需要使用，隔开即可VALUES(),(),…
修改updata
语法：
UPDATE 表名 set colnum_name = value,[colnum_name = value,…] where [条件]
例子
UPDATE `school`SET `name`='更改后的名字',`password`=333 WHERE `id`=2
通过多个条件定位数据
UPDATE `school`SET `name`='更改后的名字',`password`=333 WHERE `id` BETWEEN 3 AND 4
操作符
BETWEEN … and …在某个范围内[2,5]
AND 我和你
OR我或你
注意：
- colnum_name 是数据库的列，尽量带上``
- 条件，筛选的条件，如果没有指定，则会修改所有的列
- value，是一个具体的值，也可以是一个变量
- 多个设置的属性之间，使用英文逗号隔开
删除delete
delete删除
语法: delete from 表名 [where 条件]
例子：删除指定数据
DELETE FROM `student`WHERE id = 1;
TRUNCATE 删除
作用：完全清空一个数据库表，表的结构和索引约束不会变！
-- 清空 student 表
TRUNCATE `student`
delete 的 TRUNCATE 区别
相同：都会删除数据，都不会删除表的结构
不同：
- TRUNCATE 重新设置 自增列 计数器会归零
- TRUNCATE 不会影响事务
CREATE TABLE test(
id INT (4) NOT NULL AUTO_INCREMENT,
NAME VARCHAR(30)NOT NULL,
PRIMARY KEY (id)
)ENGINE=INNODB DEFAULT CHARSET=utf8
INSERT `test` (NAME)VALUES('1'),('2'),('3')
DELETE FROM test --发现不会影响自增
TRUNCATE TABLE test --自增归零
4DQL查询数据（重点）
DQL
Data Query Language:数据查询语言
注意：
- 所有的查询操作都用它 Select
- 简单的查询，复杂的查询它都能做~
- 数据库中最核心的语言，最重要的语句
- 使用频率最高的语句
语法：
[ ]括号代表可选的，{ }括号代表必选的。
指定查询字段
语法：SELECT 字段,字段,字段,字段…FROM 表
注意：有的时候，列名字不是那么的见名知意。我们起别名 AS 字段名 as 别名 表名 as 别名
例子：
SELECT `name`,`sex`FROM school AS s
去重distinct 当查询的内容有重复信息时加上distinct即可只显示一条。
例子
SELECT DISTINCT NAME FROM school
where条件子句
IS NULLa is null如果操作符为 NUll, 结果为真
IS NOT NULLa is not null如果操作符不为 null，结果为真
BETWEENa between b and c若a 在 b 和c 之间，则结果为真
Likea like bSQL 匹配，如果a匹配b，则结果为真
Ina in (a1,a2,a3….)假设a在a1，或者a2…. 其中的某一个值中，结果为真
like结合 %(代表0到任意个字符) _(一个字符)
例子：
-- like结合 %(代表0到任意个字符) _(一个字符)
SELECT `StudentNo`,`StudentName` FROM `student`
WHERE StudentName LIKE '刘%'
-- 查询姓刘的同学，名字后面只有一个字的
SELECT `StudentNo`,`StudentName` FROM `student`
WHERE StudentName LIKE '刘_'
-- ====== in （具体的一个或者多个值） =====
-- 查询 1001,1002,1003号学员
SELECT `StudentNo`,`StudentName` FROM `student`
WHERE StudentNo IN (1001,1002,1003);
-- 查询地址为空的学生 null ''
SELECT `StudentNo`,`StudentName` FROM `student`
WHERE address='' OR address IS NULL
联表查询
查询不同表中的数据
思路
分析需求，分析查询的字段来自哪些表，（连接查询）
确定使用哪种连接查询？ 7种
确定交叉点（这两个表中哪个数据是相同的）
判断的条件 ： 学生表的中 studentNo = 成绩表 studentNo
SELECT s.StudentNum,StudentName ,StudentAds,StudentResult
FROM student s
INNER JOIN `studentresult` r
ON s.`StudentNum`=r.`StudentNum`
1选择所有需要查询的列
2大部分要查询的来自那个表
3另一张表
4两个表之间的相同的列
Inner join如果表中至少有一个匹配，就返回行
left join会从左表中返回所有的值，即使右表中没有匹配
right join会从右表中返回所有的值，即使左表中没有匹配
分页和排序
-- 排序 ： 升序 ASC ， 降序DESC
-- ORDER BY 通过那个字段排序，怎么排
-- 查询的结果根据 成绩降序 排序
SELECT s.StudentNum,StudentName ,StudentAds,StudentResult
FROM student s
INNER JOIN `studentresult` r
ON s.`StudentNum`=r.`StudentNum`
ORDER BY studentresult DESC
分页
SELECT s.StudentNum,StudentName ,StudentAds,StudentResult
FROM student s
INNER JOIN `studentresult` r
ON s.`StudentNum`=r.`StudentNum`
ORDER BY studentresult DESC
LIMIT 0,1
– 分页，每页只显示五条数据
– 语法： limit 起始值，页面的大小
– 网页应用 ： 当前，总的页数，页面的大小
– LIMIT 0,5 1~5
– LIMIT 1,5 2~6
– Limit 6,5
– 第一页 limit 0,5 （1-1）*5
– 第二页 limit 5,5 （2-1）5
– 第三页 limit 10,5 （3-1）5
– 第N页 limit 0,5 （n-1） pageSize，pageSize
– 【pageSize：页面大小】
– 【(n-1) pageSize:起始值】
– 【n ：当前页 】
– 【数据总数/页面大小 = 总页数】
分组和过滤
SELECT s.StudentNum,StudentName ,StudentAds,StudentResult
FROM student s
INNER JOIN `studentresult` r
ON s.`StudentNum`=r.`StudentNum`
GROUP BY s.studentNum
HAVING StudentResult >=99
小总结
5MYSQL函数
常用函数
-- ==================== 常用函数 =============================
-- 数学运算
SELECT ABS(-8) -- 绝对值
SELECT CEILING(9.4) -- 向上取整
SELECT FLOOR(9.4) -- 向下取整
SELECT RAND() -- 返回一个 0~1 之间的随机数
SELECT SIGN(10) -- 判断一个数的符号 0-0 负数返回-1，正数返回 1
-- 字符串函数
SELECT CHAR_LENGTH('即使再小的帆也能远航') -- 字符串长度
SELECT CONCAT('我','爱','你们') -- 拼接字符串
SELECT INSERT('我爱编程helloworld',1,2,'超级热爱') -- 查询，从某个位置开始替换某个长度
SELECT LOWER('KuangShen') -- 小写字母
SELECT UPPER('KuangShen') -- 大写字母
SELECT INSTR('kuangshen','h') -- 返回第一次出现的子串的索引
SELECT REPLACE('狂神说坚持就能成功','坚持','努力') -- 替换出现的指定字符串
SELECT SUBSTR('狂神说坚持就能成功',4,6) -- 返回指定的子字符串 (源字符串,截取的位置，截取的长度)
SELECT REVERSE('清晨我上马') -- 反转
-- 查询姓 周的同学，名字 邹
SELECT REPLACE(studentname,'周','邹') FROM student
WHERE studentname LIKE '周%'
-- 时间和日期函数 （记住）
SELECT CURRENT_DATE() -- 获取当前日期
SELECT CURDATE() -- 获取当前日期
SELECT NOW() -- 获取当前的时间
SELECT LOCALTIME() -- 本地时间
SELECT SYSDATE() -- 系统时间
SELECT YEAR(NOW())
SELECT MONTH(NOW())
SELECT DAY(NOW())
SELECT HOUR(NOW())
SELECT MINUTE(NOW())
SELECT SECOND(NOW())
-- 系统
SELECT SYSTEM_USER()
SELECT USER()
SELECT VERSION()
聚合函数
| COUNT() | 计数 |
|---|---|
| SUM() | 求和 |
| AVG() | 平均值 |
| MAX() | 最大值 |
| MIN() | 最小值 |
例子：
-- =========== 聚合函数 ===============
-- 都能够统计 表中的数据 （ 想查询一个表中有多少个记录，就使用这个count() ）
SELECT COUNT(`BornDate`) FROM student; -- Count(字段)，会忽略所有的 null 值
SELECT COUNT(*) FROM student; -- Count（*），不会忽略 null 值， 本质 计算行数
SELECT COUNT(1) FROM result; -- Count（1），不会忽略忽略所有的 null 值 本质 计算行数
SELECT SUM(`StudentResult`) AS 总和 FROM result
SELECT AVG(`StudentResult`) AS 平均分 FROM result
SELECT MAX(`StudentResult`) AS 最高分 FROM result
SELECT MIN(`StudentResult`) AS 最低分 FROM result
6事务
要么都成功，要么都失败
原子性（Atomicity）
要么都成功，要么都失败
一致性（Consistency）
事务前后的数据完整性要保证一致 ，1000
持久性（Durability）— 事务提交
事务一旦提交则不可逆，被持久化到数据库中！
隔离性（Isolation）
事务的隔离性是多个用户并发访问数据库时，数据库为每一个用户开启的事务，不能被其他事务的操作数据所干扰，多个并发事务之间要相互隔离。
隔离所导致的一些问题
脏读：
指一个事务读取了另外一个事务未提交的数据。
不可重复读：
在一个事务内读取表中的某一行数据，多次读取结果不同。（这个不一定是错误，只是某些场合不对）
虚读(幻读)
是指在一个事务内读取到了别的事务插入的数据，导致前后读取不一致。
语法：
-- ==================== 事务 =========================
-- mysql 是默认开启事务自动提交的
SET autocommit = 0 /* 关闭 */
SET autocommit = 1 /* 开启（默认的） */
-- 手动处理事务
SET autocommit = 0 -- 关闭自动提交
-- 事务开启
START TRANSACTION -- 标记一个事务的开始，从这个之后的 sql 都在同一个事务内
INSERT xx
INSERT xx
-- 提交： 持久化 （成功！）
COMMIT
-- 回滚： 回到的原来的样子 （失败！）
ROLLBACK
-- 事务结束
SET autocommit = 1 -- 开启自动提交
-- 了解
SAVEPOINT 保存点名 -- 设置一个事务的保存点
ROLLBACK TO SAVEPOINT 保存点名 -- 回滚到保存点
RELEASE SAVEPOINT 保存点名 -- 撤销保存点
1关闭自动提交
2开启事务
3执行事务
4提交
5回滚
6事务结束
模拟转账：
-- 转账
CREATE DATABASE shop CHARACTER SET utf8 COLLATE utf8_general_ci
USE shop
CREATE TABLE `account`(
`id` INT(3) NOT NULL AUTO_INCREMENT,
`name` VARCHAR(30) NOT NULL,
`money` DECIMAL(9,2) NOT NULL,
PRIMARY KEY (`id`)
)ENGINE=INNODB DEFAULT CHARSET=utf8
INSERT INTO account(`name`,`money`)
VALUES ('A',2000.00),('B',10000.00)
-- 模拟转账：事务
SET autocommit = 0; -- 关闭自动提交
START TRANSACTION -- 开启一个事务 （一组事务）
UPDATE account SET money=money-500 WHERE `name` = 'A' -- A减500
UPDATE account SET money=money+500 WHERE `name` = 'B' -- A加500
COMMIT; -- 提交事务，就被持久化了！
ROLLBACK; -- 回滚
SET autocommit = 1; -- 恢复默认值
7索引
索引是帮助MYSQL高效获取数据的数据结构
索引的分类
在一个表中，主键索引只能有一个，唯一索引可以有多个
- 主键索引 （PRIMARY KEY ）
- 唯一的标识，主键不可重复，只能有一个列作为主键
- 唯一索引 （UNIQUE KEY）
- 避免重复的列出现，唯一索引可以重复，多个列都可以标识位 唯一索引
- 常规索引 （KEY/INDEX）
- 默认的， index。key 关键字来设置
- 全文索引 （FullText）
- 在特定的数据库引擎下才有，MyISAM
- 快速定位数据
基础语法
索引的使用
1 在创建表的时候给字段增加索引
2 创建完毕后，增加索引
语法：
显示所有的索引信息
SHOW INDEX FROM student
增加一个全文索引（索引名）列名
ALTER TABLE school .student ADD FULLTEXT INDEX `studentName`(`studentName`)
EXPLAIN 分析SQL的执行状况
EXPLAIN SELECT * FROM student; -- 非全文索引
EXPLAIN SELECT * FROM student WHERE MATCH(studentName) AGAINST('刘');
给表增加一个索引
-- id _ 表名 _ 字段名
-- CREATE INDEX 索引名 on 表(字段)
CREATE INDEX id_app_user_name ON app_user(`name`);
索引在小数据量的时候，用户不大，但是在大数据的时候，区别十分明显
索引原则
索引不是越多越好
不要对进程变动数据加索引
小数据量的表不需要加索引
索引一般加在常用来查询的字段上
权限管理和备份
-- 创建用户 CREATE USER 用户名 IDENTIFIED BY '密码'
CREATE USER kuangshen IDENTIFIED BY '123456'
-- 修改密码 （修改当前用户密码）
SET PASSWORD = PASSWORD('123456')
-- 修改密码 （修改指定用户密码）
SET PASSWORD FOR kuangshen = PASSWORD('123456')
-- 重命名 RENAME USER 原来名字 TO 新的名字
RENAME USER kuangshen TO kuangshen2
-- 用户授权 ALL PRIVILEGES 全部的权限 ， 库.表
-- ALL PRIVILEGES 除了给别人授权，其他都能够干
GRANT ALL PRIVILEGES ON *.* TO kuangshen2
-- 查询权限
SHOW GRANTS FOR kuangshen2 -- 查看指定用户的权限
SHOW GRANTS FOR root@localhost
-- ROOT用户权限：GRANT ALL PRIVILEGES ON *.* TO 'root'@'localhost' WITH GRANT OPTION
-- 撤销权限 REVOKE 哪些权限， 在哪个库撤销，给谁撤销
REVOKE ALL PRIVILEGES ON *.* FROM kuangshen2
-- 删除用户
DROP USER kuangshen
MySQL备份
为什么要备份：
- 保证重要的数据不丢失
- 数据转移
MySQL 数据库备份的方式
- 直接拷贝物理文件
- 在Sqlyog 这种可视化工具中手动导出
- 在想要导出的表或者库中，右键，选择备份或导出
使用命令导出MySql
- 在想要导出的表或者库中，右键，选择备份或导出
# mysqldump -h 主机 -u 用户名 -p 密码 数据库 表名 > 物理磁盘位置/文件名
mysqldump -hlocalhost -uroot -p123456 school student >D:/a.sql
# mysqldump -h 主机 -u 用户名 -p 密码 数据库 表1 表2 表3 > 物理磁盘位置/文件名
mysqldump -hlocalhost -uroot -p123456 school student >D:/b.sql
# mysqldump -h 主机 -u 用户名 -p 密码 数据库> 物理磁盘位置/文件名
mysqldump -hlocalhost -uroot -p123456 school >D:/c.sql
# 导入
# 登录的情况下，切换到指定的数据库
# source 备份文件
source d:/a.sql
mysql -u用户名 -p密码 库名< 备份文件
JDBC(重点)
数据库驱动
我们的程序会通过 数据库 驱动，和数据库打交道！
JDBC
SUN 公司为了简化 开发人员的（对数据库的统一）操作，提供了一个（Java操作数据库的）规范，俗称 JDBC
这些规范的实现由具体的厂商去做~
对于开发人员来说，我们只需要掌握 JDBC 接口的操作即可！
JDBC步骤
1、加载驱动
2、连接数据库 DriverManager
3、获得执行sql的对象 Statement
4、获得返回的结果集
5、释放连接
DriverManager
// DriverManager.registerDriver(new com.mysql.jdbc.Driver());
Class.forName("com.mysql.jdbc.Driver"); // 固定写法，加载驱动
Connection connection = DriverManager.getConnection(url, username, password);
// connection 代表数据库
// 数据库设置自动提交
// 事务提交
// 事务滚回
connection.rollback();
connection.commit();
connection.setAutoCommit();
URL
String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
// mysql -- 3306
// 协议 ://主机地址:端口号/数据库名?参数1&参数2&参数3
// oralce -- 1521
//jdbc:oracle:thin:@localhost:1521:sid
Statement 执行SQL 的对象 PrepareStatement 执行SQL 的对象
String sql = "SELECT * FROM users"; // 编写SQL
statement.executeQuery(); //查询操作返回 ResultSet
statement.execute(); // 执行任何SQL
statement.executeUpdate(); // 更新、插入、删除。都是用这个，返回一个受影响的行数
ResultSet 查询的结果集：封装了所有的查询结果
resultSet.getObject(); // 在不知道列类型的情况下使用
// 如果知道列的类型就使用指定的类型
resultSet.getString();
resultSet.getInt();
resultSet.getFloat();
resultSet.getDate();
resultSet.getObject();
....
遍历，指针
resultSet.beforeFirst(); // 移动到最前面
resultSet.afterLast(); // 移动到最后面
resultSet.next(); //移动到下一个数据
resultSet.previous(); //移动到前一行
resultSet.absolute(row); //移动到指定行
释放资源
//6、释放连接
resultSet.close();
statement.close();
connection.close(); // 耗资源，用完关掉！
statement对象
jdbc中statement对象可以完成对数据库发送SQL语句，完成对数据库的增删改查，只需要通过这个对象向数据库发送增删语句即可。
statement对象有executeUpdate方法可以对数据库进行增、删、改。执行完后会返回一个INT类型的整数代表更改的行数。
executeQuery方法可以对数据库发送查询语句，executeQuery方法返回代表查询结果的ResultSet对象。
使用executeUpdate(String sql)方法完成数据添加操作，示例操作：
Statement st = conn.createStatement();
String sql = "insert into user(….) values(…..) ";
int num = st.executeUpdate(sql);
if(num>0){
System.out.println("插入成功！！！");
}
使用executeUpdate(String sql)方法完成数据删除操作，示例操作：
Statement st = conn.createStatement();
String sql = "delete from user where id=1";
int num = st.executeUpdate(sql);
if(num>0){
System.out.println(“删除成功！！！");
}
使用executeUpdate(String sql)方法完成数据修改操作，示例操作：
Statement st = conn.createStatement();
String sql = "update user set name='' where name=''";
int num = st.executeUpdate(sql);
if(num>0){
System.out.println(“修改成功！！！");
}
使用executeQuery(String sql)方法完成数据查询操作，示例操作：
Statement st = conn.createStatement();
String sql = "select * from user where id=1";
ResultSet rs = st.executeQuery(sql);
while(rs.next()){
//根据获取列的数据类型，分别调用rs的相应方法映射到java对象中
}
整体代码实现
1，再src下建立资源文件db.properties
diver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=UTF8&useSSL=true
username=root
password=123456
1，提取工具类
package com.xxr.lesson2;
import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
public class JdbcUtils {
private static String diver=null;
private static String url=null;
private static String username=null;
private static String password=null;
static {
try {
InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
Properties properties = new Properties();
properties.load(in);
diver = properties.getProperty("diver");
url = properties.getProperty("url");
username = properties.getProperty("username");
password = properties.getProperty("password");
//加载驱动，只用加载一次
Class.forName(diver);
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url,username,password);
}
public static void release(Connection conn, Statement st, ResultSet rs) throws SQLException {
if (rs != null)
{
rs.close();
}
if(st!=null){
st.close();
}
if(conn!=null)
{
conn.close();
}
}
}
使用工具类对数据库进行查询
package com.xxr;
import com.xxr.lesson2.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class Test {
public static void main(String[] args) throws SQLException {
Connection connection=null;
Statement st=null;
ResultSet rs=null;
try {
connection = JdbcUtils.getConnection();
st=connection.createStatement();
rs = st.executeQuery("select * from users where id = 1");
while (rs.next())
{
System.out.println(rs.getObject("NAME"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
JdbcUtils.release(connection,st, null);
}
}
}
SQL注入问题
SQL存在漏洞，SQL会被拼接OR导致数据泄露
package com.xxr.lesson2;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class SQl注入 {
public static void main(String[] args) throws SQLException {
login("'or'2=2","'or'2=2");
}
public static void login(String username,String password) throws SQLException {
Connection con=null;
Statement st=null;
ResultSet rs=null;
try {
con= JdbcUtils.getConnection();
st = con.createStatement();
rs= st.executeQuery("select * from users where `NAME`='"+username+"'AND `password`='"+password+"'");
while (rs.next()){
System.out.println(rs.getString("NAME"));
System.out.println(rs.getString("password"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
JdbcUtils.release(con,st,rs);
}
}
}
使用IDEA连接数据库
连接成功后，可以选择数据库
选择这个如果没有点击下面的DOWNLOAD
点击提交更新数据
连接失败查看原因
事务
要么都成功要么都失败
原子性：要么全部完成，要么都不完成
一致性：总数不变
隔离性：多个进程互不干扰
持久性：一旦提交不可逆，持久化到数据库了
隔离性的问题：
脏读：一个事务读取了另一个没有提交的事务
不可重复读：在同一个事务内，重复读取表中的数据，表数据发生了改变
虚读（幻读）：在一个事务内，读取到了别人插入的数据，导致前后读出来结果不一致
package com.xxr;
import com.xxr.lesson2.jdbcUtils.DBCP;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class Test {
public static void main(String[] args) throws SQLException {
Connection connection=null;
Statement st=null;
ResultSet rs=null;
try {
connection = DBCP.getConnection();
//关闭数据库的自动提交，会自动开启事务
connection.setAutoCommit(false);//开启事务
String sql1="update users set PASSWORD = PASSWORD-100 where id = 1";
st=connection.createStatement();
st.executeUpdate( sql1);
String sql2="update users set PASSWORD = PASSWORD-100 where id = 2";
st=connection.createStatement();
st.executeUpdate( sql2);
connection.commit();
System.out.println("成功提交事务");
} catch (SQLException e) {
e.printStackTrace();
}finally {
DBCP.release(connection,st, null);
}
}
}
连接数据库连接池
数据库连接 — 执行完毕 — 释放
连接 – 释放 十分浪费系统资源
池化技术：准备一些预先的资源，过来就连接预先准备好的
最小连接数： 10
最大连接数： 15
等待超时：100ms
编写连接池，实现一个接口 DataSourc
使用了这些数据库连接池之后，我们在项目开发中就不需要编写连接数据库的 代码了
DBCP
需要用到的 jar 包 commons-dbcp-1.4 、 commons-pool-1.6
package com.xxr.lesson2.jdbcUtils;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
public class DBCP {
private static DataSource dataSource=null;
static {
try {
InputStream in = DBCP.class.getClassLoader().getResourceAsStream("dbcpconig.properties");
Properties properties = new Properties();
properties.load(in);
//创建数据源 工厂模式
dataSource = BasicDataSourceFactory.createDataSource(properties);
} catch (Exception e) {
e.printStackTrace();
}
}
//获取链接 从数据源中获取连接
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
public static void release(Connection conn, Statement st, ResultSet rs) throws SQLException {
if (rs != null)
{
rs.close();
}
if(st!=null){
st.close();
}
if(conn!=null)
{
conn.close();
}
}
}
C3P0
需要用到的 jar 包
c3p0-0.9.5.5、mchange-commons-java-0.2.19
最后
以上就是健康草莓为你收集整理的MySQL基本操作操作数据库的全部内容，希望文章能够帮你解决MySQL基本操作操作数据库所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复