ApsaraDB RDS:アプリケーションから ApsaraDB RDS for MySQL データベースにアクセスする

ドライバーのインストール

Maven プロジェクトの pom.xml ファイルに、次の依存関係を追加します。

<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>8.0.27</version>
</dependency>

サンプルコード

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

public class DatabaseConnection {
    public static void main(String args[]) {
        // プレースホルダーを実際の接続情報を置き換えてください
        String connectionUrl = "jdbc:mysql://<Host>:<Port>/<myDatabase>";

        ResultSet resultSet;

        try (Connection connection = DriverManager.getConnection(connectionUrl, "<myUsername>", "<myPassword>");
             Statement statement = connection.createStatement()) {

            String selectSql = "SELECT * FROM `courses`";
            resultSet = statement.executeQuery(selectSql);

            while (resultSet.next()) {
                System.out.println(resultSet.getString("name"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

期待される出力

接続が成功し、courses テーブルにデータが存在する場合、各行の name 列の値がコンソールに出力されます。

クラウドコンピューティング入門
データベースの基礎
高度な Java プログラミング

代わりに SQLException のスタックトレースが表示された場合は、「トラブルシューティング」をご参照ください。

PyMySQL のインストール

お使いの Python バージョンに応じて、適切なコマンドを実行します。

• Python 3： pip3 install PyMySQL

• Python 2： pip install pymysql==0.9.3

サンプルコード

import pymysql

connection = pymysql.connect(
    host='<Host>',
    port=<Port>,
    user='<myUsername>',
    passwd='<myPassword>',
    db='<myDatabase>'
)

try:
    with connection.cursor() as cursor:
        sql = "SELECT * FROM `courses`"
        cursor.execute(sql)
        for result in cursor:
            print(result)
except pymysql.err.OperationalError as e:
    if e.args[0] == 1045:
        print("アクセス拒否：ユーザー名およびパスワードを確認してください。")
    elif e.args[0] == 1049:
        print("不明なデータベース：データベース名を確認してください。")
    else:
        print(f"接続エラー：{e}")
finally:
    connection.close()

期待される出力

接続が成功し、courses テーブルにデータが存在する場合、各行がタプルとして出力されます。

('クラウドコンピューティング入門',)
('データベースの基礎',)
('高度な Java プログラミング',)

MySQL C ライブラリのインストール

CentOS 上で、以下のコマンドを実行します。

sudo yum install mysql-devel

サンプルコード

#include <stdio.h>
#include <mysql.h>
#include <string.h>

int main(void)
{
    MYSQL *t_mysql;
    MYSQL_RES *res = NULL;
    MYSQL_ROW row;
    int rc, i, fields;
    int rows;

    char select[] = "select * from courses";

    t_mysql = mysql_init(NULL);
    if (NULL == t_mysql) {
        printf("初期化失敗\n");
        return 1;
    }

    /* プレースホルダーを実際の接続情報に置き換えてください */
    if (NULL == mysql_real_connect(t_mysql, "<Host>", "<myUsername>", "<myPassword>",
            "<myDatabase>", <Port>, NULL, 0)) {
        printf("接続失敗： %s\n", mysql_error(t_mysql));
        return 1;
    }

    if (mysql_real_query(t_mysql, select, strlen(select)) != 0) {
        printf("SELECT 失敗： %s\n", mysql_error(t_mysql));
        mysql_close(t_mysql);
        return 1;
    }

    res = mysql_store_result(t_mysql);
    if (NULL == res) {
        printf("mysql_store_result()： %s\n", mysql_error(t_mysql));
        mysql_close(t_mysql);
        return 0;
    }

    fields = mysql_num_fields(res);
    while ((row = mysql_fetch_row(res))) {
        for (i = 0; i < fields; i++) {
            printf("%s\t", row[i]);
        }
        printf("\n");
    }

    mysql_free_result(res);
    mysql_close(t_mysql);
    return 0;
}

期待される出力

接続が成功した場合、courses テーブルの各行が、タブ区切りの列で出力されます。

クラウドコンピューティング入門
データベースの基礎
高度な Java プログラミング