MySQL - 删除查询



MySQL DELETE 语句

如果要从任何 MySQL 表中删除记录,可以使用 SQL 命令 DELETE FROM。此语句是 SQL 中数据操纵语言的一部分,因为它与 MySQL 表中的数据交互,而不是结构。

DELETE 语句可用于删除单个表的多个行以及跨多个表的记录。但是,为了过滤要删除的记录,可以在 DELETE 语句中使用 WHERE 子句。

可以在 mysql> 提示符下以及在任何脚本(如 PHP、Node.js、Java 和 Python)中使用此命令。

语法

以下是用于从 MySQL 表中删除数据的 DELETE 命令的基本 SQL 语法:

DELETE FROM table_name [WHERE Clause]
  • 如果没有指定 WHERE 子句,则将从给定的 MySQL 表中删除所有记录。

  • 可以使用 WHERE 子句指定任何条件。

  • 一次只能删除一个表中的记录。

当要删除表中的选定行时,WHERE 子句非常有用。

从 MySQL 表中删除数据

我们使用 MySQL DELETE 查询从数据库表中删除记录。但是,我们可以一次删除单个记录、多个记录,甚至可以使用单个查询删除表中的所有记录。让我们在本教程中通过适当的示例逐一详细讨论它们。

示例

首先,让我们使用以下查询创建一个名为 CUSTOMERS 的表:

CREATE TABLE CUSTOMERS (
   ID INT NOT NULL,
   NAME VARCHAR(20) NOT NULL,
   AGE INT NOT NULL,
   ADDRESS CHAR (25),
   SALARY DECIMAL (18, 2),
   PRIMARY KEY (ID)
);

以下查询将 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 );

执行以下 SELECT 语句以检索 CUSTOMERS 表中存在的所有记录:

Select * From CUSTOMERS;

以下是 CUSTOMERS 表:

ID 名称 年龄 地址 薪资
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

现在,让我们使用 DELETE 语句删除 CUSTOMERS 表中的 单个记录 (ID = 1),如下所示:

DELETE FROM CUSTOMERS WHERE ID = 1;

输出

执行给定查询后,输出将显示如下:

Query OK, 1 row affected (0.00 sec)

验证

执行以下查询以验证上述记录是否已删除:

Select * From CUSTOMERS;

如输出所示,已删除 ID=1 的行:

ID 名称 年龄 地址 薪资
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

删除多行

我们还可以使用 DELETE 语句删除多行。为此,我们只需在 WHERE 子句中指定多个条件,这些条件为所有应删除的记录所满足。

示例

在这里,我们正在删除先前创建的 CUSTOMERS 表中 ID 为 2 和 3 的记录:

DELETE FROM CUSTOMERS WHERE ID = 2 OR ID = 3;

输出

上面程序的输出如下所示:

Query OK, 2 rows affected (0.01 sec)

验证

执行以下查询以验证上述记录是否已删除:

Select * From CUSTOMERS;

如输出所示,已删除 ID 值为 2 和 3 的行:

ID 名称 年龄 地址 薪资
4 Chaitali 25 Mumbai 6500.00
5 Hardik 27 Bhopal 8500.00
6 Komal 22 Hyderabad 4500.00
7 Muffy 24 Indore 10000.00

删除所有行

如果要删除 MySQL 表中的所有记录,只需执行 DELETE 语句而不使用 WHERE 子句。以下是语法:

DELETE FROM table_name;

示例

以下查询将删除 CUSTOMERS 表中的所有记录:

DELETE FROM CUSTOMERS;

输出

执行给定程序后,输出将显示如下:

Query OK, 4 rows affected (0.01 sec)

验证

执行以下查询以验证 CUSTOMERS 表中的所有记录是否已删除:

Select * From CUSTOMERS;

如我们看到的输出,已返回空集,即所有记录均已删除。

Empty set (0.00 sec)

使用客户端程序在 MySQL 中删除查询

除了使用 MySQL 查询删除数据库表中的记录外,还可以使用客户端程序执行 DELETE 操作。

语法

以下是各种编程语言中此操作的语法:

要通过 PHP 程序删除数据库表中的数据,需要使用 mysqli 函数 query() 执行 DELETE 语句,如下所示:

$sql="DELETE FROM table_name [WHERE Clause]";
$mysqli->query($sql);

要通过 Node.js 程序删除数据库表中的数据,需要使用 mysql2 库的 query() 函数执行 DELETE 语句,如下所示:

sql = "DELETE FROM table_name [WHERE Clause]";
VALUES (value1, value2, value3,...valueN)"
con.query(sql);

要通过 Java 程序删除数据库表中的数据,需要使用 JDBC 函数 executeUpdate() 执行 DELETE 语句,如下所示:

String sql="DELETE FROM table_name [WHERE Clause]";
statement.executeUpdate(sql);

要通过 Python 程序删除数据库表中的数据,需要使用 MySQL Connector/Pythonexecute() 函数执行 DELETE 语句,如下所示:

delete_query = "DELETE FROM table_name [WHERE Clause]"
cursorObj.execute(delete_query);

示例

以下是程序 -

$dbhost = 'localhost';
$dbuser = 'root';
$dbpass = 'root@123';
$dbname = 'TUTORIALS';
$mysqli = new mysqli($dbhost, $dbuser, $dbpass, $dbname);

