MySQL - 锁定表

更新于 2025/6/20 21:22:17

在 MySQL 中锁定表
在 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 NodeJS Java Python

要通过 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);

示例

以下是程序示例:-

PHP NodeJS Java Python

$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.

❮ MySQL 重命名列 MySQL Drop Table 删除表 ❯

MySQL 8 教程

MySQL 8 数据库

MySQL 8 用户

MySQL 8 表

MySQL 8 查询

MySQL 8 视图

MySQL 8 索引

MySQL 运算符和子句

MySQL 连接

MySQL 键

MySQL 触发器

MySQL 8 数据类型

MySQL 正则表达式

MySQL 全文搜索

MySQL8 函数和运算符

MySQL 8 其他概念

MySQL 8 实用资源

MySQL - 锁定表

MySQL 中的表锁定

语法

在 MySQL 中解锁表

语法

示例

验证

使用客户端程序锁定表

语法

示例

输出

输出

输出

输出

颜色选择器

读后有收获微信请站长喝咖啡

错误报告

您的建议:

感谢您的帮助！