快速入門：使用 Node.js 連線和查詢適用於 MySQL 的 Azure 資料庫 - 彈性伺服器中的資料

發行項
12/27/2024

在本快速入門中，您會使用 Node.js 連線到適用於 MySQL 的 Azure 資料庫彈性伺服器。接著，您可以使用 SQL 陳述式來查詢、插入、更新和刪除 Mac、Linux 和 Windows 平台中的資料庫所含的資料。

本文假設您已熟悉使用 Node.js 進行開發，但不熟悉適用於 MySQL 的 Azure 資料庫彈性伺服器。

必要條件

本快速入門使用在以下任一指南中建立的資源作為起點︰

重要

請確定您從中連線的IP位址已使用管理適用於 MySQL 的 Azure 資料庫的防火牆規則來新增伺服器的防火牆規則 - 使用 Azure 入口網站或管理適用於 MySQL 的 Azure 資料庫的防火牆規則彈性伺服器 - 使用 Azure CLI 的彈性伺服器

安裝 Node.js 和 MySQL 連接器

根據您的平台，依照適當小節中的指示安裝 Node.js。使用 npm 將 mysql2 套件及其相依性安裝到您的專案資料夾中。

造訪 Node.js 下載頁面 \(英文\)，然後選取您需要的 Windows 安裝程式選項。
建立本機專案資料夾，例如 nodejsmysql。
開啟命令提示字元，然後將目錄變更為專案資料夾，例如 cd c:\nodejsmysql\

執行 NPM 工具將 mysql2 程式庫安裝至專案資料夾中。

cd c:\nodejsmysql\
"C:\Program Files\nodejs\npm" install mysql2
"C:\Program Files\nodejs\npm" list

檢查npm list 輸出文字，以確認安裝。版本號碼可能會隨著新修補程序發行而有所不同。

執行下列命令，以安裝 Node.js 和適用於 Node.js 的 npm 套件管理員。

 # Using Ubuntu
 sudo curl -sL https://deb.nodesource.com/setup_14.x | sudo -E bash -
 sudo apt-get install -y nodejs

 # Using Debian, as root
 sudo curl -sL https://deb.nodesource.com/setup_14.x | bash -
 sudo apt-get install -y nodejs

執行下列命令來建立專案資料夾 mysqlnodejs，然後將 mysql2 封裝安裝到該資料夾。
```
mkdir nodejsmysql
cd nodejsmysql
npm install --save mysql2
npm list
```
檢查 npm 清單輸出文字，以確認安裝。版本號碼可能會隨著新修補程序發行而有所不同。

執行下列命令，以安裝 Node.js 和適用於 Node.js 的 npm 套件管理員。

RHEL 7.x
```
sudo yum install -y rh-nodejs8
scl enable rh-nodejs8 bash
```
RHEL 8.x
```
 sudo yum install -y nodejs
```
執行下列命令來建立專案資料夾 mysqlnodejs，然後將 mysql2 封裝安裝到該資料夾。
```
mkdir nodejsmysql
cd nodejsmysql
npm install --save mysql2
npm list
```
檢查 npm 清單輸出文字，以確認安裝。版本號碼可能會隨著新修補程序發行而有所不同。

執行下列命令，以安裝 Node.js 和適用於 Node.js 的 npm 套件管理員。
```
 sudo zypper install nodejs
```
執行下列命令來建立專案資料夾 mysqlnodejs，然後將 mysql2 封裝安裝到該資料夾。
```
mkdir nodejsmysql
cd nodejsmysql
npm install --save mysql2
npm list
```
檢查 npm 清單輸出文字，以確認安裝。版本號碼可能會隨著新修補程序發行而有所不同。

瀏覽 Node.js 下載頁面，然後選取您的 macOS 安裝程式。
執行下列命令來建立專案資料夾 mysqlnodejs，然後將 mysql2 封裝安裝到該資料夾。
```
mkdir nodejsmysql
cd nodejsmysql
npm install --save mysql2
npm list
```
檢查npm list 輸出文字，以確認安裝。版本號碼可能會隨著新修補程序發行而有所不同。

取得連線資訊

取得連線到適用於 MySQL 的 Azure 資料庫彈性伺服器執行個體所需的連線資訊。您需要完整的伺服器名稱和登入認證。

