MySQL - 使用连接

连接类型
使用客户端程序进行连接

MySQL 中的 Join 子句用于合并数据库中两个或多个表中的记录。这些表根据 WHERE 子句中指定的条件连接在一起。

例如，比较两个不同表中相似列的值是否相等 (=) 可以被视为连接谓词。此外，可以使用多个运算符来连接表，例如 <、>、<>、<=、>=、!=、BETWEEN、LIKE 和 NOT 等。

我们可以在 SELECT、UPDATE 和 DELETE 语句中使用 JOINS 来连接 MySQL 表。

连接类型

SQL 提供了多种类型的连接，这些连接根据跨表数据连接的方式进行分类。具体如下:

内连接 - 内连接检索两个表的交集。它将第一个表的每一行与第二个表的每一行进行比较。如果这些行对满足连接谓词，则将它们连接在一起。这是一个默认连接。
外连接 − 外连接会检索两个表中的所有记录，即使其中一个表在另一个表中没有对应的行，类似于内连接。外连接进一步分为三种子类型:左连接、右连接和全连接。我们将在本教程的后面部分学习这些连接。

示例

在此示例中，我们首先使用 CREATE TABLE 查询创建一个名为 CUSTOMERS 的表，如下所示 −

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

然后让我们在 CUSTOMERS 表中插入以下记录 -

INSERT INTO CUSTOMERS VALUES 
(1, 'Ramesh', '32', 'Ahmedabad', 2000),
(2, 'Khilan', '25', 'Delhi', 1500),
(3, 'Kaushik', '23', 'Kota', 2500),
(4, 'Chaitali', '26', 'Mumbai', 6500),
(5, 'Hardik','27', 'Bhopal', 8500),
(6, 'Komal', '22', 'Hyderabad', 9000),
(7, 'Muffy', '24', 'Indore', 5500);

该表创建为 −

ID	NAME	AGE	ADDRESS	SALARY
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

ORDERS 表 −

我们使用以下 CREATE TABLE 查询创建另一个名为 ORDERS 的表，其中包含客户订单的详细信息 −

CREATE TABLE ORDERS (
   OID INT NOT NULL,
   DATE VARCHAR (20) NOT NULL,
   CUSTOMER_ID INT NOT NULL,
   AMOUNT DECIMAL (18, 2)
);

使用 INSERT 语句，将值插入 ORDERS 表，如下所示 -

INSERT INTO ORDERS VALUES
(102, '2009-10-08 00:00:00', 3, 3000.00),
(100, '2009-10-08 00:00:00', 3, 1500.00),
(101, '2009-11-20 00:00:00', 2, 1560.00),
(103, '2008-05-20 00:00:00', 4, 2060.00);

表格显示如下 −

OID	DATE	CUSTOMER_ID	AMOUNT
102	2009-10-08 00:00:00	3	3000.00
100	2009-10-08 00:00:00	3	1500.00
101	2009-11-20 00:00:00	2	1560.00
103	2008-05-20 00:00:00	4	2060.00

连接表 −

现在我们编写一个 SQL 查询来连接这两个表。此查询将从表 CUSTOMERS 中查询所有客户，并从 ORDERS 中提取相应数量的订单。

SELECT a.ID, a.NAME, b.DATE, b.AMOUNT
FROM CUSTOMERS a, ORDERS b
WHERE a.ID = b.CUSTOMER_ID;

输出

表格显示如下 −

ID	NAME	DATE	AMOUNT
3	Kaushik	2009-10-08 00:00:00	3000.00
3	Kaushik	2009-10-08 00:00:00	1500.00
2	Khilan	2009-11-20 00:00:00	1560.00
4	Chaitali	2008-05-20 00:00:00	2060.00

使用客户端程序连接

除了使用 MySQL 查询连接两个或两个以上的表之外，我们还可以使用客户端程序执行连接操作。

语法

PHP NodeJS Java Python

要通过 PHP 程序连接两个或两个以上的 MySQL 表，我们需要使用 mysqli 函数 query() 执行 JOIN 操作，如下所示 -

