1. ホーム
  2. スクリプト・コラム
  3. ルア

LuaプログラムでMySQLを使用するためのチュートリアル

2022-02-10 07:40:44

 MySQLのインポート

Luaで正しく実装され、完成していることを前提に、簡単な記述でSQLiteライブラリのインポートが可能です。インストール時、libsqlフォルダにデータベースに関連するファイルが格納されています。

コピーコード コードは以下の通りです。
mysql = require "luasql.mysql"

変数 MySQL は、主 MySQL テーブルを参照することで、この機能へのアクセスを提供します。
接続の作成

MySQLを起動するための環境を構築し、その環境への接続を作成することができます。これは以下に示すとおりです。

コピーコード コードは以下の通りです。
local env = mysql.mysql()
local conn = env:connect('test','root','123456')

上記の接続は、既存のMySQLファイルに接続し、新しく作成されたファイルへの接続を確立します。
関数を実行する

これで、create、insert、delete、updateなど、すべてのデータベース操作で、簡単な関数を実行できるようになります。構文は以下のとおりです。

コピーコード コードは以下の通りです。
conn:execute([[ 'MySQLSTATEMENT' ]])

上記の構文では、conn が既存の MySQL 接続を開いていることを確認し、 "MySQLSTATEMENT" を正しいステートメントに置き換える必要があります。
テーブルの作成例

テーブルを作成する簡単な例を以下に示します。int 型と varchar 型のテーブルを作成し、ID と name の 2 つのパラメータを指定します。

コピーコード コードは以下の通りです。
mysql = require "luasql.mysql"

local env = mysql.mysql()
local conn = env:connect('test','root','123456')
print(env,conn)

status,errorString = conn:execute([[CREATE TABLE sample2 (id INTEGER, name TEXT);]])
print(status,errorString )

上記のプログラムを実行すると、sampleというテーブルにはidとnameの2つのカラムが作成されます。

コピーコード コードは以下の通りです。
MySQL environment (004BB178) MySQL connection (004BE3C8)
0 nil

エラーが発生した場合は、nilのエラーステートメントが返される。以下に簡単なエラーステートメントを示す。

コピーコード コードは以下の通りです。
LuaSQL: Error executing query. MySQL: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '"id INTEGER, name TEXT)' at line 1

Insertステートメントの例

MySQLのINSERT文は以下の通りです。

コピーコード コードは以下の通りです。
conn:execute([[INSERT INTO sample values('11','Raj')]])

Update文の例

以下に示すMySQLのUPDATE文の場合。

コピーコード コードは以下の通りです。
conn:execute([[UPDATE sample3 SET name='John' where id ='12']])

Deleteステートメントの例

DELETE文-MySQLは以下の通りです。

コピーコード コードは以下の通りです。
conn:execute([[DELETE from sample3 where id ='12']])

Selectステートメントの例

select文の場合、各行を反復処理し、必要なデータを抽出する必要があります。以下に簡単なSELECT文を示します。

コピーコード コードは以下の通りです。
cursor,errorString = conn:execute([[select * from sample]])
row = cursor:fetch ({}, "a")
while row do
  print(string.format("Id: %s, Name: %s", row.id, row.name))
  -- reusing the table of results
  row = cursor:fetch (row, "a")
end

上記のコードで、conn は開いている MySQL 接続です。実行文によってカーソルが返され、テーブル・レスポンス・リターンによって目的の選択データを取得することができます。
完全な例

上記のすべての文の完全な例は、以下の参考文献に記載されています。

コピーコード コードは以下の通りです。
mysql = require "luasql.mysql"

local env = mysql.mysql()
local conn = env:connect('test','root','123456')
print(env,conn)

status,errorString = conn:execute([[CREATE TABLE sample3 (id INTEGER, name TEXT)]])
print(status,errorString )

status,errorString = conn:execute([[INSERT INTO sample3 values('12','Raj')]])
print(status,errorString )

cursor,errorString = conn:execute([[select * from sample3]])
print(cursor,errorString)

row = cursor:fetch ({}, "a")
while row do
  print(string.format("Id: %s, Name: %s", row.id, row.name))
  row = cursor:fetch (row, "a")
end
-- close everything
cursor:close()
conn:close()
env:close()

上記のプログラムを実行すると、次のような出力が得られます。

コピーコード コードは以下の通りです。
MySQL environment (0037B178) MySQL connection (0037EBA8)
0 nil
1 nil
MySQL cursor (003778A8) nil
Id: 12, Name: Raj

トランザクションの実行。

トランザクションは、データの一貫性を確保するための仕組みです。トランザクションは、以下の4つの特徴を持つことが望ましい。

  •     アトミック性。トランザクションは、すべて完了するか、まったく変更が発生しないかのどちらかです。
  •     一貫性。トランザクションは一貫性のある状態で開始され、システムを一貫性のある状態に保たなければならない。
  •     分離。トランザクションの中間結果は、現在のトランザクションの外からは見えません。
  •     永続性。トランザクションがコミットされると、その効果はシステム障害が発生した場合でも持続する。

トランザクションは START TRANSACTION で始まり、COMMIT または ROLLBACK 文で終了します。
トランザクションの開始

トランザクションを開始するには、Luaでexecute文を実行する必要があります。connはオープンなMySQL接続であると仮定します。

コピーコード コードは以下の通りです。
conn:execute([[START TRANSACTION;]])

ロールバックトランザクション

開始トランザクションの実行後に行われた変更をロールバックするために、次のステートメントを実行する必要があります。

コピーコード コードは以下の通りです。
conn:execute([[ROLLBACK;]])

トランザクションを送信する

開始トランザクションの実行以降に行われた変更をコミットするために、次のようなステートメントを実行する必要があります。

コピーコード コードは以下の通りです。
conn:execute([[COMMIT;]])

MySQLについては上記で既に知っているので、次のセクションでは基本的なSQLの操作について説明します。トランザクションは覚えておいてください。しかし、sqlite3ではもう説明しませんが、同じ文はsqlite3でも問題なく動作します。