MySQL - REPAIR 修复表
MySQL 修复表语句
数据库中的表可能会由于各种原因(例如硬件故障、软件错误或服务器意外崩溃)而损坏。发生这种情况时,由于数据不一致或错误,我们将无法访问或操作这些表中的数据。
在这种情况下,为了修复损坏的表,我们使用 MySQL REPAIR TABLE 语句。此语句仅适用于某些引擎,例如 MyISAM 等。
语法
以下是 MySQL REPAIR TABLE 语句的语法 -
REPAIR [NO_WRITE_TO_BINLOG | LOCAL] TABLE tbl_name [, tbl_name] ... [QUICK] [EXTENDED] [USE_FRM]
示例
首先,使用以下查询创建一个名为 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 语句将 7 条记录插入到上面创建的表中 -
INSERT INTO CUSTOMERS (ID,NAME,AGE,ADDRESS,SALARY) VALUES (1, 'Ramesh', 32, 'Ahmedabad', 2000.00 ), (2, 'Khilan', 25, 'Delhi', 1500.00 ), (3, 'Kaushik', 23, 'Kota', 2000.00 ), (4, 'Chaitali', 25, 'Mumbai', 6500.00 ), (5, 'Hardik', 27, 'Bhopal', 8500.00 ), (6, 'Komal', 22, 'Hyderabad', 4500.00 ), (7, 'Muffy', 24, 'Indore', 10000.00 );
假设上面创建的表已损坏,我们正在使用 REPAIR TABLE 语句来修复它。
REPAIR TABLE CUSTOMERS;
上述查询显示错误:"该表的存储引擎不支持修复",因为 REPAIR TABLE 语句不适用于默认的 InnoDB 引擎。
Table | Op | Msg_type | Msg_text |
---|---|---|---|
tutorials.customers | repair | note | The storage engine for the table doesn't support repair |
要修复该表,我们需要将表引擎更改为 MyISAM,因为它支持 REPAIR TABLE 语句。
ALTER TABLE CUSTOMERS ENGINE = MyISAM;
现在,要修复 CUSTOMERS 表,请执行以下查询 -
REPAIR TABLE CUSTOMERS;
输出
我们可以在下面的输出中看到 OK,这表明 CUSTOMERS 表状况良好,没有任何问题或损坏。
Table | Op | Msg_type | Msg_text |
---|---|---|---|
tutorials.customers | repair | status | OK |
修复多个表
在 MySQL 中,我们还可以使用 REPAIR TABLE 语句修复多个表并获取结果。为此,我们只需列出要修复的表的名称,并用逗号分隔即可。
示例
让我们使用以下 CREATE TABLE 语句创建三个不同的表,名称分别为 Test1、Test2 和 Test3 -
CREATE TABLE Test1(ID INT, Name VARCHAR(255)); CREATE TABLE Test2(ID INT, Name VARCHAR(255)); CREATE TABLE Test3(ID INT, Name VARCHAR(255));
假设上述三个表已损坏。请将这些表的引擎更改为 MyISAM,并使用 REPAIR TABLE 语句进行修复 -
ALTER TABLE Test1 ENGINE = MyISAM; ALTER TABLE Test2 ENGINE = MyISAM; ALTER TABLE Test3 ENGINE = MyISAM;
现在,要修复这些表,请执行以下查询 -
REPAIR TABLE Test1, Test2, Test3;
正如我们在下面的输出中看到的,这三个表都处于良好状态,没有任何问题或损坏。
Table | Op | Msg_type | Msg_text |
---|---|---|---|
tutorials.test1 | repair | status | OK |
tutorials.test2 | repair | status | OK |
tutorials.test3 | repair | status | OK |
修复表选项
我们有各种可选子句可与 REPAIR TABLE 一起使用,例如 QUICK、EXTENDED 和 USE_FRM 子句。我们将通过合适的示例逐一讨论它们。
QUICK 子句
QUICK 子句是默认子句,它最常用于 REPAIR TABLE。如果指定 QUICK 子句,MySQL 将修复表而不重新创建它。-
示例在下面的示例中,我们将 QUICK 子句与 REPAIR TABLE 语句一起使用来修复 CUSTOMERS 表。
REPAIR TABLE CUSTOMERS QUICK;输出
执行上述查询将产生以下输出 -
Table | Op | Msg_type | Msg_text |
---|---|---|---|
tutorials.customers | repair | status | OK |
EXTENDED 子句
如果我们指定 EXTENDED 子句,MySQL 不仅会修复表,还会重建索引并优化表结构。
注意: 与 QUICK 子句相比,EXTENDED 子句更耗时。
示例在下面的示例中,我们将 EXTENDED 子句与 REPAIR TABLE 语句结合使用来修复 CUSTOMERS 表。
REPAIR TABLE CUSTOMERS EXTENDED;输出
执行上述查询将产生以下输出 -
Table | Op | Msg_type | Msg_text |
---|---|---|---|
tutorials.customers | repair | status | OK |
USE_FRM 子句
如果 MYI 索引文件丢失,我们可以使用 USE_FRM 子句。如果您提供此子句,.NYI 文件将使用数据字典中的信息重新创建 -
示例在这里,我们将 USE_FRM 子句与 REPAIR TABLE 语句结合使用来修复 CUSTOMERS 表。
REPAIR TABLE CUSTOMERS USE_FRM;输出
执行上述查询将产生以下输出 -
Table | Op | Msg_type | Msg_text |
---|---|---|---|
tutorials.CUSTOMERS | repair | warning | Number of rows changed from 0 to 7 |
tutorials.customers | repair | status | OK |
使用客户端程序修复表
除了使用 MySQL 查询修复 MySQL 数据库中的表之外,我们还可以使用客户端程序执行"修复表"操作。
语法
以下是使用各种编程语言修复表的语法 -
要通过 PHP 程序修复 MySQL 数据库中的表,我们需要使用 mysqli 函数 query() 执行 Repair Table 语句,如下所示:-
$sql="Repair TABLE table_names"; $mysqli->query($sql);
要通过 Node.js 程序修复 MySQL 数据库中的表,我们需要使用 mysql2 库中的 query() 函数执行 Repair Table 语句,如下所示:-
sql=" REPAIR [NO_WRITE_TO_BINLOG | LOCAL] TABLE tbl_name [, tbl_name] ... [QUICK] [EXTENDED] [USE_FRM]"; con.query(sql);
要通过 Java 程序修复 MySQL 数据库中的表,我们需要使用 JDBC 函数 executeUpdate() 执行 Repair Table 语句,如下所示:-
String sql="Repair TABLE table_names"; statement.executeUpdate(sql);
要通过 Python 程序修复 MySQL 数据库中的表,我们需要使用 MySQL Connector/Python 的 execute() 函数执行 Repair Table 语句,如下所示:-
sql="REPAIR TABLE table_name"; 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.
'); $sql = " REPAIR TABLE SalesSummary "; if ($mysqli->query($sql)) { printf(" Table repair successfully.
"); } if ($mysqli->errno) { printf("table could not be repaired .
", $mysqli->error); } $mysqli->close();
输出
获得的输出如下 -
Table repair 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 = "Create Database TUTORIALS" con.query(sql); sql = "USE TUTORIALS" con.query(sql); sql = "CREATE TABLE sales(ID INT, ProductName VARCHAR(255), CustomerName VARCHAR(255), DispatchDate date, DeliveryTime time, Price INT, Location VARCHAR(255));" con.query(sql); sql = "insert into sales values(1, 'Key-Board', 'Raja', DATE('2019-09-01'), TIME('11:00:00'), 7000, 'Hyderabad'),(2, 'Earphones', 'Roja', DATE('2019-05-01'), TIME('11:00:00'), 2000, 'Vishakhapatnam'),(3, 'Mouse', 'Puja', DATE('2019-03-01'), TIME('10:59:59'), 3000, 'Vijayawada'),(4, 'Mobile', 'Vanaja', DATE('2019-03-01'), TIME('10:10:52'), 9000, 'Chennai'),(5, 'Headset', 'Jalaja', DATE('2019-04-06'), TIME('11:08:59'), 6000, 'Goa');" con.query(sql); sql = "ALTER TABLE Sales ENGINE = MyISAM;" con.query(sql); sql = "REPAIR TABLE Sales;" con.query(sql, function(err, result){ if (err) throw err console.log(result); }); });
输出
生成的输出如下 -
Connected! -------------------------- [ { Table: 'tutorials.sales', Op: 'repair', Msg_type: 'status', Msg_text: 'OK' } ]
import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; public class RepairTable{ 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...!"); //Repair tables...! String sql = "REPAIR TABLE customers"; statement.executeUpdate(sql); System.out.println("Table repaired successfully...!"); connection.close(); } catch(Exception e){ System.out.println(e); } } }
输出
获得的输出如下所示 -
Connected successfully...! Table repaired successfully...!
import mysql.connector #建立连接 connection = mysql.connector.connect( host='localhost', user='root', password='password', database='tut' ) table_name = 'tutorials_tbl_temp' #创建游标对象 cursorObj = connection.cursor() repair_table_query = f"REPAIR TABLE {table_name}" cursorObj.execute(repair_table_query) print(f"Table '{table_name}' is repaired successfully.") # 获取并使用游标中剩余的结果 # 确保在关闭游标之前没有未读的结果。 for _ in cursorObj: pass cursorObj.close() connection.close()
输出
以下是上述代码的输出 -
Table 'tutorials_tbl_temp' is repaired successfully.