# 连接 MySQL
mysql -u username -p

-- 注释写法1 : 不区分大小写，关键字建议大写
# 注释写法2 : 可以使用缩进或空格
/*	注释写法3 */

/* 数据库的操作 */
# 查询所有数据库
SHOW DATABASES;

# 查询当前数据库
SELECT DATABASE();

# 创建数据库
CREATE DATABSE [IF NOT EXISTS] 数据库名 [DEFAULT CHARSET 字符集] [COLLATE 排序规则];

# 使用数据库 
USE 数据库名;

# 删除
DROP DATABASE [IF NOT EXISTS] 数据库名;

/* 表操作 */
# 查询所有数据表
SHOW TABLES;

# 查询表结构
DESC 表名;

# 查询表的建表语句
SHOW CREATE TABLE 表名;

# 创建表
CREATE TABLE 表名(
    字段1 字段1类型[COMMENT 字段1注释],
	字段2 字段2类型[COMMENT 字段2注释],
    字段3 字段3类型[COMMENT 字段3注释],
)[COMMENT 表注释];

# 添加字段
ALTER TABLE 表名 ADD 字段名 类型(长度) [COMMENT 注释][约束];

# 修改数据类型
ALTER TABLE 表名 MODIFY 字段名 新数据类型(长度);

# 修改字段名和字段类型
ALTER TABLE 表名 CHANGE 旧字段名 新字段名 类型(长度) [COMMENT 注释] [约束];

# 删除字段
ALTER TABLE 表名 DROP 字段名;

# 修改表名
ALTER TABLE 表名 RENAME TO 新表名;

# 删除表
DROP TABLE [IF EXISTS] 表名;

# 删除指定表并重新创建该表
TRUNCATE TABLE 表名;

# 给指定字段添加数据
INSERT INTO 表名(字段名1, 字段名2, ...) VALUES(值1, 值2, ...);

# 给全部字段添加数据
INSERT INTO 表名字 VALUES(值1, 值2, ...);

# 修改数据
UPDATE 表名 SET 字段名1 = 值1, 字段名2 = 值2, ... [WHERE 条件];

# 删除数据
DELETE FROM 表名 [WHERE 条件];

SELECT
	字段列表
FROM
	表名列表
WHERE
	条件列表
GROUP BY
	分组字段列表
HAVING
	分组后条件列表
ORDER BY
	排序字段列表
LIMIT
	分页参数

# 查询多个字段
SELECT 字段1, 字段2, 字段3 ... FROM 表名;
SELECT * FROM 表名;

# 设置别名
SELECT 字段1[AS 别名1], 字段2[AS 别名2] .. FROM 表名;

# 去除重复记录
SELECT DISTINCT 字段列表 FROM 表名;

# 查询没有身份证号的员工信息
SELECT * FROM emp WHERE idcard IS NULL;

# 查询 15岁 到 20岁 之间的员工信息
SELECT * FROM emp WHERE age >= 15 and age <= 20;
SELECT * FROM emp WHERE age BETWEEN 20 and 15;

# 查询年龄为 18岁 或 20岁 或 40岁 的员工信息
SELECT * FROM emp WHERE age = 18 OR age = 20 OR age = 40;
SELECT * FROM emp WHERE age IN(18, 20, 40);

# 查询姓名为两个字的员工信息
SELECT * FROM emp WHERE name LIKE '__';

# 查询身份证最后一位是X的员工信息
SELECT * FROM emp WHERE idcard LIKE '%X';

# 统计企业员工数据量
SELECT COUNT(*) FROM emp;

# 根据性别分组，统计男性员工和女性员工的数量
SELECT gender, count(*) FROM emp GROUP BY gender;

# 查询年龄小于 45岁 的员工，并根据工作地址分组，获取员工数量大于3的工作地址
SELECT workaddress, count(*) FROM emp WHERE age<45 GROUP BY workaddress HAVING count(*)>3;

# 根据年龄对公司的员工进行升序排序
SELECT * FROM emp ORDER BY age ASC;

# 根据入职时间对员工进行降序排序
SELECT * FROM emp ORDER BY entrydate DESC;

# 先按年龄升序排，年龄同的按入职时间降序排
SELECT * FROM emp ORDER BY age ASC, entrydate DESC;

# 查询第 1 页员工数据，每页展示 10 条记录
SELECT * FROM emp LIMIT 0, 10;

# 查询第 2 页员工数据，每页展示 10 条记录
SELECT * FROM emp LIMIT 10,10;

