Lua-database-access

提供:Dev Guides
移動先:案内検索

Lua-データベースアクセス

単純なデータ操作の場合、ファイルを使用できますが、これらのファイル操作は効率的で、スケーラブルで、強力ではない場合があります。 この目的のために、データベースの使用に切り替えることがよくあります。 LuaSQLは、Luaから多数のデータベース管理システムへのシンプルなインターフェイスです。 LuaSQLは、さまざまなタイプのSQLのサポートを提供するライブラリです。 これには、

  • SQLite
  • MySQL
  • ODBC

このチュートリアルでは、LuaでのMySQLとSQLiteのデータベース処理について説明します。 これは両方に汎用インターフェースを使用し、この実装を他のタイプのデータベースにも移植できるはずです。 まず、MySQLで操作を実行する方法を見てみましょう。

MySQLデータベースのセットアップ

次の例を使用して期待どおりに動作させるには、dbの初期セットアップが必要です。 前提は以下のとおりです。

  • デフォルトのユーザーをルートとして、パスワードを「123456」としてMySQLをインストールしてセットアップしました。
  • データベーステストを作成しました。
  • リンクを理解するためにMySQLチュートリアルを完了しました:/mysql/index [MySQL Basics。]

MySQLのインポート

Luaの実装が正しく行われていると仮定して、単純な require ステートメントを使用してsqliteライブラリをインポートできます。

mysql = require "luasql.mysql"

変数mysqlは、メインmysqlテーブルを参照することにより、関数へのアクセスを提供します。

接続のセットアップ

MySQL環境を開始し、その環境の接続を作成することにより、接続をセットアップできます。 以下に示します。

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

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

関数を実行する

接続には、作成、挿入、削除、更新などのすべてのdb操作を実行するのに役立つ単純な実行関数があります。 構文は次のとおりです-

conn:execute([[MySQLSTATEMENT' ]])

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

テーブル作成の例

簡単なテーブル作成の例を以下に示します。 タイプintegerのidとタイプvarcharの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

ステートメントの挿入の例

MySQLの挿入ステートメントを以下に示します。

conn:execute([[INSERT INTO sample values('11','Raj')]])

更新ステートメントの例

MySQLの更新ステートメントを以下に示します。

conn:execute([[UPDATE sample3 SET name='John' where id ='12']])

ステートメントの削除の例

MySQLの削除ステートメントを以下に示します。

conn:execute([[DELETE from sample3 where id ='12']])

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つのプロパティが必要です-

  • Atomicity -トランザクションが完了するか、まったく何も起こりません。
  • 一貫性-トランザクションは一貫した状態で開始し、システムを一貫した状態のままにする必要があります。
  • 分離-トランザクションの中間結果は、現在のトランザクションの外部では見えません。
  • 耐久性-トランザクションがコミットされると、システム障害が発生した後でも効果は持続します。

トランザクションはSTART TRANSACTIONで始まります。コミットまたはロールバックステートメントで終了します。

トランザクション開始

トランザクションを開始するには、connが開いているMySQL接続であると仮定して、Luaで次のステートメントを実行する必要があります。

conn:execute([[START TRANSACTION;]])

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

start transactionの実行後に行われた変更をロールバックするには、次のステートメントを実行する必要があります。

conn:execute([[ROLLBACK;]])

トランザクションのコミット

start transactionの実行後に行われた変更をコミットするには、次のステートメントを実行する必要があります。

conn:execute([[COMMIT;]])

上記でMySQLについて知っており、次のセクションでは基本的なSQL操作について説明します。 トランザクションを覚えてください。ただし、SQLite3については再度説明しませんが、SQLite3でも同じステートメントが機能するはずです。

SQLiteのインポート

Luaの実装が正しく行われていると仮定して、単純なrequireステートメントを使用してSQLiteライブラリをインポートできます。 インストール中に、データベース関連ファイルを含むフォルダーlibsql。

sqlite3 = require "luasql.sqlite3"

変数sqlite3は、メインのsqlite3テーブルを参照することにより、関数へのアクセスを提供します。

接続のセットアップ

SQLite環境を開始し、その環境の接続を作成することにより、接続をセットアップできます。 以下に示します。

local env  = sqlite3.sqlite3()
local conn = env:connect('mydb.sqlite')

上記の接続は、既存のSQLiteファイルに接続するか、新しいSQLiteファイルを作成し、新しく作成されたファイルとの接続を確立します。

関数を実行する

接続には、作成、挿入、削除、更新などのすべてのdb操作を実行するのに役立つ単純な実行関数があります。 構文は次のとおりです-

conn:execute([[SQLite3STATEMENT' ]])

上記の構文では、connが開いていることと既存のsqlite3接続を確認し、「SQLite3STATEMENT」を正しいステートメントに置き換える必要があります。

テーブル作成の例

簡単なテーブル作成の例を以下に示します。 タイプintegerのidとタイプvarcharの2つのパラメーターを持つテーブルを作成します。

sqlite3 = require "luasql.sqlite3"

local env  = sqlite3.sqlite3()
local conn = env:connect('mydb.sqlite')
print(env,conn)

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

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

SQLite3 environment (003EC918)  SQLite3 connection (00421F08)
0   nil

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

LuaSQL: unrecognized token: ""'id' INTEGER, 'name' TEXT)"

ステートメントの挿入の例

SQLiteの挿入ステートメントを以下に示します。

 conn:execute([[INSERT INTO sample values('11','Raj')]])

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はオープンなsqlite3接続です。 実行ステートメントによって返されるカーソルの助けを借りて、テーブル応答をループし、必要な選択データをフェッチできます。

完全な例

上記のすべてのステートメントを含む完全な例を以下に示します。

sqlite3 = require "luasql.sqlite3"

local env  = sqlite3.sqlite3()
local conn = env:connect('mydb.sqlite')
print(env,conn)

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

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

cursor,errorString = conn:execute([[select* from sample]])
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()

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

SQLite3 environment (005EC918)  SQLite3 connection (005E77B0)
0   nil
1   nil
SQLite3 cursor (005E9200)   nil
Id: 1, Name: Raj

このlibsqlライブラリを使用して、利用可能なすべてのクエリを実行できます。 したがって、これらの例にとどまらないでください。 それぞれのMySQL、SQLite3、およびLuaでサポートされている他のデータベースで利用可能なさまざまなクエリステートメントを実験します。