MySQL - 内连接
- MySQL 内连接
- 使用内连接连接多个表
- 带 WHERE 子句的内连接
- 使用客户端程序执行内连接
MySQL 内连接
MySQL 内连接是一种连接类型，用于根据两个相关表中的公共列来组合记录。这些表基于特定条件连接在一起。如果两个表中的记录都满足指定的条件，则它们会被组合。
这是默认的连接类型；也就是说，即使使用 JOIN 关键字代替 INNER JOIN，表也会使用公共列的匹配记录进行连接。它们也被称为等值连接（Equijoin）。
语法
以下是 MySQL 内连接的基本语法 −
SELECT column_name(s) FROM table_name1 INNER JOIN table_name2 ON table_name1.column_name = table_name2.column_name
示例
创建一个名为 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) );
现在使用 INSERT 语句向该表插入数据，如下所示 −
INSERT INTO CUSTOMERS 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);
创建的表如下所示 −
| 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 表 −
让我们创建另一个名为 ORDERS 的表，其中包含订单详情和订单日期。
CREATE TABLE ORDERS ( OID INT NOT NULL, DATE VARCHAR (20) NOT NULL, CUSTOMER_ID INT NOT NULL, AMOUNT DECIMAL (18, 2) );
使用 INSERT 语句向该表插入数据，如下所示 −
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 |
内连接查询 −
现在让我们使用以下内连接查询组合这两个表 −
SELECT ID, NAME, AMOUNT, DATE FROM CUSTOMERS INNER JOIN ORDERS ON CUSTOMERS.ID = ORDERS.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 |
使用 Inner Join 连接多个表
使用 Inner Join 查询，我们也可以连接尽可能多的表。
然而，一次只能基于单个条件连接两个表。这个过程是顺序进行的，直到所有表都被组合在一起。
语法
以下是使用 Inner Join 连接两个以上表的语法 −
SELECT column_name1, column_name2... FROM table_name1 INNER JOIN table_name2 ON condition_1 INNER JOIN table_name3 ON condition_2 . . .
示例
在本示例中，让我们连接三个表，包括 CUSTOMERS 和 ORDERS 以及一个新表 EMPLOYEE。我们将首先使用下面的查询创建 EMPLOYEE 表 −
CREATE TABLE EMPLOYEE ( EID INT NOT NULL, EMPLOYEE_NAME VARCHAR (30) NOT NULL, SALES_MADE DECIMAL (20) );
现在，我们可以使用 INSERT 语句向这个空表插入值，如下所示 −
INSERT INTO EMPLOYEE VALUES (102, 'SARIKA', 4500), (100, 'ALEKHYA', 3623), (101, 'REVATHI', 1291), (103, 'VIVEK', 3426);
EMPLOYEE 表的详细信息如下所示。
| EID | EMPLOYEE_NAME | SALES_MADE |
|---|---|---|
| 102 | SARIKA | 4500 |
| 100 | ALEKHYA | 3623 |
| 101 | REVATHI | 1291 |
| 103 | VIVEK | 3426 |
使用下面的查询，我们正在组合三个表 CUSTOMERS、ORDERS 和 EMPLOYEE。
SELECT OID, DATE, AMOUNT, EMPLOYEE_NAME FROM CUSTOMERS INNER JOIN ORDERS ON CUSTOMERS.ID = ORDERS.CUSTOMER_ID INNER JOIN EMPLOYEE ON ORDERS.OID = EMPLOYEE.EID;
输出
输出结果如下所示 −
| OID | DATE | AMOUNT | EMPLOYEE_NAME |
|---|---|---|---|
| 102 | 2009-10-08 00:00:00 | 3000.00 | SARIKA |
| 100 | 2009-10-08 00:00:00 | 1500.00 | ALEKHYA |
| 101 | 2009-11-20 00:00:00 | 1560.00 | REVATHI |
| 103 | 2008-05-20 00:00:00 | 2060.00 | VIVEK |
带 WHERE 子句的 Inner Join
Inner Join 使用 WHERE 子句对从表中检索的记录应用约束。
语法
与 WHERE 子句一起使用 Inner Join 的语法如下所示 −
SELECT column_name(s) FROM table_name1 INNER JOIN table_name2 ON table_name1.column_name = table_name2.column_name WHERE condition
示例
考虑前面的两个表 CUSTOMERS 和 ORDERS；使用 inner join 查询连接它们，并使用 WHERE 子句应用一些约束。
SELECT ID, NAME, DATE, AMOUNT FROM CUSTOMERS INNER JOIN ORDERS ON CUSTOMERS.ID = ORDERS.CUSTOMER_ID WHERE ORDERS.AMOUNT > 2000.00;
输出
表显示如下 −
| ID | NAME | DATE | AMOUNT |
|---|---|---|---|
| 3 | Kaushik | 2009-10-08 00:00:00 | 3000.00 |
| 4 | Chaitali | 2008-05-20 00:00:00 | 2060.00 |
使用客户端程序执行 Inner Join
我们也可以通过执行 Inner Join 操作，使用客户端程序来连接两个或多个表。
语法
PHP
NodeJS
Java
Python
要通过 PHP 程序使用 Inner Join 操作连接具有公共字段的表，我们需要使用 mysqli 函数 query() 执行 JOIN 子句，如下所示 −
$sql = 'SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a INNER JOIN tcount_tbl b ON a.tutorial_author = b.tutorial_author'; $mysqli->query($sql);
要通过 JavaScript 程序使用 Inner Join 操作连接具有公共字段的表，我们需要使用 mysql2 库的 query() 函数执行 JOIN 子句，如下所示 −
sql = "SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a INNER JOIN tcount_tbl b ON a.tutorial_author = b.tutorial_author"; con.query(sql);
要通过 Java 程序使用 Inner Join 操作连接具有公共字段的表，我们需要使用 JDBC 函数 executeQuery() 执行 JOIN 子句，如下所示 −
String sql = "SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a INNER JOIN tcount_tbl b ON a.tutorial_author = b.tutorial_author"; st.executeQuery(sql);
要通过 Python 程序使用 Inner Join 操作连接具有公共字段的表，我们需要使用 MySQL Connector/Python 的 execute() 函数执行 JOIN 子句，如下所示 −
using_inner_join_query = "SELECT ID, NAME, AMOUNT, DATE FROM CUSTOMERS INNER JOIN ORDERS ON CUSTOMERS.ID = ORDERS.CUST_ID" cursorObj.execute(using_inner_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 INNER 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);
//inner join
sql = "SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a INNER 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 InnerJoin {
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 INNER JOIN...!;
String sql = "SELECT a.tutorial_id, a.tutorial_author, b.tutorial_count FROM tutorials_tbl a INNER JOIN tcount_tbl b ON a.tutorial_author = b.tutorial_author";
ResultSet resultSet = statement.executeQuery(sql);
System.out.println("Table records after INNER 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);
}
}
}
输出
得到的输出如下所示 −
Table records after INNER 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()
inner_join_query = f"""SELECT ID, NAME, AMOUNT, DATE FROM CUSTOMERS INNER JOIN ORDERS ON CUSTOMERS.ID = ORDERS.CUST_ID """
cursorObj.execute(inner_join_query)
# 获取满足条件的所有行
filtered_rows = cursorObj.fetchall()
for row in filtered_rows:
print(row)
cursorObj.close()
connection.close()
输出
上述代码的输出如下所示 −
(3, 'kaushik', 3000, '2009-10-08 00:00:00') (3, 'kaushik', 1500, '2009-10-08 00:00:00') (2, 'Khilan', 1560, '2009-11-20 00:00:00') (4, 'Chaital', 2060, '2008-05-20 00:00:00')