MySQL - 交集运算符

Table of content
上一页
下一页

在数学集合论中，两个集合的交集是一个仅包含两个集合共有的元素的集合。换句话说，两个集合的交集是存在于两个集合中的元素的集合。

如果我们使用INTERSECT运算符对两个集合执行交集运算，它将显示两个表中的公共行。此运算符会从最终结果集中删除重复行。

MySQL INTERSECT 运算符

在 MySQL 中，INTERSECT 运算符用于返回两个 SELECT（表）语句的结果集中相同的/公共记录。

但是，只有当两个 SELECT 语句具有相同数据类型和名称的相同数量的列时，INTERSECT 运算符才有效。

语法

以下是 MySQL 中 INTERSECT 运算符的语法：

SELECT column1, column2,..., columnN
FROM table1, table2,..., tableN
INTERSECT
SELECT column1, column2,..., columnN
FROM table1, table2,..., tableN

示例

首先，让我们使用以下查询创建一个名为STUDENTS的表：

CREATE TABLE STUDENTS(
   ID INT NOT NULL,
   NAME VARCHAR(20) NOT NULL,
   HOBBY VARCHAR(20) NOT NULL,
   AGE INT NOT NULL,
   PRIMARY KEY(ID)
);

在这里，我们使用INSERT语句将一些值插入表中。

INSERT INTO STUDENTS VALUES
(1, 'Vijay', 'Cricket', 18),
(2, 'Varun', 'Football', 26),
(3, 'Surya', 'Cricket', 19),
(4, 'Karthik', 'Cricket', 25),
(5, 'Sunny', 'Football', 26),
(6, 'Dev', 'Cricket', 23);

表创建如下：

ID 姓名 爱好 年龄
1 Vijay 板球 18
2 Varun 足球 26
3 Surya 板球 19
4 Karthik 板球 25
5 Sunny 足球 26
6 Dev 板球 23

现在，让我们使用以下查询创建另一个名为ASSOCIATES的表：

CREATE TABLE ASSOCIATES(
   ID INT NOT NULL,
   NAME VARCHAR(20) NOT NULL,
   SUBJECT VARCHAR(20) NOT NULL,
   AGE INT NOT NULL,
   HOBBY VARCHAR(20) NOT NULL,
   PRIMARY KEY(ID)
);

在这里，我们使用INSERT语句将一些值插入表中：

INSERT INTO ASSOCIATES VALUES
(1, 'Naina', 'Maths', 24, 'Cricket'),
(2, 'Varun', 'Physics', 26, 'Football'),
(3, 'Dev', 'Maths', 23, 'Cricket'),
(4, 'Priya', 'Physics', 25, 'Cricket'),
(5, 'Aditya', 'Chemistry', 21, 'Cricket'),
(6, 'Kalyan', 'Maths', 30, 'Football');

表创建如下：

ID 姓名 科目 年龄 爱好
1 Naina 数学 24 板球
2 Varun 物理 26 足球
3 Dev 数学 23 板球
4 Priya 物理 25 板球
5 Aditya 化学 21 板球
6 Kalyan 数学 30 足球

现在，我们使用以下查询返回两个表中的公共记录：

SELECT NAME, AGE, HOBBY FROM STUDENTS
INTERSECT
SELECT NAME, AGE, HOBBY FROM ASSOCIATES;

输出

输出如下所示：

姓名 年龄 爱好
Varun 26 足球
Dev 23 板球

BETWEEN 运算符与 INTERSECT

MySQL INTERSECT 运算符可以与 BETWEEN 运算符一起使用，以查找存在于指定范围内的行。

示例

在以下查询中，我们检索两个表中都存在的记录。此外；我们正在检索年龄在 25 到 30 之间的记录：

SELECT NAME, AGE, HOBBY FROM STUDENTS
WHERE AGE BETWEEN 25 AND 30
INTERSECT
SELECT NAME, AGE, HOBBY FROM ASSOCIATES
WHERE AGE BETWEEN 20 AND 30;

输出

执行给定程序后，输出将显示如下：