# 查询用户
USE mysql;
SELECT * FROM USER;

# 创建用户
CREATE USER '用户名'@'主机名' IDENTIFIED BY '密码';

# 修改用户密码
ALTER USER '用户名'@'主机名' IDENTIFIED WITH mysql_native_password BY '新密码';

# 删除用户
DROP USER '用户名'@'主机名';

# 查询权限
SHOW GRANTS FOR '用户名'@'主机名';

# 授予权限
GRANT 权限列表 ON 数据库名.表名 TO '用户名'@'主机名';

# 撤销权限
REVOKE 权限列表 ON 数据库名.表名 FROM '用户名'@'主机名';

-- concat
SELECT CONCAT('Hello ', 'MySQL');

-- LOWER
SELECT LOWER('Hello');

-- UPPER
SELECT UPPER('Hello');

-- LPAD
SELECT LPAD('01', 5, '-');

-- RPAD
SELECT RPAD('01', 5, '-');

-- TRIM
SELECT TRIM(' Hello MySQL ');

-- SUBSTRIMG
SELECT SUBSTRING('Hello MySQL', 1, 5);

-- CEIL(x)
SELECT CEIL(1.1);

-- FLOOR(x)
SELECT FLOOR(1.9);

-- MOD(x,y)
SELECT MOD(3, 4);

-- RAND()
SELECT RAND();

-- ROUND(x,y)
SELECT ROUND(3.1415926, 2);

-- CURDATE()
SELECT CURDATE();

-- CURTIME()
SELECT CURTIME();

-- NOW()
SELECT NOW();

-- YEAR, MONTH, DAY
SELECT YEAR(NOW());
SELECT MONTH(NOW());
SELECT DAY(NOW());

-- DATE_ADD(date, INTERVAL expr type)
SELECT DATE_ADD(NOW(), INTERVAL 70 DAY);

-- DATEDIFF(date1, date2)
SELECT DATEDIFF('2024-02-29', '2023-11-11');

-- IF
SELECT IF(FALSE, 'OK', 'ERROR');

-- IFNULL
SELECT IFNULL('Get', 'DEFAULT');
SELECT IFNULL('', 'DEFATLT');
SELECT IFNULL(null, 'DEFATLT');

-- CASE WHEN[val1] THEN[res1] ... ELSE[default] END
SELECT name, CASE WHEN score >= 85 THEN '优秀' WHEN score >= 60 THEN '及格' ELSE '不及格' END FROM student_score;

-- CASE [expr] WHEN[val1] THEN[res1] ... ELSE[default] END
SELECT name, CASE workaddress WHEN '北京' THEN '一线城市' WHEN '上海' THEN '一线城市'ELSE '二线城市' END FROM emp; 

CREATE TABLE USER(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
    name VARCHAR(10) NOT NULL UNIQUE COMMENT '姓名',
    age INT CHECK(age > 0 AND age <= 120) COMMENT '年龄',
    status CHAR(1) DEFAULT '1' COMMENT '状态',
	gender CHAR(1) COMMENT '性别'
) COMMENT '用户表';

CREATE TABLE emp(
    id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
    name VARCHAR(10) NOT NULL UNIQUE COMMENT '姓名',
	age INT CHECK(age > 0 AND age <= 120) COMMENT '年龄',
    salary INT CHECK(salary > 0) NOT NULL COMMENT '薪资',
    entrydate NOT NULL COMMENT '入职时间',
    managerid INT COMMENT '直属领导ID',
    dept_id INT '部门ID'
) COMMENT '员工表';

CREATE TABLE dept(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT 'ID',
    name VARCHAR(50) NOT NULL COMMENT '部门名称'
) COMMENT '部门表';

# 添加外键
ALTER TABLE emp ADD CONSTRAINT fk_emp_dept_id FOREIGN KEY (dept_id) REFERENCES dept(id) ON UPDATE CASCADE ON DELETE CASCADE;

ALTER TABLE emp ADD CONSTRAINT fk_emp_dept_id FOREIGN KEY (dept_id) REFERENCES dept(id) ON UPDATE CASCADE ON DELETE SET NULL;

# 删除外键
ALTER TABLE emp DROP FOREIGN KEY fk_emp_dept_id;

CREATE TABLE student(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
    name VARCHAR(10) COMMENT '姓名',
    sid VARCHAR(10) COMMENT '学号'
) COMMENT '学生表';

CREATE TABLE course(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
    name VARCHAR(10) COMMENT '课程名称'
)COMMENT '课程表';

