本文介绍如何使用Node.js的MySQL驱动包连接AnalyticDB for MySQL集群。

前提条件

  • 已下载并安装Node.js。下载地址请参见Node.js

  • 已安装MySQL驱动包。

注意事项

  • 如果已安装Node.js的服务器(例如云服务器ECS)与AnalyticDB for MySQL集群在同一VPC内,请使用内网连接地址;如果不在同一VPC内,请先为AnalyticDB for MySQL集群申请外网地址。具体操作,请参见申请和释放公网地址

  • 已将安装Node.js所在服务器的IP地址添加到AnalyticDB for MySQL集群的白名单中。具体操作,请参见设置白名单

连接AnalyticDB for MySQL集群

var mysql = require('mysql');
var connection = mysql.createConnection({
    //AnalyticDB MySQL集群的连接地址,可以在控制台的集群信息页面获取连接地址。
      host: 'am-bp***.ads.aliyuncs.com',
    //AnalyticDB MySQL集群的连接端口号。
      port: 3306,
    //AnalyticDB MySQL集群的用户账号:高权限账号或者普通账号。
      user: 'account_name',
    //AnalyticDB MySQL集群的用户账号的密码。
      password: 'account_password',
    //AnalyticDB MySQL集群的数据库名称。
      database: 'db_name',
    //建立连接的超时时间,默认10000毫秒。
      connectTimeout: 10000
});

connection.connect(function(err) {
    if (err) {
        throw err;
    }
    console.log("Connection established.");

    connection.query('SELECT count(*) AS count FROM information_schema.tables', function(err1, results, fields) {
        if (err1) {
            throw err1;
        }
        console.log('Count: ' + results[0].count);
    });

    connection.end(function(err2) {
        if (err2) {
            throw err2;
        }
        console.log("Connection closed.");
    });
});