登入 Azure 入口網站。
從 Azure 入口網站的左側功能表中，選取 [所有資源]，然後搜尋您所建立的伺服器 (例如 mydemoserver)。
選取伺服器名稱。
從伺服器的 [概觀] 面板，記下 [伺服器名稱] 和 [伺服器管理員登入名稱]。如果您忘記密碼，您也可以從此面板重設密碼。

執行程式碼範例

將 JavaScript 程式碼貼入新文字檔，然後使用副檔名 .js 將其儲存到專案資料夾 (例如 C:\nodejsmysql\createtable.js 或 /home/username/nodejsmysql/createtable.js)。
將程式代碼中的、 userpassword 和 database 組態選項取代host為您在建立 MySQL 彈性伺服器和資料庫時所指定的值。
取得 SSL 憑證：若要搭配用戶端應用程式使用加密連線，您必須下載公用 SSL 憑證，此憑證也可以在 Azure 入口網站的 [網路] 刀鋒視窗中取得，如下列螢幕擷取畫面所示。

儲存憑證檔案至慣用位置。

在 ssl 設定選項中，將 ca-cert 檔案名稱取代為這個本機檔案的路徑。這可讓應用程式透過 SSL 安全地連線到資料庫。
開啟命令提示字元或 Bash 殼層，然後將目錄變更為您的專案資料夾 cd nodejsmysql。
若要執行應用程式，請輸入後接檔案名稱的節點命令，例如 node createtable.js。
在 Windows 上，如果節點應用程式不在環境變數路徑中，您可能需要使用完整路徑來啟動節點應用程式，例如 "C:\Program Files\nodejs\node.exe" createtable.js

連線、建立資料表及插入資料

使用下列程式碼搭配 CREATE TABLE 和 INSERT INTO SQL 陳述式來連線和載入資料。

mysql.createConnection（）方法可用來與適用於 MySQL 的 Azure 資料庫彈性伺服器實例進行介面。 connect() 函式用來建立伺服器連線。 query() 函式用來對 MySQL 資料庫執行 SQL 查詢。

const mysql = require('mysql2');
const fs = require('fs');

var config =
{
    host: 'your_server_name.mysql.database.azure.com',
    user: 'your_admin_name',
    password: 'your_admin_password',
    database: 'quickstartdb',
    port: 3306,
    ssl: {ca: fs.readFileSync("your_path_to_ca_cert_file_DigiCertGlobalRootCA.crt.pem")}
};

const conn = new mysql.createConnection(config);

conn.connect(
    function (err) {
    if (err) {
        console.log("!!! Cannot connect !!! Error:");
        throw err;
    }
    else
    {
        console.log("Connection established.");
        queryDatabase();
    }
});

function queryDatabase()
{
    conn.query('DROP TABLE IF EXISTS inventory;',
        function (err, results, fields) {
            if (err) throw err;
            console.log('Dropped inventory table if existed.');
        }
    )
    conn.query('CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);',
        function (err, results, fields) {
            if (err) throw err;
            console.log('Created inventory table.');
        }
    )
    conn.query('INSERT INTO inventory (name, quantity) VALUES (?, ?);', ['banana', 150],
        function (err, results, fields) {
            if (err) throw err;
            else console.log('Inserted ' + results.affectedRows + ' row(s).');
        }
    )
    conn.query('INSERT INTO inventory (name, quantity) VALUES (?, ?);', ['orange', 250],
        function (err, results, fields) {
            if (err) throw err;
            console.log('Inserted ' + results.affectedRows + ' row(s).');
        }
    )
    conn.query('INSERT INTO inventory (name, quantity) VALUES (?, ?);', ['apple', 100],
        function (err, results, fields) {
            if (err) throw err;
            console.log('Inserted ' + results.affectedRows + ' row(s).');
        }
    )
    conn.end(function (err) {
        if (err) throw err;
        else  console.log('Done.')
    });
};

讀取資料

使用下列程式碼搭配 SELECT SQL 陳述式來連線和讀取資料。

mysql.createConnection（）方法可用來與適用於 MySQL 的 Azure 資料庫彈性伺服器實例進行介面。 connect() 方法用來建立伺服器連線。 query() 方法用來執行對 MySQL 資料庫的 SQL 查詢。結果陣列用來保留查詢的結果。

const mysql = require('mysql2');
const fs = require('fs');