CREATE TABLE student_course(
	id INT PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
    studentid INT COMMENT '学生ID',
    courseid INT COMMENT '课程ID',
    CONSTRAINT fk_courseid FOREIGN KEY (courseid) REFERENCES course(id),
    CONSTRAINT fk_studentid FOREIGN KEY (studentid) REFERENCES student(id)
)COMMENT '学生选课表';

# 多表查询 - 笛卡尔积
SELECT * FROM emp, dept WHERE emp.detp_id = dept.id;

# 内连接查询的是两张交集的部分
SELECT 字段列表 FROM 表1, 表2 WHERE 条件 ...;
SELECT 字段列表 FROM 表1 [INNER] JOIN 表2 ON 连接条件;

# 左外连接
SELECT 字段列表 FROM 表1 LEFT [OUTER] JOIN 表2 ON 条件 ...;

# 右外连接
SELECT 字段列表 FROM 表1 RIGHT [OUTER] JOIN 表2 ON 条件 ...;

# 自连接可以是内连接也可以是外连接
SELECT 字段列表 FROM 表A 别名A JOIN 表A 别名B ON 条件 ...;
SELECT 字段列表 FROM 表A 别名A LEFT[OR RIGHT] [OUTER] JOIN 表B 别名B ON 条件 ...;

# UNION ALL 是不合并相同信息
SELECT * FROM emp WHERE salary < 5000
UNION ALL
SELECT * FROM emp WHERE age > 50;

# 嵌套查询就是子查询
SELECT * FROM t1 WHERE column1 = (SELECT column1 FROM t2);

# 查询销售部所有员工信息
SELECT * FROM emp WHERE dept_id = (SELECT id FROM dept WHERE name = '销售部');

# 查询销售部和市场部所有员工信息
SELECT * FROM emp WHERE dept_id IN((SELECT id FROM dept WHERE name IN('销售部', '市场部')));

# SOME、ANY、ALL 使用
# 比财务部所有人工资都高
SELECT * FROM emp WHERE salary > ALL(SELECT salary FROM emp WHERE dept_id = (SELECT id FROM dept WHERE name = '财务部'));

# 查看、设置事务提交方式
SELECT @@autocommint;
SET @@autocommint = 0;

# 开启事务
START TRANSACTION;
BEGIN;

# 提交事务
COMMIT;

# 回滚事务
ROLLBACK;

CREATE TABLE account(
	ID INT AUTO_INCREMENT PRIMARY KEY  COMMENT '主键',
	NAME VARCHAR(10) COMMENT '姓名',
	MONEY INT COMMENT '余额'
) COMMENT '账户表';
INSERT INTO account(ID, NAME, MONEY) VALUES (null, '张三', 2000), (null, '李四', 2000);

# 恢复数据
UPDATE account SET MONEY = 2000 WHERE NAME IN('张三', '李四');

# 张三给李四转账 1000
# 1.查询张三账户余额
SELECT MONEY FROM account WHERE name = '张三';
# 2.将张三用户余额 -1000
UPDATE account SET MONEY = MONEY - 1000 WHERE name = '张三';
# 3.将李四用户余额 +1000
UPDATE account SET MONEY = MONEY + 1000 WHERE name = '李四';

# 查看事务隔离级别
SELECT @@TRANSACTION_ISOLATION;

# 设置事务隔离级别
SET [SESSION|GLOBAL] TRANSACTION ISOLATION LEVEL {READ UNCOMMITTED | READ COMMITTED | REPEATABLE READ | SERIALIZABLE};

# 启动
systemctl start mysqld

# 重启
systemctl restart msyqld

# 停止
systemctl stop mysqld

grep 'temporary password' /var/log/mysqld.log

# 设置密码复杂度和密码长度
SET GLOBAL VALIDATE_PASSWORD.policy = 0;
SET GLOBAL VALIDATE_PASSWORD.length = 4;

# 修改密码
ALTER USER 'root'@'localhost' IDENTIFIED BY '1234';

CREATE USER 'root'@'%' IDENTIFIED WITH mysql_native_password BY '1234';

grant all on *.* to 'root'@'%';

# 创建表时指定存储引擎
CREATE TABLE 表名(

)ENGINE = INNODB；

# 查询数据库支持的存储引擎
SHOW ENGINES；

# 创建索引
CREATE [UNIQUE | FULLTEXT] INDEX index_name ON table_name (index_col_name, ...);

# 查看索引
SHOW INDEX FROM table_name;