$sql = 'SELECT a.ID, a.NAME, b.DATE, b.AMOUNT FROM CUSTOMERS a, ORDERS b WHERE a.ID = b.CUSTOMER_ID';
$mysqli->query($sql);

要通过 JavaScript 程序连接两个或两个以上的 MySQL 表，我们需要使用 mysql2 库的 query() 函数执行 JOIN 操作，如下所示 -

sql = 'SELECT a.ID, a.NAME, b.DATE, b.AMOUNT FROM CUSTOMERS a, ORDERS b WHERE a.ID = b.CUSTOMER_ID';
con.query(sql);

要通过 Java 程序连接两个或两个以上的 MySQL 表，我们需要使用 JDBC 函数 executeQuery() 执行 JOIN 操作，如下所示 -

String sql = 'SELECT a.ID, a.NAME, b.DATE, b.AMOUNT FROM CUSTOMERS a, ORDERS b WHERE a.ID = b.CUSTOMER_ID';
st.executeQuery(sql);

要通过 Python 程序连接两个或两个以上的 MySQL 表，我们需要使用 MySQL Connector/Python 的 execute() 函数执行 JOIN 操作，如下所示 -

using_join_query = 'SELECT a.ID, a.NAME, b.DATE, b.AMOUNT FROM CUSTOMERS a, ORDERS b WHERE a.ID = b.CUSTOMER_ID'
cursorObj.execute(using_join_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 a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a JOIN tcount_tbl b 
ON a.tutorial_author = b.tutorial_author';
$result = $mysqli->query($sql);
if ($result->num_rows > 0) {
    while ($row = $result->fetch_assoc()) {
        printf(
            "Id: %s, Author: %s, Count: %d 
",
            $row["tutorial_id"],
            $row["tutorial_author"],
            $row["tutorial_count"]
        );
    }
} else {
    printf('No record found.
');
}
mysqli_free_result($result);
$mysqli->close();

输出

获得的输出如下 -

Id: 3, Author: Sanjay, Count: 1

var mysql = require("mysql2");
var con = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "password",
}); //连接到 MySQL

con.connect(function (err) {
  if (err) throw err;
//   console.log("Connected successfully...!");
//   console.log("--------------------------");
  sql = "USE TUTORIALS";
  con.query(sql);
  sql = "SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a JOIN tcount_tbl b ON a.tutorial_author = b.tutorial_author";
  con.query(sql, function (err, result) {
    if (err) throw err;
    console.log(result);
  });
});

输出

生成的输出如下 -

[ { tutorial_id: 1, tutorial_author: 'John Poul', tutorial_count: 2 } ]

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class Join {
   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...!");
        //Mysql JOIN...!;
         String sql = "SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a JOIN tcount_tbl b ON a.tutorial_author = b.tutorial_author";
         ResultSet resultSet = statement.executeQuery(sql);
         System.out.println("Table records after join...!");
         while (resultSet.next()){
            System.out.println(resultSet.getString(1)+ " "+ resultSet.getString(2)+" "+resultSet.getString(3));
         }
         connection.close();
      } catch (Exception e) {
         System.out.println(e);
      }
   }
}

输出

获得的输出如下所示 -

Connected successfully...!
Table records after join...!
1 John Paul 1
3 Sanjay 1

import mysql.connector
#建立连接
connection = mysql.connector.connect(
    host='localhost',
    user='root',
    password='password',
    database='tut'
)
cursorObj = connection.cursor()
using_join_query = f"""SELECT ID, NAME, AGE, AMOUNT FROM CUSTOMERS JOIN ORDERS ON CUSTOMERS.ID = ORDERS.CUST_ID"""
cursorObj.execute(using_join_query)
# 获取所有符合条件的行
filtered_rows = cursorObj.fetchall()
for row in filtered_rows:
    print(row)
cursorObj.close()
connection.close()

输出

以下是上述代码的输出 -

(3, 'Kaushik', 23, 3000)
(3, 'Kaushik', 23, 1500)
(2, 'Khilan', 25, 1560)
(4, 'Chaital', 25, 2060)

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 - 使用连接

连接类型

示例

输出

使用客户端程序连接

语法

示例

输出

输出

输出

输出

颜色选择器

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

错误报告

您的建议:

感谢您的帮助！