Sequel で OceanBase データベースに接続するサンプルプログラム

本記事では、SequelとOceanBaseデータベースを使用してアプリケーションを構築し、テーブルの作成、データの挿入、クエリなどの基本的な操作を実現する方法について説明します。

前提条件

• RubyとRubyGemsがインストール済みであること。
• OceanBaseデータベースがインストール済みで、MySQLモードのテナントが作成されていること。

手順

1. RubyとRubyGemsのバージョンを確認する
2. 必要なgemをインストールする
3. OceanBaseデータベース接続情報を取得する
4. サンプルプログラムを作成する
5. サンプルプログラムを実行する

ステップ１：RubyとRubyGemsのバージョンを確認する

ターミナルを開き、以下のコマンドを実行してRubyとRubyGemsのバージョンを確認します：

ruby -v
gem -v

ステップ２：必要なgemをインストールする

gem を使用してSequelとmysql2をインストールします：

gem install sequel mysql2

ステップ３：OceanBaseデータベース接続情報を取得する

OceanBaseデータベースのデプロイ担当者または管理者から、該当するデータベース接続文字列を取得します。

mysql -h$host -P$port -u$user_name -p$password -D$database_name

パラメータ説明：

• $host：OceanBaseデータベースの接続IPアドレスを指定します。
• $port：OceanBaseデータベースの接続ポートを指定します。
• $database_name：アクセスするデータベース名を指定します。
• $user_name：テナントの接続アカウントを指定します。
• $password：アカウントのパスワードを指定します。

ステップ4：サンプルプログラムを作成する

1. 設定ファイル config.rb を作成します：

   PASSWORD = ENV['OB_PASSWORD'] || 'your_password'
   
   CLIENT_CONFIG = {
     adapter: 'mysql2',
     host: 'your_host',
     port: your_port,
     username: 'your_username',
     password: PASSWORD,
     all_databases: true
   }
   

2. サンプルプログラム main.rb を作成します：

   require 'sequel'
   require 'sequel/adapters/mysql2'
   require File.expand_path('config.rb', __dir__)
   
   # 接続の作成
   db = Sequel.connect(CLIENT_CONFIG)
   
   # データベースの作成
   db_name = "ruby_test_db"
   db.run("CREATE DATABASE IF NOT EXISTS #{db_name}")
   
   db.disconnect
   
   # 新しいデータベースへの再接続
   CLIENT_CONFIG[:database] = db_name
   db = Sequel.connect(CLIENT_CONFIG)
   puts "Database '#{db_name}' selected"
   
   # テーブルの作成
   db.run("DROP TABLE IF EXISTS users")
   db.run("CREATE TABLE users (
     id INT AUTO_INCREMENT PRIMARY KEY,
     name VARCHAR(255) NOT NULL,
     created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
   )")
   
   # サンプルデータの挿入
   sample_names = ["Alice", "Bob", "Charlie", "David"]
   sample_names.each do |name|
     db.run("INSERT INTO users (name) VALUES ('#{name}')")
   end
   
   puts "テーブルの作成とサンプルデータの挿入に成功しました"
   puts "サンプルレコードを #{sample_names.size}件挿入しました"
   
   # すべてのデータをクエリして表示する
   results = db[:users]
   puts "\nUsers:"
   results.each do |row|
     puts "ID: #{row[:id]}, Name: #{row[:name]}, Created at: #{row[:created_at]}"
   end
   
   # 接続を閉じる
   db.disconnect
   

ステップ5：サンプルプログラムを実行する

1. プログラムの実行：

   ruby main.rb
   

   期待される実行結果：

   Database 'ruby_test_db' selected
   Table created and sample data inserted successfully
   Inserted 4 sample records
   
   Users:
   ID: 1, Name: Alice, Created at: 2025-05-21 15:20:06 +0800
   ID: 2, Name: Bob, Created at: 2025-05-21 15:20:06 +0800
   ID: 3, Name: Charlie, Created at: 2025-05-21 15:20:06 +0800
   ID: 4, Name: David, Created at: 2025-05-21 15:20:06 +0800
   

よくある質問

1. 接続エラー：データベースに接続できない場合は、次のことを確認してください：

   • データベースのアドレスとポートが正しいかどうか
   • ユーザー名とパスワードが正しいかどうか
   • ネットワークが正常に接続されているかどうか

2. 権限エラー：権限に関連するエラーが発生した場合は、ユーザーが必要な操作を実行するために十分な権限を持っていることを確認してください。

3. SQL構文エラー：SQLステートメントに構文エラーがある場合は、SQLステートメントの構文が正しいかどうか確認してください。

パフォーマンス最適化の推奨事項

1. Sequelのバッチ処理操作を使用する
2. 接続プールを使用してデータベース接続を管理する
3. プリコンパイル済みクエリを使用する
4. キャッシュを適切に利用する
5. データベースのインデックスを最適化する