日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 运维知识 > 数据库 >内容正文

数据库

MySQL从入门到精通

發布時間:2024/3/13 数据库 47 豆豆
生活随笔 收集整理的這篇文章主要介紹了 MySQL从入门到精通 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

一、配置

MySQL服務啟動

  • 手動
  • cmd --> services.msc 打開服務的窗口
  • 使用管理員打開cmd
    • net start mysql:啟動mysql的服務
    • net stop mysql:關閉mysql服務
  • MySQL登陸

  • mysql -u用戶名 -p密碼
  • mysql -hip -u連接目標的用戶 -p對應的密碼
  • MySQL退出

  • exit
  • quit
  • 二、SQL

    1.什么是SQL?

    ? Structured Query Language:結構化查詢語言

    ? 其實就是定義了所有關系型數據可的規則。每種數據庫操作的方式存在不一樣的地方,稱為“方言”

    2.SQL通用語法

    • SQL 語句可以單行或多行書寫,以分號結尾
    • 可使用空格和縮進來增強語句的可讀性
    • MySQL數據庫的SQL語句不區分大小寫,關鍵字建議用大寫

    3.SQL分類

  • DDL(Data Definition Language)數據定義語言

    用來定義數據庫對象:數據庫,表,列等。關鍵字:create,drop,alter等

  • DML(Data Manipulation Language)數據庫操作語言

    用來對數據庫中表的數據進行增刪改查。關鍵字:insert,delete,uodate等

  • DQL(Data Query Language)數據查詢語言

    用來查詢數據庫中表的記錄(數據)。關鍵字:select,where等

  • DCL(Data Control Language)數據控制語言(了解)

    用來定義數據庫的訪問權限和安全級別,及創建用戶。關鍵字:GRANT,REVOKE等

  • (一)、DDL:操作數據庫、表

    操作數據庫

    • C(Create):創建
      • 創建數據庫:create database 數據庫名稱;
      • 創建數據庫,判斷是否存在:create database if not exists 數據庫名稱;
      • 創建數據庫,并制定字符集:create database character set 字符集;
      • 創建db4數據庫,判斷是否存在,并制定字符集為gbk:
        • create database if not exists character set gbk;
    • R(Retrieve):查詢
      • 查詢所有數據庫的名稱:show databases;
      • 查詢某個數據庫的字符集:查詢某個數據庫的創建語句
        • show create database 數據庫名稱;
    • U(Updete):修改
      • 修改數據庫的字符集
        • alter database 數據庫名稱 character set 字符集;
    • D(Delete):刪除
      • 刪除數據庫:drop database 數據庫名稱;
      • 判斷數據庫是否存在,存在再刪除:drop database if exists 數據庫名稱;
    • 使用數據庫
      • 查詢當前正在使用的數據庫
        • select database();
      • 使用數據庫
        • use 數據庫名稱;

    操作表

    • C(Create):創建

      • 語法:

        • create table 表名(列名1 數據類型1,列名2 數據類型2,...列名n 數據類型n );
      • 數據類型:

        • int:整數類型
          • age int,
        • double:小數類型
          • score double(5,2)
        • date:日期,只包含年月日,yyyy-MM-dd
        • datetime:日期,包含年月日時分秒 yyyy-MM-dd HH:mm:ss
        • timestamp:時間戳類型 包含年月日時分秒 yyyy-MM-dd HH:mm:ss
          • 如果沒有賦值,默認使用當前系統時間
        • varchar:字符串
          • name varchar(20):姓名最大20個字符
      • 創建表

        • create table student(id int,name varchar(32),age int,score double(4,1),birthday date,insert_time timestamp );
      • 復制表

        • create table 表名 like 被復制的表名;
    • R(Retrieve):查詢

      • 查詢某個數據庫中所有表的名稱:show tables;
      • 查詢表結構:desc 表名;
    • U(Updete):修改

      • 修改表名
        • alter table 表名 rename to 新表名;
      • 修改標的字符集
        • alter table 表名 character set 字符集名稱;
      • 添加列
        • alter table 表名 add 列名 數據類型;
      • 修改列名稱 類型
        • alter table 表名 change 列名 新列名 新數據類型;
        • alter table 表名 madify 列名 新數據類型;
      • 刪除列
        • alter table 表名 drop 列名;
    • D(Delete):刪除

      • drop table 表名;
      • drop table if exists 表名;

    (二)、DML:增刪改表中數據

    1. 添加數據

    語法:

    • insert into 表名(列名1,列名2, …列名n) values (值1,值2,…值n);

    注意:

    • 列名和值要一一對應
    • 如果表明后,不定義列名,則么人給所有列添加值
      • insert into 表名 values (值1,值2,…值n);
    • 除了數字類型,其他類型需要使用引號(單雙都可以)引起來

    2. 刪除數據

    語法:

    • delete from 表名 [where 條件];

    注意:

    • 如果不加條件,則刪除表中所有記錄
    • 如果要刪除所有記錄
      • delete from 表名; ---- 不推薦使用,有多少條記錄就會執行多少次刪除操作
      • truncate table 表名; ---- 推薦使用,效率更高,先刪除表,然后再創建一張一模一樣的表

    3. 修改數據

    語法:

    • update 表名 set 列名1=值1, 列名2=值2, … [where 條件];

    注意:

    • 如果不加任何條件,則會將表中所有記錄全部修改

    (三)、DQL:查詢表中的記錄

    語法:

    select字段列表 from表名列表 where條件列表 group by分組字段 having分組之后的條件 order by排序 limit分頁限定

    1. 基礎查詢

    • 多個字段的查詢
      • select 字段名1, 字段名2… from 表名;
      • 注意:
        • 如果查詢所有字段,則可以使用*來代替字段列表。
    • 去除重復:
      • distinct
    • 計算列:
      • 一般可以使用自足運算計算一些列的值。(一般只會進行數值型的計算)
      • ifnull(表達式1, 表達式2):null參與的運算,計算結果都為null
        • 表達式1:那個字段需要判斷是否為null
        • 如果該字段為null后替換的值
    • 起別名:
      • as:as也可以省略

    2. 條件查詢

    • where字句后面跟條件

    • 運算符

      • >、<、<=、>=、=、<>
      • between ... and ... 在一個范圍之間
      • in(集合) 集合表示多個值,用逗號分隔
      • like'張%' 模糊查詢
        • 占位符:
          • _ :單個任意字符
          • %:任意個任意字符
      • is null 查詢某一列為null的值,不能寫=null
      • and 或 &&
      • or 或 ||
      • not 或 !

    3. 排序查詢

    語法: order by 子句

    • order by 排序字段1 排列方式1, 排序字段2 排序方式2…

    排序方式:

    • ASC:升序,默認的。
    • DESC:降序

    注意:

    • 如果有多個排序條件,則當前面的條件值一樣時,蔡虎判斷第二條件。

    4. 聚合函數

    將一列數據作為整體,進行縱向的計算

    • count:計算個數
      • 一般選擇非空的列:主鍵
    • max:計算最大值
    • min:計算最小值
    • sum:計算和
    • avg:計算平均值
    SELECT COUNT(IFNULL(`stu_name`,0)) 人數 FROM student; SELECT MAX(stu_age) 最大年齡 FROM student; SELECT MIN(stu_age) 最小年齡 FROM student; SELECT SUM(stu_age) 年齡總和 FROM student; SELECT AVG(stu_age) 平均年齡 FROM student;

    注意: 聚合函數的計算,會排除null值

    • 解決方案:
      • 選擇不包含空的列進行計算
      • IFNULL函數

    5. 分組查詢

    語法: group by 分組字段;

    注意:

    • 分組之后查詢的字段:分組字段、聚合函數
    • where和haring的區別
      • where在分組之間進行限定,如果不滿足條件,則不參與分組;having在分組之后進行限定,如果不滿足結果,則不被查詢出來
      • where后不可以跟聚合函數,having可以進行聚合函數的判斷
    #按照班級分組,分別查詢平均年齡,每個班的人數 SELECT class_id, AVG(stu_age), COUNT(stu_id) FROM student GROUP BY class_id;#按照班級分組,分別查詢平均年齡,每個班的人數,小于12歲的不參與分組 SELECT class_id, AVG(stu_age), COUNT(stu_id) FROM student WHERE stu_age>=12 GROUP BY class_id;#按照班級分組,分別查詢平均年齡,每個班的人數,小于12歲的不參與分組,分組之后人數要大于兩個人 SELECT class_id, AVG(stu_age), COUNT(stu_id) FROM student WHERE stu_age>=12 GROUP BY class_id HAVING COUNT(stu_id)>2;

    6. 分頁查詢

    語法: limit 開始的索引,每頁查詢的條數;

    公式: 開始的索引 = (當前的頁碼-1)* 每頁顯示的條數

    #每頁顯示三條 SELECT * FROM student LIMIT 0,3; #第一頁 SELECT * FROM student LIMIT 3,3; #第二頁 SELECT * FROM student LIMIT 6,3; #第三頁

    limit 是一個MySQL“方言”

    三、約束

    概念: 對表中的數據進行限定,保證數據的正確性、有效性和完整性

    分類:

    • 主鍵約束:primary key
    • 非空約束:not null
    • 唯一約束:unique
    • 外鍵約束:foreign key

    主鍵約束:primary key

    注意:

    # 含義:非空主鍵 # 一張表只能有一個字段為主鍵 # 主鍵就是表中記錄的唯一標識
    • 在創建表時添加約束

      • CERATE TABLE stu(id INT PRIMARY KEY,`name` VARCHAR(20) );
    • 創建完表后,添加主鍵

      • ALTER TABLE stu MODIFY id INT PRIMARY KEY;
    • 刪除主鍵

      • ALTER TABLE stu DROP PRIMARY KEY;

    自動增長:

    • 概念:如果某一類是數值類型的,使用auto_increment 可以來完成值的自動增長

    • 在創建表時,添加主鍵約束,并完成自動增長

      • CERATE TABLE stu(id INT PRIMARY KEY AUTO_INCREMENT,`name` VARCHAR(20) );
    • 創建表完成后,添加自動增長

      • ALTER TABLE stu MODIFY id INT AUTO_INCREMENT;
    • 刪除自動增長

      • ALTER TABLE stu MODIFY id INT;

    非空約束:not null

    • 在創建表時添加約束

      • #創建表時添加非空約束 CREATE TABLE stu(id INT,`name` VARCHAR(32) NOT NULL );
    • 創建表完后,添加非空約束

      • #創建表完成后,添加非空約束 ALTER TABLE stu MODIFY `name` VARCHAR(32) NOT NULL;
    • 刪除name的非空約束

      • #刪除name的非空約束 ALTER TABLE stu MODIFY `name` VARCHAR(32);

    唯一約束:unique

    某一列不能重復

    注意: 唯一約束可以由null值,但是只能有一條記錄為null

    • 在創建表時添加約束

      • #創建表時添加唯一約束 CREATE TABLE stu1(id INT,phone_number VARCHAR(20) UNIQUE );
    • 在表創建完后,添加唯一約束

      • #在表創建完后,添加唯一約束 ALTER TABLE stu1 MODIFY phone_number VARCHAR(20) UNIQUE;
    • 刪除唯一約束

      • #刪除唯一約束 ALTER TABLE stu1 DROP INDEX phone_number;

    外鍵約束:foreign key

    • 在創建表時,可以添加外鍵

      • CREATE TABLE 表名(...外鍵列CONSTRAINT 外鍵名稱 FOREIGN KEY (外鍵列名稱) REFERENCES 主表名稱(主表列名稱) );
    • 創建表之后,添加外鍵

      • ALTER TABLE 表名 DROP FOREIGN KEY 外鍵名稱;
    • 刪除外鍵

      • ALTER TABLE 表名 ADD CONSTRAINT 外鍵名稱 FOREIGN KEY (外鍵列名稱) REFERENCES 主表名稱(主表列名稱);

    級聯操作:

    • 添加級聯操作

      • ALTER TABLE 表名 ADD CONSTRAINT 外鍵名稱FOREIGN KEY (外鍵字段名稱) REFERENCES 主表名稱(主表列名稱) ON UPDATE CASCADE ON DELETE CASCADE;
    • 分類:

      • 級聯更新:ON UPDATE CASCADE
      • 級聯刪除:ON DELETE CASCADE

    四、多表之間的關系

    (一)、關系分類

    一對一

    • 如:人和身份證
    • 分析:一個人只有一個身份證,一個身份證只能對應一個身份證

    一對多:

    • 如:部門和員工
    • 分析:一個部門有多個員工,一個員工只能對應一個部門

    多對多:

    • 如:學生和課程
    • 分析:一個學生可以選擇很多課程,一個課程也可以被很多學生選擇

    (二)、實現關系

    一對多(多對一):

    • 如:部門和員工
    • 實現方式:在多的一方建立外鍵,指向一的一方的主鍵

    多對多:

    • 如:學生和課程
    • 實現方式:多對多關系實現需要借助第三張中間表。中間表至少包含兩個字段。這兩個字段作為第三張表的外鍵,分別指向兩張表的主鍵

    一對一:

    • 如:學生和身份證
    • 實現方式:可以在任意一方添加唯一外鍵指向另一方的主鍵

    (三)、案例

    # 創建旅游路線分類表,tab_category # cid 旅游路線分類主鍵,自動增長 # cname 旅游路線分類名稱非空,唯一,字符串 100 CREATE TABLE tab_category (cid INT PRIMARY KEY AUTO_INCREMENT,`cname` VARCHAR(100) NOT NULL UNIQUE );# 創建旅游線路表 tab_route /* rid 旅游線路主鍵,自動增長 rname 旅游線路名稱非空,唯一,字符串 100 price 價格 rdate 上架時間,日期類型 cid 外鍵,所屬分類 */ CREATE TABLE tab_route(rid INT PRIMARY KEY AUTO_INCREMENT,`rname` VARCHAR(100) NOT NULL UNIQUE,price DOUBLE,rdate DATE,cid INT,FOREIGN KEY (cid) REFERENCES tab_category(cid) );# 創建用戶表 tab_user /* uid 用戶主鍵 username 用戶名 長度100,唯一,非空 password 密碼 長度30,非空 name 真實姓名 長度100 birthday 生日 sex 性別 定長字符串1 telephone 手機號 字符串11 email 郵箱 字符串長度100 */ CREATE TABLE tab_user(uid INT PRIMARY KEY AUTO_INCREMENT,`username` VARCHAR(100) UNIQUE NOT NULL,`password` VARCHAR(30) NOT NULL,`name` VARCHAR(100),`birhtday` DATE,`sex` CHAR(1) DEFAULT'男',`telephone` VARCHAR(11),`email` VARCHAR(100) );# 創建收藏表 tab_favorite /* rid 路由路線id,外鍵 date 收藏時間 uid 用戶id,外鍵 rid和uid不能重復,設置符合主鍵,同一個人用戶不能收藏同一個人線路兩次 */ CREATE TABLE tab_favotite(rid INT, #線路iddate DATETIME,uid INT, #用戶id# 創建復合主鍵PRIMARY KEY(rid,uid),FOREIGN KEY (rid) REFERENCES tab_route(rid),FOREIGN KEY (uid) REFERENCES tab_user(uid) );

    五、范式

    概念: 設計數據庫時,需要遵循的一些規范。要遵循后面的范式要求,必須先遵循前邊的范式要求

    (一)、幾個概念:

    • 函數依賴: A --> B,如果通過A屬性(屬性組)的值,可以確定唯一B屬性的值。則稱為B依賴于A
      • 例如:學號 --> 姓名 (學號,課程名稱)–> 分數
    • 完全函數依賴: A --> B,如果A是一個屬性組,則B屬性值的確定需要依賴于A屬性組中的所有屬性值
      • 例如:(學號,課程名稱)–> 分數
    • 部分函數依賴: A --> B,如果A是一個屬性組,則B屬性的值的確定只需要依賴與A屬性組中的某一些值即可
      • 例如:(學號,課程名稱)–>姓名
    • 傳遞函數依賴: A–> B, B --> C,如果通過A屬性(屬性組)的值,可以確定唯一B屬性的值,通過B屬性(屬性組)的值可以確定唯一C屬性的值,則稱為C傳遞依賴與A
      • 例如:學號 --> 系名,系名 -->系主任
    • 碼: 如果在一張表中,一個屬性或屬性組,被其他所有屬性所完全依賴,則成這個屬性(屬性組)為該表的碼
      • 例如:(學號,課程名稱)
      • 主屬性:碼屬性組中的所有屬性
      • 非主屬性:除了碼屬性組的屬性

    (二)、分類:

    • 第一范式(1NF): 沒一列都是不可分割的原子數據項

    • 第二范式(2NF): 在1NF的基礎上,非碼屬性必須完全依賴于碼(在1NF基礎上消除非主屬性對主碼的部分函數依賴

    • 第三范式(3NF): 在2NF基礎上,任何非主屬性不依賴于其他非主屬性(在2NF基礎上消除傳遞依賴

    • 巴斯-科德范式(BCNF):

    六、數據庫的備份和還原

    (一)、命令行

    • 語法:
      • 備份: mysqldump -u用戶名 -p密碼 數據庫名 > 保存的路徑
      • 還原:
        • 登錄數據庫——mysql -u用戶名 -p密碼
        • 創建數據庫——creat database 數據庫名;
        • 使用數據庫——use 數據庫名;
        • 執行文件 source 文件路徑——source d://a.sql

    (二)、圖形化界面

    • 很簡單
      • 備份:右鍵需要備份的數據庫 --> 轉儲SQL文件 --> 結構和數據
      • 還原:右鍵 --> 運行SQL文件 --> 找到需要還原的sql文件

    七、多表查詢

    (一)、什么是多表查詢

    查詢語法:

    select列名列表 from表名列表 where....

    案例:

    • # 創建部門表 create table dept(id int primary key auto_increment,name varchar(20) );insert into dept (name) values ('開發部'),('市場部'),('財務部');# 創建員工表 create table emp (id int primary key auto_increment,name varchar(10),gender char(1), -- 性別salary double, -- 工資join_date date, -- 入職日期dept_id int,foreign key (dept_id) references dept(id) -- 外鍵,關聯部門表(部門表的主鍵) );insert into emp(name,gender,salary,join_date,dept_id) values('孫悟空','男',7200,'2013-02-24',1); insert into emp(name,gender,salary,join_date,dept_id) values('豬八戒','男',3600,'2010-12-02',2); insert into emp(name,gender,salary,join_date,dept_id) values('唐僧','男',9000,'2008-08-08',2); insert into emp(name,gender,salary,join_date,dept_id) values('白骨精','女',5000,'2015-10-07',3); insert into emp(name,gender,salary,join_date,dept_id) values('蜘蛛精','女',4500,'2011-03-14',1);
    • 直接SELECT * FROM emp,dept; 的話就是將兩個表的數據進行笛卡爾積 計算,會存在很多無用的數據

    (二)、多表查詢的分類

    1. 內連接查詢

    隱式內連接: 使用where條件消除無用的數據

    • 語法: SELECT 字段名 FROM 左表, 右表 WHERE 條件;

    • # 隱式內連接 SELECT emp.`name`,gender,dept.`name` 部門 FROM emp,dept WHERE emp.`dept_id` = dept.`id`;

    顯示內連接: 使用INNER JOIN語句,可以省略INNER

    • 語法: SELECT 字段名 FROM 左表 [INNER] JOIN 右表 ON 條件;

    • # 顯式內連接 SELECT emp.`name`,gender,dept.`name` 部門 FROM emp JOIN dept ON emp.dept_id=dept.id;

    內連接總結:

    • 確定查詢哪些表
    • 確定表連接的條件
    • 確定查詢的條件
    • 確定查詢的字段

    2. 外鏈接查詢

    左外連接:

    • 語法: SELECT 字段列表 FROM 表1 LEFT [OUTER] JOIN 表2 ON 條件;

    • 查詢的是左表所有數據以及其交集部分。

    • 用左邊表的記錄去匹配右邊表的記錄,如果符合條件的則顯示;否則,顯示 NULL

    • 可以理解為:在內連接的基礎上保證左表的數據全部顯示**(左表是部門,右表員工)**

    • -- 在部門表中增加一個銷售部 insert into dept (name) values ('銷售部'); select * from dept; -- 使用內連接查詢 select * from dept d inner join emp e on d.`id` = e.`dept_id`; -- 使用左外連接查詢 select * from dept d left join emp e on d.`id` = e.`dept_id`;

    右外鏈接:

    • 語法: SELECT 字段列表 FROM 表1 RIGHT [OUTER] JOIN 表2 ON 條件;

    • 查詢的是右表所有數據以及其交集部分。

    • -- 在員工表中增加一個員工 insert into emp values (null, '沙僧','男',6666,'2013-12-05',null); select * from emp; -- 使用內連接查詢 select * from dept inner join emp on dept.`id` = emp.`dept_id`; -- 使用右外連接查詢 select * from dept right join emp on dept.`id` = emp.`dept_id`;

    3. 子查詢

    • 概念: 查詢中嵌套查詢,稱嵌套查詢為子查詢

    • 事例: 查詢最高員工的工資是多少

      • SELECT * FROM emp WHERE (SELECT MAX(salary) FROM emp)=salary;

    子查詢的結果是單行單列的:

    • 子查詢可以作為條件,使用運算符去判斷。運算符:> >= < <= =

    • -- 查詢員工工資小于平均工資的人的信息 SELECT * FROM emp WHERE (SELECT AVG(salary) FROM emp)>salary;

    子查詢的結果是多行單列的:

    • 子查詢可作為條件,結果集類似于一個數組,父查詢使用 IN 運算符

    • -- 查詢財務部和市場部所有的員工信息 SELECT * FROM emp WHERE dept_id IN (SELECT id FROM dept WHERE dept.`name` IN ('財務部','市場部'));

    子查詢的結果是多行多列的:

    • 子查詢結果只要是多列,肯定在 FROM 后面作為表,子查詢作為一張虛擬的表

    • -- 查詢員工入職日期是2011-11-11日之后的員工信息和部門信息 SELECT * FROM (SELECT * FROM emp WHERE join_date>'2011-11-11') t1,dept t2 WHERE t1.dept_id=t2.id;

    (三)、練習

    -- 部門表 CREATE TABLE dept (id INT PRIMARY KEY PRIMARY KEY, -- 部門iddname VARCHAR(50), -- 部門名稱loc VARCHAR(50) -- 部門所在地 );-- 添加4個部門 INSERT INTO dept(id,dname,loc) VALUES (10,'教研部','北京'), (20,'學工部','上海'), (30,'銷售部','廣州'), (40,'財務部','深圳');-- 職務表,職務名稱,職務描述 CREATE TABLE job (id INT PRIMARY KEY,jname VARCHAR(20),description VARCHAR(50) );-- 添加4個職務 INSERT INTO job (id, jname, description) VALUES (1, '董事長', '管理整個公司,接單'), (2, '經理', '管理部門員工'), (3, '銷售員', '向客人推銷產品'), (4, '文員', '使用辦公軟件');-- 員工表 CREATE TABLE emp (id INT PRIMARY KEY, -- 員工idename VARCHAR(50), -- 員工姓名job_id INT, -- 職務idmgr INT , -- 上級領導joindate DATE, -- 入職日期salary DECIMAL(7,2), -- 工資bonus DECIMAL(7,2), -- 獎金dept_id INT, -- 所在部門編號CONSTRAINT emp_jobid_ref_job_id_fk FOREIGN KEY (job_id) REFERENCES job (id),CONSTRAINT emp_deptid_ref_dept_id_fk FOREIGN KEY (dept_id) REFERENCES dept (id) );-- 添加員工 INSERT INTO emp(id,ename,job_id,mgr,joindate,salary,bonus,dept_id) VALUES (1001,'孫悟空',4,1004,'2000-12-17','8000.00',NULL,20), (1002,'盧俊義',3,1006,'2001-02-20','16000.00','3000.00',30), (1003,'林沖',3,1006,'2001-02-22','12500.00','5000.00',30), (1004,'唐僧',2,1009,'2001-04-02','29750.00',NULL,20), (1005,'李逵',4,1006,'2001-09-28','12500.00','14000.00',30), (1006,'宋江',2,1009,'2001-05-01','28500.00',NULL,30), (1007,'劉備',2,1009,'2001-09-01','24500.00',NULL,10), (1008,'豬八戒',4,1004,'2007-04-19','30000.00',NULL,20), (1009,'羅貫中',1,NULL,'2001-11-17','50000.00',NULL,10), (1010,'吳用',3,1006,'2001-09-08','15000.00','0.00',30), (1011,'沙僧',4,1004,'2007-05-23','11000.00',NULL,20), (1012,'李逵',4,1006,'2001-12-03','9500.00',NULL,30), (1013,'小白龍',4,1004,'2001-12-03','30000.00',NULL,20), (1014,'關羽',4,1007,'2002-01-23','13000.00',NULL,10);-- 工資等級表 CREATE TABLE salarygrade (grade INT PRIMARY KEY, -- 級別losalary INT, -- 最低工資hisalary INT -- 最高工資 );-- 添加5個工資等級 INSERT INTO salarygrade(grade,losalary,hisalary) VALUES (1,7000,12000), (2,12010,14000), (3,14010,20000), (4,20010,30000), (5,30010,99990);-- 需求:-- 1.查詢所有員工信息。查詢員工編號,員工姓名,工資,職務名稱,職務描述 SELECT emp.id,emp.ename,emp.salary,job.jname,job.description FROM emp,job WHERE emp.job_id=job.id;-- 2.查詢員工編號,員工姓名,工資,職務名稱,職務描述,部門名稱,部門位置 SELECT t1.id,t1.ename,t1.salary,t2.jname,t2.description,t3.dname,t3.loc FROM emp t1,job t2, dept t3 WHERE t1.job_id=t2.id AND t1.dept_id=t3.id;-- 3.查詢員工姓名,工資,工資等級 SELECTt1.ename,t1.salary,t2.grade FROMemp t1,salarygrade t2 WHEREt1.salary>t2.losalary AND t1.salary<t2.hisalary;-- 4.查詢員工姓名,工資,職務名稱,職務描述,部門名稱,部門位置,工資等級 SELECT t1.ename,t1.salary,t2.jname,t2.description,t3.dname,t3.loc,t4.grade FROM emp t1,job t2, dept t3,salarygrade t4 WHERE (t1.job_id=t2.id AND t1.dept_id=t3.id) AND t1.salary>t4.losalary AND t1.salary<t4.hisalary;-- 5.查詢出部門編號、部門名稱、部門位置、部門人數/*1.部門編號、部門名稱、部門位置dept表。部門人數emp表2.使用分組查詢。按照emp.dept_id完成分組,查詢count (id)3.使用子查詢將第2步的查詢結果和dept表進行關聯查詢*/ SELECT t1.id,t1.dname,t1.loc,t2.renshu FROMdept t1,(SELECTdept_id,COUNT(id) renshuFROMempGROUP BYdept_id) t2 WHEREt1.id=t2.dept_id;-- 6.查詢所有員工的姓名及其直接上級的姓名,沒有領導的員工也需要查詢 /*1.姓名emp,直接上級的姓名empemp表的id和mgr是自關聯2.條件emp .id =emp.mgr3.查詢左表的所有數據,和交集數據使用左外連接查詢 */ SELECTt1.ename,t1.mgr,t2.id,t2.ename FROMemp t1 LEFT JOINemp t2 ONt1.mgr=t2.id;SELECT * FROM emp;

    八、事務

    (一)、事務的基本介紹

    概念:

    • 如果一個包含多個步驟的業務操作,被事務管理,那么這些操作要么同時成功,要么同事失敗。
    • 在實際的開發過程中,一個業務操作如:轉賬,往往是要多次訪問數據庫才能完成的。轉 賬是一個用戶扣錢,另一個用戶加錢。如果其中有一條 SQL 語句出現異常,這條 SQL 就可能執行失敗。
    • 事務執行是一個整體,所有的 SQL 語句都必須執行成功。如果其中有 1 條 SQL 語句出現異常,則所有的 SQL 語句都要回滾,整個業務執行失敗。

    操作:

    • 開啟事務:start transaction;
    • 回滾:rollback;
    • 提交:commit;

    回滾點:

    • 在某些成功的操作完成之后,后續的操作有可能成功有可能失敗,但是不管成功還是失敗,前面操作都已經成 功,可以在當前成功的位置設置一個回滾點。可以供后續失敗操作返回到該位置,而不是返回所有操作,這個點稱 之為回滾點。
    • 設置回滾點:savepoint 名字;
    • 回到回滾點:rollback to 名字;

    MySQL數據庫中事務提交的兩種方式:

    • 自動提交:

      • MySQL 默認每一條 DML(增刪改)語句都是一個單獨的事務,每條語句都會自動開啟一個事務,語句執行完畢 自動提交事務,MySQL 默認開始自動提交事務
    • 手動提交:

      • Oracle 數據庫默認是手動提交事務
      • 需要先開啟事務,再提交
      • 執行成功的情況: 開啟事務 -> 執行多條 SQL 語句 -> 成功提交事務
      • 執行失敗的情況: 開啟事務 -> 執行多條 SQL 語句 -> 事務的回滾
    • 修改事務的默認提交方式

      • 查看事務的默認提交方式:select @@autocommit; 1代表自動提交,0代表手動提交
      • 修改默認提交方式:set @@autocommit=0;

    (二)、事務的四大特征

    原子性: 是不可分割的最小操作單位,要么同時成功,要么同時失敗。

    持久性: 當事務提交或回滾后,數據會持久化的保存數據。

    隔離性: 多個事務之間。相互獨立。

    一致性: 事務操作前后,數據總量不變。

    (三)、事務的隔離級別(了解)

    概念: 多個事務之間隔離的,互相獨立的。但是如果多個事務操作同一批數據,則會引發一些問題,設置不同的隔離級別就可以解決這些問題。

    存在的問題:

    • 臟讀:一個事務讀取到另一個事物中沒有提交的數據
    • 不可重復讀(虛讀):在同一個事務中,兩次讀取到的數據不一樣
    • 幻讀:一個事務操作(DML)數據表中所有的記錄,另一個事務添加了一條數據,則第一個事務查詢不到自己的修改

    隔離級別:

    • read uncommitted:讀未提交
      • 會產生的問題:臟讀、不可重復讀、幻讀
    • read committed:讀已提交 (Oracle默認)
      • 會產生的問題:不可重復讀、幻讀
    • repeatable read:可重復讀 (MySQL默認)
      • 會產生的問題:幻讀
    • serializable:串行化
      • 可以解決所有問題
      • 使用 serializable 隔離級別,一個事務沒有執行完,其他事務的 SQL 執行不了,可以擋住幻讀

    注意: 隔離級別從小到大安全性越來越高,但是效率越來越低

    數據庫查詢隔離級別:

    • select @@tx_isolation;
    • 在MySQL 8中已經修改為----SELECT @@transaction_isolation;

    數據庫設置隔離級別:

    • set global transaction isolation level 級別字符串;
    • 修改事務隔離級別的操作可以修改為:SET transaction_isolation = ‘READ-UNCOMMITTED’;

    九、DCL學習

    回顧SQL分類:

    • DDL:操作數據庫和表
    • DML:增刪改表中數據
    • DQL:查詢表中數據
    • DCL:管理用戶,授權

    DEA: 數據庫管理員

    DCL:管理用戶,授權

    1. 管理用戶

    • 添加用戶:

      • # 用戶名:登陸的用戶名;主機名:可以訪問的主機 CREATE USER '用戶名'@'主機名' IDENTIFIED BY '密碼';
    • 刪除用戶:

      • DROP USER '用戶名'@'主機名';
    • 修改用戶密碼:

      • # mysql8.0以上 alter user '用戶名'@'主機名' identified by '新密碼';
      • # mysql5.0 UPDATE USET SET PASSWORD=PASSWORD('新密碼') WHERE user='用戶名';
      • mysql中忘記了root用戶密碼?

        • cmd --> net stop mysql 停止MySQL服務
        • 使用無驗證方式啟動mysql服務:mysqld – skip-grant-tables
        • 打開新的cmd窗口,直接輸入mysql命令,敲回車。就可以登錄成功
        • use mysql;
        • update user set password = password(‘你的新密碼’); 根據版本略有不同
        • 關閉兩個窗口
        • 打開任務管理器,手動結束mysqld.exe進程
        • 啟動mysql服務
        • 使用新密碼登陸
    • 查詢用戶:

      • # 切換到mysql數據庫 USE mysql; # 查詢user表 SELECT * FROM USER;

    2. 管理權限

    • 查詢權限:

      • SHOW GRANTS FOR '用戶名'@'主機名';
    • 授予權限:

      • GRANT 權限列表 ON 數據庫名.表名 to '用戶名'@'主機名';
    • 撤銷權限:

      • REVOKE 權限列表 ON 數據庫名.表名 FROM '用戶名'@'主機名';

    十、JDBC

    • 概念: Java DataBase Connectivity (Java數據庫連接),Java語言操作數據庫
    • JDBC本質: 其實是官方(sun公司)定義的一套操作所有關系型數據庫的規則,即接口。各個數據庫廠商趨勢線這套接口,提供數據庫驅動jar包。我們可以使用這套接口(JDBC編程,)真正執行的代碼是驅動jar包中的實現類

    快速入門:

    • 步驟:
      • /* JDBC快速入門*/ public class JdbcDemo1 {public static void main(String[] args) throws Exception {//1. 導入jar包//2. 驅動注冊Class.forName("com.mysql.cj.jdbc.Driver");//3. 獲取數據庫連接對象Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3", "root", "123456");//4. 定義sql語句String sql = "update account set balance = 500 where id=1";//5. 獲取執行sql的對象,StatementStatement stmt = conn.createStatement();//6. 執行sqlint count = stmt.executeUpdate(sql);//7. 處理結果System.out.println(count);//8. 釋放資源stmt.close();conn.close();} }

    (一)、詳解各個對象:

    DriverManager:驅動管理對象

    • 功能:

      • 注冊驅動:告訴程序員該使用哪一數據庫驅動jar

        • static void registerDriver(Driver driver):注冊與給定的驅動程序 DriverManager
        • 寫代碼使用Class.forName("com.mysql.cj.jdbc.Driver");

        • 注意: mysql5 之后的驅動jar包可以省略注冊驅動的步驟

      • 獲取數據庫連接

        • 方法: static Connection getConnection(String url, String user, String password)
        • 參數:
          • url:指定連接的路徑
            • 語法:jdbc:mysql://ip地址(域名):端口號/數據庫名稱
            • 例子:jdbc:mysql://localhost:3306/db3
            • 擴展:如果連接的是本機的一個mysql服務器,并且mysql服務默認端口是3306,則url可以簡寫為:jdbc:mysql:///數據庫名稱
          • user:用戶名
          • password:密碼

    Connection:數據庫連接對象

    • 功能:
      • 獲取執行sql對象:
        • Statement createStatement()
        • PreparedStetement prepareStatement(String sql)
      • 管理事務:
        • 開啟事務:setAutoCommit(boolean autoCommit):調用該方法設置參數為false,即為開啟事務
        • 提交事務:commit()
        • 回滾事務:rollback()

    Statement:執行sql的對象

    • 執行sql:

      • boolean execute(String sql):可以執行任意的sql
      • int executeUpdate(String sql):執行DML(insert、update、delete)語句、DDL(create、alter、drop)語句
        • 返回值:影響的行數,可以通過這個影響的行數判斷DML語句是否執行成功 返回值>0的則執行成功,反之則失敗。
      • ResultSet executeQuery(String sql):執行DQL(select)語句
    • 練習:

      • account表,添加一條記錄

      • account表,修改記錄

      • account表,刪除一條記錄

      • /*account表,添加一條記錄,insert語句練習修改和刪除的步驟也是一樣,直接改sql語句就可以*/ public class JdbcDemo2 {public static void main(String[] args) {Statement stmt = null;Connection conne = null;try {//1. 注冊驅動Class.forName("com.mysql.cj.jdbc.Driver"); //可以不寫//2. 定義sqlString sql = "insert into account values(null,'王五',3000)";//3. 獲取Connection對象conne = DriverManager.getConnection("jdbc:mysql:///db3", "root", "123456");//4. 獲取執行sql的對象 Statementstmt = conne.createStatement();//5. 執行sqlint count = stmt.executeUpdate(sql); //影響的行數//6. 處理結果System.out.println(count);if (count > 0) {System.out.println("添加成功");} else {System.out.println("添加失敗");}} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException throwables) {throwables.printStackTrace();} finally {//7. 釋放資源//避免空指針異常if (stmt != null) {try {stmt.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (conne != null) {try {conne.close();} catch (SQLException throwables) {throwables.printStackTrace();}}}} }

    ResultSet:結果集對象,封裝查詢結果

    • next():游標向下移動一行,判斷當前行是最后一行末尾(是否有數據),如果是返回false,如果不是返回true

    • getXxx(參數):獲取數據

      • Xxx:代表數據類型
      • 參數:可以是int或者String
        • int:代表列的編號,從1開始
        • String:代表列的名稱
    • 使用步驟:

      • 游標向下移動一行
      • 判斷是否有數據
      • 獲取數據
    //6. 處理結果 //6.1 讓游標向下移動一行 while (rs.next()){//6.2 獲取數據int id = rs.getInt(1);String name = rs.getString(2);double balance = rs.getDouble(3);System.out.println(id+"-"+name+"-"+balance); }

    練習: 定義一個方法,查詢emp表的數據將其封裝為對象,然后裝載集合,返回。

    • 定義Emp類(自己定義一個Emp類,代碼中沒展示)
    • 定義方法 public List< Emp > findAll(){}
    • 實現方法 select * from emp;
    /*** 定義一個方法,查詢emp表的數據將其封裝為對象,然后裝載集合,返回。*/ public class JdbcDemo5 {public static void main(String[] args) {List<Emp> emps = findAll();System.out.println(emps);}/*** 查詢所有emp對象** @return*/public static List<Emp> findAll() {Emp emp = null;List<Emp> emps = new ArrayList<>();Connection conne = null;Statement stmt = null;ResultSet rs = null;try {//1. 注冊驅動Class.forName("com.mysql.cj.jdbc.Driver");//2. 獲取連接conne = DriverManager.getConnection("jdbc:mysql:///db2", "root", "123456");//3. 定義sqlString sql = "select * from emp";//4. 獲取執行sql的對象stmt = conne.createStatement();//5.執行sqlrs = stmt.executeQuery(sql);//6. 處理結果,封裝對象,裝載集合while (rs.next()) {//封裝對象emp = new Emp();emp.setId(rs.getInt(1));emp.setEname(rs.getString(2));emp.setJob_id(rs.getInt(3));emp.setMgr(rs.getInt(4));emp.setJoindate(rs.getDate(5));emp.setSalary(rs.getDouble(6));emp.setBouns(rs.getDouble(7));emp.setDept_id(rs.getInt(8));//裝載集合emps.add(emp);}} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException throwables) {throwables.printStackTrace();} finally { //釋放資源if (rs != null) {try {rs.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (stmt != null) {try {stmt.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (conne != null) {try {conne.close();} catch (SQLException throwables) {throwables.printStackTrace();}}}return emps;} }

    PreparedStatemt:執行sql的對象

    SQL注入問題: 在拼接sql時,有一些sql的特殊關鍵字參與字符串的拼接。會造成安全性問題

    解決SQL注入問題: 使用PreparedStatemt對象解決

    預編譯SQL: 參數試用 ? 作為占位符

    步驟:

    • 導入驅動jar包
    • 注冊驅動
    • 獲取數據庫連接對象 Connection
    • 定義sql
      • 注意: sql的參數使用 ? 作為占位符。如 select * from user where username=?and password=?;
    • 獲取執行sql語句的對象 PreparedStatement Connection.preparedStatement(String sql);
    • 給 ? 賦值
      • 方法: setXxx(參數1,參數2)
        • 參數1: ? 的位置編號 從1開始
        • 參數2: ? 的值
    • 執行sql
    • 處理結果
    • 釋放
    //1. 注冊驅動 Class.forName("com.mysql.cj.jdbc.Driver"); //2. 定義sql String sql = "select * from user where username = ? and password = ?"; //3. 獲取Connection對象 conne = DriverManager.getConnection("jdbc:mysql:///db3", "root", "123456"); //4. 獲取執行sql的對象 PrepareStatement pstmt = conne.prepareStatement(sql); //5. 給 ? 賦值 pstmt.setString(1,username); pstmt.setString(2,password); //6. 執行sql rs = stmt.executeQuery(); //7. 判斷 return rs.next(); //如果有下一行,則返回true //8. 釋放 ...

    (二)、抽取JDBC工具類

    目的: 簡化書寫

    分析:

    • 注冊驅動(也抽取出來)
    • 抽取一個方法獲取連接對象
      • 需求: 不想傳遞參數(麻煩),還得保證工具類的通用性
      • 解決: 通過配置文件
        • jdbc.properties
    • 抽取一個方法釋放資源

    jdbc.properties

    url=jdbc:mysql:///db2 user=root password=123456 driver=com.mysql.cj.jdbc.Driver

    JDBCUtils.java

    /*** JDBC工具類*/ public class JDBCUtils {private static String url;private static String user;private static String password;private static String driver;/*** 文件的數據,只需要讀取一次即可拿到這些值。使用靜態代碼塊*/static {//讀取資源文件,獲取值。try {//1. 創建Properties集合Properties properties = new Properties();//獲取src路徑下文件的方式 ----> ClassLoader 類加載器ClassLoader classLoader = JDBCUtils.class.getClassLoader();URL res = classLoader.getResource("jdbc.properties");String path = res.getPath();System.out.println(path);//2. 加載文件properties.load(new FileReader(path));//3. 獲取數據,賦值url = properties.getProperty("url");user = properties.getProperty("user");password = properties.getProperty("password");driver = properties.getProperty("driver");//4. 注冊驅動Class.forName(driver);} catch (IOException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}}/*** 獲取連接** @return 連接對象*/public static Connection getConnection() throws SQLException {return DriverManager.getConnection(url, user, password);}/*** 釋放資源** @param stmt* @param conn*/public static void close(Statement stmt, Connection conn) {if (stmt != null) {try {stmt.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (conn != null) {try {conn.close();} catch (SQLException throwables) {throwables.printStackTrace();}}}/*** 釋放資源** @param rs* @param stmt* @param conne*/public static void close(ResultSet rs, Statement stmt, Connection conne) {if (rs != null) {try {rs.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (stmt != null) {try {stmt.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (conne != null) {try {conne.close();} catch (SQLException throwables) {throwables.printStackTrace();}}} }

    JdbcDemo5.java

    /*** 定義一個方法,查詢emp表的數據將其封裝為對象,然后裝載集合,返回。*/ public class JdbcDemo5 {public static void main(String[] args) {List<Emp> emps = findAll();System.out.println(emps);}/*** 查詢所有emp對象** @return*/public static List<Emp> findAll() {Emp emp = null;List<Emp> emps = new ArrayList<>();Connection conne = null;Statement stmt = null;ResultSet rs = null;try {//1. 注冊驅動,2. 獲取連接conne = JDBCUtils.getConnection();//3. 定義sqlString sql = "select * from emp";//4. 獲取執行sql的對象stmt = conne.createStatement();//5.執行sqlrs = stmt.executeQuery(sql);//6. 處理結果,封裝對象,裝載集合while (rs.next()) {//封裝對象emp = new Emp();emp.setId(rs.getInt(1));emp.setEname(rs.getString(2));emp.setJob_id(rs.getInt(3));emp.setMgr(rs.getInt(4));emp.setJoindate(rs.getDate(5));emp.setSalary(rs.getDouble(6));emp.setBouns(rs.getDouble(7));emp.setDept_id(rs.getInt(8));//裝載集合emps.add(emp);}} catch (SQLException throwables) {throwables.printStackTrace();} finally { //釋放資源JDBCUtils.close(rs,stmt,conne);}return emps;} }

    (三)、JDBC管理事務

    事務: 一個包含多個步驟的業務操作。如果這個業務操作被事務管理,則這多個不收要么同時成功,要么同是失敗。

    操作:

    • 開啟事務
    • 提交事務
    • 回滾事務

    使用Connection對象來管理事務:

    • 開啟事務: setAutoCommit(boolean autoCommit):調用該方法設置參數為false,即開啟事務
    • 提交事務: commit()
    • 回滾事務: rollback()

    提前定義一個JDBCUtils工具類

    /*** 事務操作*/ public class JdbcDemo6 {public static void main(String[] args) {Connection conn = null;PreparedStatement pstmt1 = null;PreparedStatement pstmt2 = null;try {//1. 獲取連接conn = JDBCUtils.getConnection();//開啟事務conn.setAutoCommit(false);//2. 定義sql 張三減500 李四加500String sql1 = "update account set balance=balance- ? where id= ?";String sql2 = "update account set balance=balance+ ? where id= ?";//3. 獲取執行sql對象pstmt1 = conn.prepareStatement(sql1);pstmt2 = conn.prepareStatement(sql2);//4. 設置參數pstmt1.setDouble(1, 500);pstmt1.setDouble(2, 1);pstmt2.setDouble(1, 500);pstmt2.setDouble(2, 2);//5. 執行sqlpstmt1.executeUpdate();pstmt2.executeUpdate();//提交事務conn.commit();} catch (Exception throwables) {//事務回滾try {if (conn!=null){conn.rollback();}} catch (SQLException e) {e.printStackTrace();}throwables.printStackTrace();}finally {JDBCUtils.close(pstmt1,conn);JDBCUtils.close(pstmt2,null);}} }

    十一、數據庫連接池

    概念: 其實就是一個容器(集合),存放數據庫連接的容器。

    • 當系統初始化好后,容器被創建,容器中會申請一些連接對象,當用戶來訪問數據時,從容器中獲取連接對象,用戶訪問完之后,會將連接對象歸還給容器。

    好處:

    • 節約資源
    • 用戶訪問高效

    實現:

    • 標準接口:DataSource javax.sql包下的
      • 方法:
        • 獲取連接:getConnection()
        • 歸還連接:Connection.close(),如果連接對象Connection是從連接池中獲取的,那么調用Connection.close()方法,則不會關閉連接了。而是歸還連接
    • 一般我們不去實現它,有數據庫廠商來實現
      • C3P0:數據庫連接池技術
      • Druid:數據庫連接池技術,由阿里巴巴提供的

    C3P0:數據庫連接池技術

    步驟:

    • 導入jar包(兩個)
      • c3p0-0.9.5.2.jar
      • mchange-commons-java-0.2.12.jar
      • 不要忘記導入數據庫的驅動jar包
    • 定義配置文件:
      • 名稱:c3p0.properties 或者 c3p0-config.xml
      • 路徑:直接將文件放在src目錄下即可
    • 創建核心對象:數據庫連接池對象 ComboPooledDataSource
    • 獲取連接:getConnection

    配置文件:c3p0-config.xml

    <c3p0-config><!-- 使用默認的配置讀取連接池對象 --><default-config><!-- 連接參數 --><property name="driverClass">com.mysql.cj.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/db2</property><property name="user">root</property><property name="password">123456</property><!-- 連接池參數 --><!--初始化申請的連接數量--><property name="initialPoolSize">5</property><!--最大的連接數量--><property name="maxPoolSize">10</property><!--超時時間--><property name="checkoutTimeout">3000</property></default-config><named-config name="otherc3p0"> <!-- 連接參數 --><property name="driverClass">com.mysql.cj.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/db2</property><property name="user">root</property><property name="password">123456</property><!-- 連接池參數 --><property name="initialPoolSize">5</property><property name="maxPoolSize">8</property><property name="checkoutTimeout">1000</property></named-config> </c3p0-config>

    C3P0Demo1.java

    public class C3P0Demo1 {public static void main(String[] args) throws SQLException {//1. 獲取DataSource,使用默認配置 // DataSource ds = new ComboPooledDataSource();//1.1 獲取DataSource,使用指定名稱的配置DataSource ds = new ComboPooledDataSource("otherc3p0");//2. 獲取連接對象Connection conn = ds.getConnection();//3. 打印System.out.println(conn);} }

    Dtuid:數據庫連接池技術(阿里巴巴)

    步驟:

    • 導入jar包 druid-1.0.9.jar
    • 定義配置文件:
      • 是properties形式
      • 可以叫任意名稱,可以放在任意的目錄下
    • 加載配置文件 Propeoties
    • 獲取數據庫連接對象:通過工廠類來獲取,DruidDataSourceFactory
    • 獲取連接:getConnection

    配置文件:druid.properties

    driverClassName=com.mysql.cj.jdbc.Driver url=jdbc:mysql://127.0.0.1:3306/db3 username=root password=123456 # 初始化連接數量 initialSize=5 # 最大連接數 maxActive=10 # 雖大等待時間 maxWait=3000

    DruidDemo1.java

    /*** Druid演示*/ public class DruidDemo1 {public static void main(String[] args) throws Exception {//1. 導入jar包//2. 定義配置文件//3. 加載配置文件Properties pro = new Properties();InputStream inputStream = DruidDemo1.class.getClassLoader().getResourceAsStream("druid.properties");pro.load(inputStream);//4. 獲取連接池對象DataSource ds = DruidDataSourceFactory.createDataSource(pro);//5. 獲取連接Connection conn = ds.getConnection();System.out.println(conn);} }

    定義工具類:

    • 定義工具類 JDBCUils
    • 提供靜態代碼塊加載配置文件,初始化連接池對象
    • 提供方法
      • 獲取連接方法:通過數據庫連接池獲取連接
      • 釋放資源
      • 獲取連接池的方法
    /*** Druid的工具類*/ public class JDBCUtils {//1. 定義成員變量 DataSourceprivate static DataSource ds;static {try {//1. 加載配置文件Properties pro = new Properties();pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));//2. 獲取DataSourceds = DruidDataSourceFactory.createDataSource(pro);} catch (IOException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}}/*** 獲取連接* @return* @throws SQLException*/public static Connection getConnection() throws SQLException {return ds.getConnection();}/*** 釋放資源* @param stms* @param conn*/public static void close(Statement stms, Connection conn){ // if (stms!=null){ // try { // stms.close(); // } catch (SQLException throwables) { // throwables.printStackTrace(); // } // } // if (conn!=null){ // try { // conn.close(); // } catch (SQLException throwables) { // throwables.printStackTrace(); // } // }close(null,stms,conn);}/*** 釋放資源* @param rs* @param stms* @param conn*/public static void close(ResultSet rs, Statement stms, Connection conn){if (rs!=null){try {rs.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (stms!=null){try {stms.close();} catch (SQLException throwables) {throwables.printStackTrace();}}if (conn!=null){try {conn.close();} catch (SQLException throwables) {throwables.printStackTrace();}}}/*** 獲取連接池方法* @return*/public static DataSource getDataSource(){return ds;} }

    DruidDemo2.java

    /*** 使用工具類*/ public class DruidDemo2 {public static void main(String[] args) {/*** 完成添加操作:給account表添加一條記錄*/Connection conn = null;PreparedStatement pstmt = null;try {//1. 獲取連接conn = JDBCUtils.getConnection();//2. 定義sqlString sql = "insert into account values(null,?,?)";//3. 獲取pstmt對象pstmt = conn.prepareStatement(sql);//4.給 ? 賦值pstmt.setString(1,"趙六");pstmt.setDouble(2,3000);//5. 執行sqlpstmt.executeUpdate();} catch (SQLException throwables) {throwables.printStackTrace();}finally {JDBCUtils.close(pstmt,conn);}} }

    十二、Spring JDBC

    Spring框架對JDBC的簡單封裝。提供了一個JDBCTemplate對象簡化JDBC的開發

    步驟:

    • 導入jar包
    • 創建JdbcTemplate對象。依賴于數據源DataSource
      • JdbcTemplate template = new JdbcTemplate(ds);
    • 調用JdbcTemplate的方法來完成CRUD的操作
      • update():執行DML語句。增、刪、該語句
      • queryForMap():查詢結果將結果集封裝為map集合,將列名作為key,將值作為value 將這條記錄封裝為map
        • 注意: 這個方法查詢的結果集長度只能是1
      • queryForList():查詢結果將結果集封裝為list集合
        • 注意: 將每一條記錄封裝為一個Map集合,在將Map集合裝載到List集合中
      • query():查詢結果,將結果封裝為JavaBean對象
        • 一般我們使用BeanPropertyRowMapper實現類,可以完成數據到JavaBean的自動封裝
        • new BeanPropertyRowMapper<類型> (類型.class)
      • queryForObject:查詢結果,將結果封裝為對象
        • 一般用于聚合函數的查詢
    /*** JdbcTemplate入門*/ public class JdbcTemplateDemo1 {public static void main(String[] args) {//1. 導入jar包//2. 創建JDBCTemplate對象JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());//3. 調用方法String sql = "update account set balance = 5000 where id = ?";int count = template.update(sql, 3);System.out.println(count);} }

    練習

    需求:

    • 修改1號數據的salary 為 10000
    • 添加一條記錄
    • 刪除剛才添加的記錄
    • 查詢id為1的記錄,將其封裝為map集合
    • 查詢所有記錄,將其封裝為List集合
    • 查詢所有記錄,將其封裝為Emp對象的List集合
    • 查詢總記錄數

    注意:自己提前寫好JDBCUtils工具類和數據庫文件

    public class JdbcTemplateDemo2 {//1. 獲取JdbcTemplate對象private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());/*** 修改1001號數據的salary 為 10000*/@Testpublic void test1() {//2. SQL語句String sql = "update emp set salary=10000 where id=?";//3. 執行sqltemplate.update(sql, 1001);}/*** 添加一條記錄*/@Testpublic void test2() {//2. 定義sqlString sql = "insert into emp(id,ename,dept_id) value(?,?,?)";//3. 執行sqltemplate.update(sql, 1015, "郭靖", 10);}/*** 刪除剛才添加的記錄*/@Testpublic void test3() {String sql = "delete from emp where id=?";template.update(sql, 1015);}/*** 查詢id為1的記錄,將其封裝為map集合* 注意:這個方法查詢的結果集長度只能是1*/@Testpublic void test4() {String sql = "select * from emp where id=?";Map<String, Object> map = template.queryForMap(sql, 1001);System.out.println(map);}/*** 查詢所有記錄,將其封裝為List集合*/@Testpublic void test5() {String sql = "select * from emp";List<Map<String, Object>> list = template.queryForList(sql);for (Map<String, Object> m :list) {System.out.println(m);}}/*** 查詢所有記錄,將其封裝為Emp對象的List集合*/@Testpublic void test6(){String sql = "select * from emp";List<Emp> list = template.query(sql, new RowMapper<Emp>() {@Overridepublic Emp mapRow(ResultSet rs, int i) throws SQLException {Emp emp = new Emp();emp.setId(rs.getInt("id"));emp.setEname(rs.getString("ename"));emp.setJob_id(rs.getInt("job_id"));emp.setMgr(rs.getInt("mgr"));emp.setJoindate(rs.getDate("joindate"));emp.setSalary(rs.getDouble("salary"));emp.setBonus(rs.getDouble("bonus"));emp.setDept_id(rs.getInt("dept_id"));return emp;}});for (Emp emp :list) {System.out.println(emp);}}/*** 查詢所有記錄,將其封裝為Emp對象的List集合*/@Testpublic void test6_2(){String sql = "select * from emp";List<Emp> list = template.query(sql, new BeanPropertyRowMapper<Emp>(Emp.class));for (Emp emp :list) {System.out.println(emp);}}/*** 查詢總記錄數*/@Testpublic void test7(){String sql = "select count(id) from emp";Long total = template.queryForObject(sql, Long.class);System.out.println(total);} }

    總結

    以上是生活随笔為你收集整理的MySQL从入门到精通的全部內容,希望文章能夠幫你解決所遇到的問題。

    如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。