var config =
{
    host: 'your_server_name.mysql.database.azure.com',
    user: 'your_admin_name',
    password: 'your_admin_password',
    database: 'quickstartdb',
    port: 3306,
    ssl: {ca: fs.readFileSync("your_path_to_ca_cert_file_DigiCertGlobalRootCA.crt.pem")}
};

const conn = new mysql.createConnection(config);

conn.connect(
    function (err) {
        if (err) {
            console.log("!!! Cannot connect !!! Error:");
            throw err;
        }
        else {
            console.log("Connection established.");
            readData();
        }
    });

function readData(){
    conn.query('SELECT * FROM inventory',
        function (err, results, fields) {
            if (err) throw err;
            else console.log('Selected ' + results.length + ' row(s).');
            for (i = 0; i < results.length; i++) {
                console.log('Row: ' + JSON.stringify(results[i]));
            }
            console.log('Done.');
        })
    conn.end(
        function (err) {
            if (err) throw err;
            else  console.log('Closing connection.')
    });
};

更新資料

使用下列程式碼搭配 UPDATE SQL 陳述式來連線和更新資料。

mysql.createConnection（）方法可用來與適用於 MySQL 的 Azure 資料庫彈性伺服器實例進行介面。 connect() 方法用來建立伺服器連線。 query() 方法用來執行對 MySQL 資料庫的 SQL 查詢。

const mysql = require('mysql2');
const fs = require('fs');

var config =
{
    host: 'your_server_name.mysql.database.azure.com',
    user: 'your_admin_name',
    password: 'your_admin_password',
    database: 'quickstartdb',
    port: 3306,
    ssl: {ca: fs.readFileSync("your_path_to_ca_cert_file_DigiCertGlobalRootCA.crt.pem")}
};

const conn = new mysql.createConnection(config);

conn.connect(
    function (err) {
        if (err) {
            console.log("!!! Cannot connect !!! Error:");
            throw err;
        }
        else {
            console.log("Connection established.");
            updateData();
        }
    });

function updateData(){
       conn.query('UPDATE inventory SET quantity = ? WHERE name = ?', [75, 'banana'],
            function (err, results, fields) {
                if (err) throw err;
                else console.log('Updated ' + results.affectedRows + ' row(s).');
           })
       conn.end(
           function (err) {
                if (err) throw err;
                else  console.log('Done.')
        });
};

刪除資料

使用 DELETE SQL 陳述式並搭配使用下列程式碼以連接和刪除資料。

const mysql = require('mysql2');
const fs = require('fs');

var config =
{
    host: 'your_server_name.mysql.database.azure.com',
    user: 'your_admin_name',
    password: 'your_admin_password',
    database: 'quickstartdb',
    port: 3306,
    ssl: {ca: fs.readFileSync("your_path_to_ca_cert_file_DigiCertGlobalRootCA.crt.pem")}
};

const conn = new mysql.createConnection(config);

conn.connect(
    function (err) {
        if (err) {
            console.log("!!! Cannot connect !!! Error:");
            throw err;
        }
        else {
            console.log("Connection established.");
            deleteData();
        }
    });

function deleteData(){
       conn.query('DELETE FROM inventory WHERE name = ?', ['orange'],
            function (err, results, fields) {
                if (err) throw err;
                else console.log('Deleted ' + results.affectedRows + ' row(s).');
           })
       conn.end(
           function (err) {
                if (err) throw err;
                else  console.log('Done.')
        });
};

清除資源

若要清除在此快速入門期間使用的所有資源，請使用下列命令刪除資源群組：

az group delete \
    --name $AZ_RESOURCE_GROUP \
    --yes

共用方式為

快速入門：使用 Node.js 連線和查詢適用於 MySQL 的 Azure 資料庫 - 彈性伺服器中的資料

必要條件

安裝 Node.js 和 MySQL 連接器

取得連線資訊

執行程式碼範例

連線、建立資料表及插入資料

讀取資料

更新資料

刪除資料

清除資源

意見反應

其他資源

共用方式為

快速入門：使用 Node.js 連線和查詢適用於 MySQL 的 Azure 資料庫 - 彈性伺服器中的資料

必要條件

安裝 Node.js 和 MySQL 連接器

取得連線資訊

執行程式碼範例

連線、建立資料表及插入資料

讀取資料

更新資料

刪除資料

清除資源

相關內容

意見反應

其他資源