# 删除索引
DROP INDEX index_name ON table_name;

SHOW GLOBAL STATUS LIKE 'com______';

# 开启 MySQL 慢日志查询
slow_query_log = 1

# 设置超 2 秒就视为慢查询
long_query_time = 2

# 重启后，慢查询日志
SHOW VARIABLES LIKE 'slow_query_log';

# 生成文件 /var/lib/mysql/localhost-slow.log

# 默认关闭，通过 SET 在 session / global 开启
SET profiling = 1;

# 查看 profiles 是否开启
SELECT @@have_profiling;

# 查看每一条 SQL 的耗时基本情况
SHOW profiles;

# 查看指定 query_id 的 SQL 语句各个阶段的耗时情况
SHOW profile FOR query query_id;

# 查看指定 query_id 的 SQL 语句 CPU 使用情况
SHOW profile cpu FOR query query_id;

# 直接在 SELECT 语句前加上关键字 explain / desc
EXPLAIN SELECT 字段 FROM 表名 WHERE 条件;

/*
	id 相同，从上到下顺序执行；不同则值大的先执行。
	select_type 表示 SELECT 类型。
	tyep 表连接类型，性能好到差为 NULL、system、const、eq_ref、ref、range、index、all。
	possible_key 显示可能应用这个表上的索引，一个或多个。
	key 为实际使用的索引。
	key_len 索引中使用的字节数，即索引字段最大可能值。
	rows MySQL 认为必须要执行查询的行数，这是估计值。
	filtered 表示返回结果的行数占所需读取行数的百分比，值越大越好。
*/

# 未建立索引前执行 SQL
SELECT * FROM tb_sku WHERE sn = '100000003145001';
# 针对字段建立索引
CREATE INDEX idx_sku_sn ON tb_sku(sn);
# 再次执行
SELECT * FROM tb_sku WHERE sn = '100000003145001';

# USE INDEX
explain select * from tb_user use index(idx_user_pro) where profession='软件工程';

# IGNORE INDEX
explain select * from tb_user ignore index(idx_user_pro) where profession='软件工程';

# FORCE
explain select * from tb_user force index(idx_user_pro) where profession='软件工程';

CREATE INDEX idx_xxx ON table_name(column(n));

# 前缀长度：不重复数据 和 总数据的比值
SELECT count(distinct email)/count(*) FROM tb_user;
SELECT count(distinct substring(email, 1,5)) / count(*) FROM tb_user;

# 单列索引情况 MysQL 优化器会自动评估哪个字段的索引效率更高
EXPLAIN select id,phone,name from tb_user where phone='12314123' and name = '李白';

-- 批量插入
INSERT INTO tb_test VALUES (1, 'Tom'), (2, 'Cat');

-- 手动提交事务
START TRANSACTION;
INSERT INTO tb_test VALUES (1, 'Tom'), (2, 'Cat');
INSERT INTO tb_test VALUES (3, 'Jerry'), (4, 'Mike');
COMMIT;

-- 主键顺序插入

-- 大批量插入
# 连接服务器
mysql --local-infile -u root -p

# 设置变量，从本地加载文件导入数据
SET GLOBAL local_infile = 1;

# 执行 load 指令，加载数据到表
load data local infile '/root/sql1.log' into table 'tb_user' fields terminated by ',' lines terminated by '\n';

# 不直接使用 limit 获取全部数据，而是只获取 id 然后再作为表查询
SELECT s.* FROM tb_sku s, (SELECT id FROM tb_sku ORDER BY id LIMIT 9000000, 10) a WHERE s.id = a.id;

# 效率排行 ：count(*) > count(1) > count(主键) > count(字段)

# 创建
CREATE [OR REPLACE] VIEW 视图名称[(列名列表)] AS SELECT语句 [with cascaded check option]; 

# 查询
SHOW CREATE VIEW 视图名称;
SELECT * FROM 视图名称 ...;

# 修改
CREATE [OR REPLACE] VIEW 视图名称[(列名列表)] AS SELECT语句。
ALTER VIEW 视图名称[(列名列表)] AS SELECT语句。

# 删除
DROP VIEW [IF EXISTS] 视图名;

# 创建
# 通过关键字 delimiter 指定 SQL 语句结束符
/*
delimiter $$
CREATE PROCEDURE 存储过程名称([参数列表])
BEGIN
	-- SQL 语句
END$$
*/
CREATE PROCEDURE 存储过程名称([参数列表])
BEGIN
	-- SQL 语句
END;