if($mysqli->connect_errno ) {
   printf("Connect failed: %s<br />", $mysqli->connect_error);
   exit();
}
printf('Connected successfully.<br />');

if ($mysqli->query('DELETE FROM tutorials_tbl where tutorial_id = 4')) {
   printf("Table tutorials_tbl record deleted successfully.<br />");
}
if ($mysqli->errno) {
   printf("Could not delete record from table: %s<br />", $mysqli->error);
}
$sql = "SELECT tutorial_id, tutorial_title, tutorial_author, submission_date 
   FROM tutorials_tbl";

$result = $mysqli->query($sql);
  
if ($result->num_rows > 0) {
   while($row = $result->fetch_assoc()) {
      printf("Id: %s, Title: %s, Author: %s, Date: %d <br />", 
         $row["tutorial_id"], 
         $row["tutorial_title"], 
         $row["tutorial_author"],
         $row["submission_date"]);               
   }
} else {
   printf('No record found.<br />');
}
mysqli_free_result($result);
$mysqli->close();

输出

获得的输出如下 -

Connected successfully.
Table tutorials_tbl record deleted successfully.
Id: 1, Title: MySQL Tutorial, Author: Mahesh, Date: 2021
Id: 2, Title: HTML Tutorial, Author: Mahesh, Date: 2021
Id: 3, Title: PHP Tutorial, Author: Mahesh, Date: 2021
Id: 5, Title: Apache Tutorial, Author: Suresh, Date: 2021
var mysql = require('mysql2');
var con = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "Nr5a0204@123"
});

  //Connecting to MySQL
  con.connect(function (err) {
  if (err) throw err;
  console.log("Connected!");

  //Selecting a Database
  sql = "USE TUTORIALS"
  con.query(sql);

  //Updating a single record in the table
  sql = "DELETE FROM tutorials_tbl WHERE tutorial_id = 5;"
  con.query(sql);

  //Selecting records from table
  sql = "SELECT * FROM tutorials_tbl"
  con.query(sql, function (err, result) {
      if (err) throw err;
      console.log(result);
  });
});

输出

生成的输出如下 -

Connected!
[
  {
    tutorial_id: 1,
    tutorial_title: 'Learn PHP',
    tutorial_author: 'John Paul',
    submission_date: 2023-07-25T18:30:00.000Z
  },
  {
    tutorial_id: 2,
    tutorial_title: 'Learn MySQL',
    tutorial_author: 'Abdul S',
    submission_date: 2021-03-27T18:30:00.000Z
  },
  {
    tutorial_id: 3,
    tutorial_title: 'Learning Java',
    tutorial_author: 'Sanjay',
    submission_date: 2007-05-05T18:30:00.000Z
  },
  {
    tutorial_id: 4,
    tutorial_title: 'Python Tutorial',
    tutorial_author: 'Sasha Lee',
    submission_date: 2016-09-03T18:30:00.000Z
  }
]
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class DeleteQuery {
	public static void main(String[] args) {
		String url = "jdbc:mysql://127.0.0.1:3306/TUTORIALS";
		String user = "root";
		String password = "password";
		ResultSet rs;
		try {
			Class.forName("com.mysql.cj.jdbc.Driver");
            Connection con = DriverManager.getConnection(url, user, password);
            Statement st = con.createStatement();
            //System.out.println("Database connected successfully...!");
            String sql = "DELETE FROM tutorials_tbl WHERE tutorial_id = 6";
            st.executeUpdate(sql);
            System.out.println("Delete query executed successfully..!");
            String sql1 = "SELECT * FROM tutorials_tbl";
            rs = st.executeQuery(sql1);
            System.out.println("Table records: ");
            while(rs.next()) {
            	String tutorial_id = rs.getString("tutorial_id");
            	String tutorial_title = rs.getString("tutorial_title");
            	String tutorial_author = rs.getString("tutorial_author");
            	String submission_date = rs.getString("submission_date");
            	System.out.println("Id: " + tutorial_id + ", Title: " + tutorial_title + ", Author: " +  tutorial_author + ", Submission_date: " + submission_date);
            }
		}catch(Exception e) {
			e.printStackTrace();
		}
	}
}

输出

获得的输出如下所示 -

Delete query executed successfully..!
Table records: 
Id: 1, Title: Learn PHP, Author: John Paul, Submission_date: 2023-08-08
Id: 2, Title: Angular Java, Author: Abdul S, Submission_date: 2023-08-08
Id: 3, Title: Learning Java, Author: Sanjay, Submission_date: 2007-05-06
Id: 4, Title: Python Tutorial, Author: Sasha Lee, Submission_date: 2016-09-04
Id: 5, Title: Hadoop Tutorial, Author: Chris Welsh, Submission_date: 2023-08-08
import mysql.connector
import datetime
#establishing the connection
connection = mysql.connector.connect(
    host='localhost',
    user='root',
    password='password',
    database='tut'
)
#Creating a cursor object 
cursorObj = connection.cursor()
delete_query = "DELETE FROM tutorials_tbl WHERE tutorial_id = 6"
cursorObj.execute(delete_query)
connection.commit()
print("Row deleted successfully.")
cursorObj.close()
connection.close()

输出

以下是上述代码的输出 -

Row deleted successfully.
广告