MySQL - 锁定表
MySQL 数据库提供多用户环境，允许多个客户端同时访问数据库。为了顺利运行此环境，MySQL 引入了锁的概念。
会话中的客户端可以锁定正在处理的某个表，以防止其他客户端使用同一张表。此过程可以避免多个用户同时处理同一张表时可能发生的数据丢失。
客户端可以锁定表并在需要时解锁。但是，如果某个表已被某个客户端会话锁定，则其他客户端会话在锁定状态释放之前无法访问该表。
MySQL 中的表锁定
您可以通过锁定 MYSQL 中的表来限制对表记录的访问。这些锁用于阻止其他会话修改当前会话中的表。
MySQL 会话只能为自己获取或释放表锁。要使用 MySQL LOCK TABLES 语句锁定表，您需要拥有 TABLE LOCK 和 SELECT 权限。
这些锁用于解决并发问题。MYSQL 表锁有两种类型 -
读锁 - 如果您在表上应用此锁，则对该表的写操作将受到限制。即，只有持有锁的会话才能写入该表。
写锁 - 此锁允许限制未持有锁的会话对表执行读写操作。
语法
以下是 MySQL LOCK TABLES 语句的语法 -
LOCK TABLES table_name [READ | WRITE];
在 MySQL 中解锁表
客户端会话使用/访问 MySQL 表后，必须解锁该表才能供其他客户端会话使用。为此，您可以使用 MySQL UNLOCK TABLES 语句。这将释放该表，直到其他会话再次锁定它。
语法
以下是 MySQL UNLOCK TABLES 语句的语法 -
UNLOCK TABLES;
示例
首先创建一个名为 CUSTOMERS 的表，其中包含如下所示的详细信息 -
CREATE TABLE CUSTOMERS ( ID INT AUTO_INCREMENT, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, ADDRESS CHAR (25), SALARY DECIMAL (18, 2), PRIMARY KEY (ID) );
现在，让我们使用 INSERT 语句将 2 条记录插入到上面创建的表中 -
INSERT INTO CUSTOMERS (ID,NAME,AGE,ADDRESS,SALARY) VALUES (1, 'Ramesh', 32, 'Ahmedabad', 2000.00 ), (2, 'Khilan', 25, 'Delhi', 1500.00 );
使用以下查询创建另一个名为BUYERS的表 -
CREATE TABLE BUYERS ( B_ID INT AUTO_INCREMENT, B_NAME VARCHAR(20) NOT NULL, B_AGE INT NOT NULL, B_ADDRESS CHAR (25), B_SALARY DECIMAL (18, 2), PRIMARY KEY (B_ID) );
以下查询使用 INSERT INTO SELECT 语句将记录插入到 BUYERS 表中。此处，我们尝试将 CUSTOMERS 表中的记录插入到 BUYERS 表中。
锁定和解锁:
在传输之前，我们获取要插入记录的 BUYERS 表的写锁，并获取要插入记录的 CUSTOMERS 表的读锁。最后，在传输之后，我们释放记录。
LOCK TABLES CUSTOMERS READ, BUYERS WRITE;
INSERT INTO BUYERS (B_ID, B_NAME, B_AGE, B_ADDRESS, B_SALARY)
SELECT
ID, NAME, AGE, ADDRESS, SALARY
FROM
CUSTOMERS
WHERE
ID = 1 AND NAME = 'Ramesh';
INSERT INTO BUYERS (B_ID, B_NAME, B_AGE, B_ADDRESS, B_SALARY)
SELECT
ID, NAME, AGE, ADDRESS, SALARY
FROM
CUSTOMERS
WHERE
ID = 2 AND NAME = 'Khilan';
UNLOCK TABLES;
验证
我们可以使用以下查询来验证 BUYERS 表的内容 -
SELECT * FROM BUYERS;
正如我们在 BUYERS 表中看到的，记录已转移。
| B_ID | B_NAME | B_AGE | B_ADDRESS | B_SALARY |
|---|---|---|---|---|
| 1 | Ramesh | 32 | Ahmedabad | 2000.00 |
| 2 | Khilan | 25 | Delhi | 1500.00 |
使用客户端程序锁定表
除了使用 MySQL 查询锁定 MySQL 数据库中的表之外，我们还可以使用客户端程序执行 LOCK TABLES 操作。
语法
以下是使用各种编程语言锁定 MySQL 表的语法 -
要通过 PHP 程序锁定 MySQL 数据库中的表，我们需要使用 mysqli 函数 query() 执行 Lock Tables 语句，如下所示:-
$sql="LOCK TABLES table_name [READ | WRITE]"; $mysqli->query($sql);
要通过 Node.js 程序锁定 MySQL 数据库中的表，我们需要使用 mysql2 库中的 query() 函数执行 Lock 语句，如下所示:-
sql = "LOCK TABLES table_name [READ | WRITE]"; con.query(sql);
要通过 Java 程序锁定 MySQL 数据库中的表，我们需要使用 JDBC 函数 executeUpdate() 执行 Lock 语句，如下所示:-
String sql="LOCK TABLES table_name [READ | WRITE]"; statement.executeUpdate(sql);
要通过 Python 程序锁定 MySQL 数据库中的表，我们需要使用 MySQL Connector/Python 的 execute() 函数执行 Lock 语句，如下所示:-
sql="LOCK TABLES table_name [READ | WRITE]"; cursorObj.execute(sql);
示例
以下是程序示例:-
$dbhost = 'localhost';
$dbuser = 'root';
$dbpass = 'password';
$dbname = 'TUTORIALS';
$mysqli = new mysqli($dbhost, $dbuser, $dbpass, $dbname);
if ($mysqli->connect_errno) {
printf("Connect failed: %s
", $mysqli->connect_error);
exit();
}
// printf('Connected successfully.
');
// Here we are locking two table;
$sql = "LOCK TABLES tut_tbl READ, clone_table WRITE";
if ($mysqli->query($sql)) {
printf("Table locked successfully!.
");
}
if ($mysqli->errno) {
printf("Table could not be locked!.
", $mysqli->error);
}
$mysqli->close();
输出
获得的输出如下 -
Table locked successfully!.
var mysql = require('mysql2');
var con = mysql.createConnection({
host: "localhost",
user: "root",
password: "Nr5a0204@123"
});
//连接到 MySQL
con.connect(function (err) {
if (err) throw err;
console.log("Connected!");
console.log("--------------------------");
sql = "USE TUTORIALS"
con.query(sql);
sql = "CREATE TABLE SalesDetails (ID INT, ProductName VARCHAR(255), CustomerName VARCHAR(255), DispatchDate date, DeliveryTime time, Price INT, Location VARCHAR(255), CustomerAge INT, CustomrtPhone BIGINT, DispatchAddress VARCHAR(255), Email VARCHAR(50));"
con.query(sql);
sql = "insert into SalesDetails values(1, 'Key-Board', 'Raja', DATE('2019-09-01'), TIME('11:00:00'), 7000, 'Hyderabad', 25, '9000012345', 'Hyderabad - Madhapur', 'pujasharma@gmail.com');"
con.query(sql);
sql = "insert into SalesDetails values(2, 'Mobile', 'Vanaja', DATE('2019-03-01'), TIME('10:10:52'), 9000, 'Chennai', 30, '90000123654', 'Chennai- TNagar', 'vanajarani@gmail.com');"
con.query(sql);
sql = "CREATE TABLE CustContactDetails (ID INT,Name VARCHAR(255), Age INT,Phone BIGINT, Address VARCHAR(255), Email VARCHAR(50));"
con.query(sql);
sql = "LOCK TABLES SalesDetails READ, CustContactDetails WRITE;"
con.query(sql);
sql = "INSERT INTO CustContactDetails (ID, Name, Age, Phone, Address, Email) SELECT ID, CustomerName, CustomerAge, CustomrtPhone, DispatchAddress, Email FROM SalesDetails WHERE ID = 1 AND CustomerName = 'Raja';"
con.query(sql);
sql = "INSERT INTO CustContactDetails (ID, Name, Age, Phone, Address, Email) SELECT ID, CustomerName, CustomerAge, CustomrtPhone, DispatchAddress, Email FROM SalesDetails WHERE ID = 2 AND CustomerName = 'Vanaja';"
con.query(sql);
sql = "UNLOCK TABLES;"
con.query(sql);
sql = "SELECT * FROM CustContactDetails;"
con.query(sql, function(err, result){
if (err) throw err
console.log(result);
});
});
输出
生成的输出如下 -
Connected!
--------------------------
[
{
ID: 1,
Name: 'Raja',
Age: 25,
Phone: 9000012345,
Address: 'Hyderabad - Madhapur',
Email: 'pujasharma@gmail.com'
},
{
ID: 2,
Name: 'Vanaja',
Age: 30,
Phone: 90000123654,
Address: 'Chennai- TNagar',
Email: 'vanajarani@gmail.com'
}
]
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class TableLock {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/TUTORIALS";
String username = "root";
String password = "password";
try {
Class.forName("com.mysql.cj.jdbc.Driver");
Connection connection = DriverManager.getConnection(url, username, password);
Statement statement = connection.createStatement();
System.out.println("Connected successfully...!");
//Lock table....
String sql = "LOCK TABLES tutorials_tbl READ, clone_tbl WRITE";
statement.executeUpdate(sql);
System.out.println("Table Locked successfully...!");
connection.close();
} catch (Exception e) {
System.out.println(e);
}
}
}
输出
获得的输出如下所示 -
Connected successfully...! Table Locked successfully...!
import mysql.connector
#建立连接
connection = mysql.connector.connect(
host='localhost',
user='root',
password='password',
database='tut'
)
table_name = 'tutorials_tbl'
#创建游标对象
cursorObj = connection.cursor()
lock_table_query = f"LOCK TABLES {table_name} WRITE"
cursorObj.execute(lock_table_query)
print(f"Table '{table_name}' is locked successfully.")
cursorObj.close()
connection.close()
输出
以下是上述代码的输出 -
Table 'tutorials_tbl' is locked successfully.