# 调用
CALL 名称([参数]);

# 查看
SELECT * FROM INFORMATION_SCHEMA.ROUTINES WHERE ROUTINE_SCHEMA = 'xxx';
SHOW CREATE PROCEDURE 存储过程名称;

# 删除
DROP PROCEDURE [IF EXISTS] 存储过程名称;

# 查看系统变量
SHOW [SESSION|GLOBAL] VARIABLES;
SHOW [SESSION|GLOBAL] VARIABLES LIKE ...;
SELECT @@[SESSION|GLOBAL] 系统变量名;

# 设置系统变量
SET [SESSION|GLOBAL] 系统变量名 = 值;
SET @@[SESSION|GLOBAL] 系统变量名 = 值;

# 赋值
SET @var_name = expr;
SET @var_name := expr;
SELECT @var_name := expr;
SELECT 字段名 INTO @var_name FROM 表名;
# 使用
SELECT @var_name;

# 声明
DECLARE 变量名 变量类型 [DEFAULT ...];
# 赋值
SET 变量名 = 值;
SET 变量名 := 值;
SELECT 字段名 INTO 变量名 FROM 表名 ...;

# if 语句
IF 条件1 THEN
...
ELSEIF 条件2 THEN	
...
ELSE
...
END IF;

#  参数 IN、OUT、INOUT
CREATE PROCEDURE 存储过程名称([IN/OUT/INOUT 参数名 参数类型])
BEGIN
	-- SQL 语句
END;

# case 语句
CASE case_value
	WHEN when_value1 THEN statement_list1
	...
END CASE;

CASE
	WHEN search_condition1 THEN statement_list1
	...
END CASE;

# while 语句
WHILE 条件 DO
	SQL 逻辑
END WHILE;

# repeat 语句
REPEAT
	SQL 逻辑
	UNTIL 条件
END REPEAT;

# loop 函数
# LEAVE：退出循环；ITERATE：跳过当前循环，进入下次循环。
[begin_label:]LOOP
	SQL 逻辑
END LOOP [end_label];

CREATE PROCEDURE pp(IN n INT)
BEGIN
	DECLARE total INT DEFAULT 0;
	
	sum:LOOP
		IF n <= 0 THEN
			LEAVE sum;
		END IF;
		
		SET total := total + n;
		SET n := n - 1;
	END LOOP sum;
	SELECT total;
END;

/* 
	游标（CURSOR）用来存储查询结果集的数据类型，
	在存储过程和函数中可使用游标对结果集进行循环处理。
*/
# 游标声明
DECLARE 游标名称 CURSOR FOR 查询语句;
# 打开游标
OPEN 游标名称;
# 获取游标记录(循环获取)
FETCH 游标名称 INTO 变量;
# 关闭游标
CLOSE 游标名称;

# 条件处理程序 Handler
# handler_action：CONTINUE 继续执行当前程序、EXIT 终止执行当前程序。
# SQLSTATE sqlstate_value 状态码、SQLWARNING 以01开头的SQLSTATE代码简写、NOT FOUND 以02开头的SQLSTATE代码简写、SQLEXCEPTION 其他。
DECLARE handler_action HANDLER FOR condition_value statement;

DECLARE exit HANDLER FOR SQLSTATE '02000' CLOSE u_cursor;

/*
	DETREMINISTIC：相同的输入参数总是产生相同的结果;
	NO SQL：不包含 SQL 语句;
	READS SQL DATA：包含连续读取数据的语句，但不包含写入数据语句。
*/
CREATE FUNCTION 存储函数名称([参数列表])
RETURNS type [characteristic ...]
BEGIN
	-- SQL 语句
	RETURN ...;
END;

# 创建
CREATE TRIGGER trigger_name
BEFORE / AFTER INSERT / UPDATE / DELETE
ON table_name FOR EACH ROW
BEGIN
	triggle_statement;
END;
# 查看
SHOW TRIGGERS;
# 删除
DROP TRIGGER [schema_name.]trigger_name;

-- 通过触发器记录 tb_user 表的变更数据，将变更日志插入到日志表 user_logs 中，包含增加、修改、删除
# 日志表 user_log
create table user_logs(
	id int(11) not null auto_increment;
    operation varchar(20) not null comment '操作类型',
    operation_tim datetime not null comment '操作时间',
    operate_id int(11) not null comment '操作ID',
    operate_params varchar(500) comment '操作参数',
    primary key(id)
)engine=innodb default charset=utf8;