姓名 年龄 爱好
Varun 26 足球

IN 运算符与 INTERSECT

在 MySQL 中，我们可以使用 INTERSECT 运算符与 IN 运算符一起使用，以查找具有指定值的公共行。IN 运算符用于根据指定值的列表过滤结果集。

示例

在以下查询中，我们尝试从两个表中返回公共记录。此外；我们使用 th IN 运算符来检索爱好为“板球”的记录。

SELECT NAME, AGE, HOBBY FROM STUDENTS
WHERE HOBBY IN('Cricket')
INTERSECT
SELECT NAME, AGE, HOBBY FROM ASSOCIATES
WHERE HOBBY IN('Cricket');

输出

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

姓名 年龄 爱好
Dev 23 板球

LIKE 运算符与 INTERSECT

LIKE 运算符用于对字符串值执行模式匹配。

我们可以将 LIKE 运算符与 MySQL 中的 INTERSECT 运算符一起使用，以查找与指定模式匹配的公共行。

示例

在以下查询中，我们使用通配符“%”与 LIKE 运算符一起从两个表的公共名称中获取包含“v”的名称。

SELECT NAME, AGE, HOBBY FROM STUDENTS
WHERE NAME LIKE 'v%'
INTERSECT
SELECT NAME, AGE, HOBBY FROM ASSOCIATES
WHERE NAME LIKE 'v%';

输出

让我们编译并运行程序，以产生以下结果：

姓名 年龄 爱好
Varun 26 足球

使用客户端程序的 Intersect 运算符

除了在 MySQL 服务器上执行 Intersect 运算符之外，我们还可以使用客户端程序在表上执行 Intersect 运算符。

语法

以下是各种编程语言中 MySQL 表中 Intersect 运算符的语法：

PHP NodeJS Java Python

要在 PHP 程序中通过 MySQL 表执行 Intersect 操作符，需要使用 **mysqli** 连接器的 **query()** 函数执行 **INTERSECT** 语句。

$sql = "SELECT column1, column2,..., columnN FROM table1, table2,..., 
tableN INTERSECT SELECT column1, column2,..., columnN 
FROM table1, table2,..., tableN";  
$mysqli->query($sql);

要在 JavaScript 程序中通过 MySQL 表执行 Intersect 操作符，需要使用 **mysql2** 连接器的 **query()** 函数执行 **INTERSECT** 语句。

sql = "SELECT column1, column2,..., columnN FROM table1, table2,..., tableN
INTERSECT SELECT column1, column2,..., columnN 
FROM table1, table2,..., tableN";
con.query(sql);

要在 Java 程序中通过 MySQL 表执行 Intersect 操作符，需要使用 **JDBC 4 类型** 驱动程序的 **executeQuery()** 函数执行 **INTERSECT** 语句。

String sql = "SELECT column1, column2,..., columnN FROM table1, table2,..., tableN 
INTERSECT SELECT column1, column2,..., columnN 
FROM table1, table2,..., tableN";
statement.executeQuery(sql);

要在 Python 程序中通过 MySQL 表执行 Intersect 操作符，需要使用 **MySQL Connector/Python** 提供的 **execute()** 函数执行 **INTERSECT** 语句。

intersect_query = SELECT column1, column2,..., column
FROM table1, table2,..., tableN
INTERSECT SELECT column1, column2,..., column
FROM table1, table2,..., tableN
cursorObj.execute(intersect_query);

示例

