MySQL - 使用連線

Table of content

連線型別
使用客戶端程式進行連線

上一個

下一個

MySQL 中的連線子句用於組合來自資料庫中兩個或多個表的記錄。這些表根據 WHERE 子句中指定的條件連線在一起。

例如，比較兩個不同表中相似列的值的相等性（=）可以被視為連線謂詞。此外，可以使用多個運算子來連線表，例如 <、>、<>、<=、>=、!=、BETWEEN、LIKE 和 NOT 等。

我們可以在 SELECT、UPDATE 和 DELETE 語句中使用連線來連線 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	姓名	年齡	地址	薪水
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	日期	CUSTOMER_ID	金額
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	姓名	日期	金額
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()執行連線操作，如下所示：

$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()函式執行連線操作，如下所示：

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()執行連線操作，如下所示：

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()函式執行連線操作，如下所示：

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",
}); //Connecting to 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://: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
#establishing the connection
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)
# Fetching all the rows that meet the criteria
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)

列印頁面

上一個

下一個