MySQL - 锁定表-世界杯经典语录-申办世界杯_世界杯阵容

By admin

2025-08-27 02:58:50

世界杯经典语录

MySQL - 锁定表

❮ 上一节

下一节 ❯

MySQL - 锁定表

在 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

Ramesh

Ahmedabad

2000.00

Khilan

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 = "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.

❮ 上一节

下一节 ❯

申办世界杯_世界杯阵容 - tanglinghua.com

申办世界杯_世界杯阵容 - tanglinghua.com

MySQL - 锁定表