以下是此操作在各种编程语言中的实现：

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.
');
$sql = "SELECT NAME, AGE, HOBBY FROM STUDENTS INTERSECT SELECT NAME, AGE, HOBBY FROM ASSOCIATES;";
$result = $mysqli->query($sql);
if ($result->num_rows > 0) {
   printf("Table records: \n");
   while($row = $result->fetch_assoc()) {
      printf("NAME %s, AGE %d, HOBBY %s",
      $row["NAME"],
      $row["AGE"],
      $row["HOBBY"],);
      printf("\n");         
   }
} else {
   printf('No record found.
');
}
mysqli_free_result($result);
$mysqli->close();

输出

获得的输出如下：

Table records:
NAME Varun, AGE 26, HOBBY Football
NAME Dev, AGE 23, HOBBY Cricket       

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!");
  console.log("--------------------------");

  //Creating a Database
  sql = "create database TUTORIALS"
  con.query(sql);

  //Select database
  sql = "USE TUTORIALS"
  con.query(sql);

  //Creating STUDENTS table
  sql = "CREATE TABLE STUDENTS(ID INT NOT NULL,NAME VARCHAR(20) NOT NULL,HOBBY VARCHAR(20) NOT NULL,AGE INT NOT NULL,PRIMARY KEY(ID));"
  con.query(sql);

  //Inserting Records
  sql = "INSERT INTO STUDENTS(ID, NAME, HOBBY, AGE) VALUES(1, 'Vijay', 'Cricket',18),(2, 'Varun','Football', 26),(3, 'Surya', 'Cricket',19),(4, 'Karthik','Cricket', 25),(5, 'Sunny','Football', 26),(6, 'Dev', 'Cricket',23);"
  con.query(sql);

  //Creating ASSOCIATES table
  sql = "CREATE TABLE ASSOCIATES(ID INT NOT NULL,NAME VARCHAR(20) NOT NULL,SUBJECT VARCHAR(20) NOT NULL,AGE INT NOT NULL,HOBBY VARCHAR(20) NOT NULL,PRIMARY KEY(ID));"
  con.query(sql);
  
  //Inserting Records
  sql = "INSERT INTO ASSOCIATES(ID, NAME, SUBJECT, AGE, HOBBY) VALUES(1, 'Naina','Maths', 24, 'Cricket'),(2, 'Varun','Physics', 26, 'Football'),(3, 'Dev','Maths', 23, 'Cricket'),(4, 'Priya','Physics', 25, 'Cricket'),(5,'Aditya', 'Chemistry', 21, 'Cricket'),(6,'Kalyan', 'Maths', 30, 'Football');"
  con.query(sql);

  //Using INTERSECT Operator
  sql = "SELECT NAME, AGE, HOBBY FROM STUDENTS INTERSECT SELECT NAME, AGE, HOBBY FROM ASSOCIATES;"
  con.query(sql, function(err, result){
    if (err) throw err
    console.log(result)
  });
});

输出

产生的输出如下：

Connected!
--------------------------
[
  { NAME: 'Varun', AGE: 26, HOBBY: 'Football' },
  { NAME: 'Dev', AGE: 23, HOBBY: 'Cricket' }
]  

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class IntersectOperator {
  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 = "SELECT NAME, AGE, HOBBY FROM STUDENTS INTERSECT SELECT NAME, AGE, HOBBY FROM ASSOCIATES";
            rs = st.executeQuery(sql);
            System.out.println("Table records: ");
            while(rs.next()) {
              String name = rs.getString("NAME");
              String age = rs.getString("AGE");
              String hobby = rs.getString("HOBBY");
              System.out.println("Name: " + name + ", Age: " + age + ", Hobby: " + hobby);
            }
    }catch(Exception e) {
      e.printStackTrace();
    }
  }
}

输出

获得的输出如下所示：

Table records: 
Name: Varun, Age: 26, Hobby: Football
Name: Dev, Age: 23, Hobby: Cricket  

import mysql.connector
#establishing the connection
connection = mysql.connector.connect(
    host='localhost',
    user='root',
    password='password',
    database='tut'
)
cursorObj = connection.cursor()
intersect_query = f"""
SELECT NAME, AGE, HOBBY FROM STUDENTS
INTERSECT
SELECT NAME, AGE, HOBBY FROM ASSOCIATES;
"""
cursorObj.execute(intersect_query)
# Fetching all the rows that meet the criteria
filtered_rows = cursorObj.fetchall()
for row in filtered_rows:
    print(row)
cursorObj.close()
connection.close()

输出

以下是上述代码的输出：

('Varun', 26, 'Football')
('Dev', 23, 'Cricket')
打印页面
上一页
下一页
广告