# 插入数据触发器
create trigger tb_user_insert_trigger
	after insert on tb_user for each row
begin
	insert into user_logs(id, operation, operate_time, operate_id, operate_params) values (null, 'insert', now(), new.id, concat('插入的数据内容为：id=', new.id, ', name=', new.name, ', phone=', new.phone, ', email=', new.email))
end;

# 更新数据触发器
create trigger tb_user_update_trigger
	after insert on tb_user for each row
begin
	insert into user_logs(id, operation, operate_time, operate_id, operate_params) values (null, 'update', now(), new.id, concat('更新前内容为：id=', old.id, ', name=', old.name, ', phone=', old.phone, ', email=', old.email,'更新后内容为：id=', new.id, ', name=', new.name, ', phone=', new.phone, ', email=', new.email))
end;

# 不加锁一致性数据备份
mysqldump --single-transaction -h [address] -uroot -p1234 TestDB > TestDB.sql;
# 加锁
flush tables with read lock;

# 备份
mysqldump -h [address] -uroot -p1234 TestDB > TestDB.sql;

# 解锁
unlock tables;

/*
	当开启事务时，就不能对元数据进行操作，只有事务结束了才能操作。
	一般来说，读数据是可以加表锁；而改数据是不能加表锁的。
*/
# 表锁
LOCK TABLES 表名 READ / WRITE;
UNLOCK TABLES / 客户端断开连接;

# 加锁
SELECT 语句 LOCK IN SHARE MODE;

# 查看元数据锁
SELECT * FROM performance_schema.metadata_locks;

# 查看意向锁和行锁
SELECT * FROM performance_schema.data_locks;

# 创建表空间
CREATE TABLESPACE xxx ADD 
DATAFILE 'file_name'
ENGINE = engine_name;
# 创建表
CREATE TABLE xxx TABLESPACE ts_name;

SHOW ENGINE innodb status;

mysql -uroot -p123456 db01 -e "select * from stu*"

mysqladmin -uroot -p123456 drop 'test01'

mysqladmin -uroot -p123456 version

# 查询每个数据库的表的数量以及表中记录的数量
mysqlshow -uroot -p1234 --count

# 查询 test 库中每个表的字段数，以及行数
mysqlshow -uroot -p1234 test --count

# 查询 test 库中 book 表的详细情况
mysqlshow -uroot -p1234 test book --count

source /root/test.sql
mysqlimport -uroot -p1234 test /tmp/city.txt

# 查看日志文件地址
SHOW VARIABLES LIKE '%log_error%';

# 查看日志文件地址
SHOW VARIABLES LIKE '%log_bin';

# 查看格式
SHOW VARIABLES LIKE '%binlog_format%';

SHOW VARIABLES LIKE '%binlog_expire_logs_seconds%';

# 查询 general_log 是否开启
SHOW VARIABLES LIKE '%general%';

# 在配置中开启查询日志
general_log = 1

# 设置文件名默认为 host_name.log
general_log_file = mysql_query.log

# 慢查询日志
slow_query_log = 1

# 执行时间参数
long_query_time = 2

# 记录执行较慢的管理语句
log_slow_admin_statements = 1

# 记录执行较慢的未使用索引的语句
log_queries_not_using_indexs = 1

# 开放指定 3306 端口号
firewall-cmd --zone=public --add-port=3306/tcp -permanent
firewall-cmd -reload

# 关闭服务器防火墙
systemctl stop firewalld
systemctl diable firewalld

# mysql 服务器 ID，确保集群中唯一
server-id = 1

# 是否只读，1 代表只读，0代表读写
read-only = 0

# 忽略的数据，指不需要同步的数据库
# binlog-ignore-db = mysql

# 指定同步的数据库
# binlog-do-db = db01

systemctl restart mysqld

# 创建用户
CREATE USER 'master'@'%' IDENTIFIED WITH mysql_native_password BY 'root@123456';

# 分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'master'@'%'

/*
	file 从哪个日志文件开始推送
	postions 从哪个位置开始推送
	binlog_ignore_db 指定不需要同步的数据库
*/
SHOW MASTER STATUS;

# 设置服务器 ID
server-id = 2

# 是否只读
read-only = 1

systemctl mysql restart

CHANGE REPLICATION SOURCE TO SOURCE_HOST='xxx.xxx',SOURCE_USER='xxx',SOURCE_PASSWORD='xxx',SOURCE_LOG_FILE='xxx',SOURCE_LOG_POS=xxx;

START REPLICA;

SHOW REPLICA STATUS;