Lua數據庫/MySQL操作

對於簡單的數據操作,我們可以使用文件,但是,有時候這些文件操作效率不高,可擴展性和強大不好。所以我們可能會經常切換到使用數據庫。 LuaSQL是從Lua一些數據庫管理系統的一個簡單的接口。 LuaSQL它提供了對不同類型的SQL支持庫。這包括:

  • SQLite

  • Mysql

  • ODBC

在本教程中,將涵蓋Lua中的SQLite和MySQL數據庫處理。使用這個通用接口爲應儘可能實施於其它類型的數據庫。首先,讓我們看看如何在MySQL中執行操作。

MySQL數據庫的設置

以使用下面的示例以預期方式工作,我們所需要的初始數據庫設置。假設如下面列出:

  • 已經安裝並設置MySQL的默認用戶以root,密碼爲「123456」。

  • 您已經創建了一個數據庫test。

  • 您通過MySQL教程去了解MySQL基礎知識。

導入MySQL

我們可以用一個簡單語句導入SQLite庫,假設Lua中正確實現並已完成。在安裝過程中,文件夾libsql包含數據庫相關的文件。

mysql = require "luasql.mysql"

可變的MySQL將提供通過參照主MySQL表訪問該功能。

建立連接

我們可以設立一個啓動MySQL的環境,然後創建環境的連接。如下所示。

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

上面的連接將連接到現有的MySQL文件並建立與新創建的文件的連接。

執行函數

這將有助於我們做的創建,插入,刪除,更新等,所有的數據庫操作執行簡單的功能。語法如下所示

conn:execute([[ 'MySQLSTATEMENT' ]])

在上面的語法,我們需要確保conn是開放的和現有的MySQL連接並替換「MySQLSTATEMENT」使用正確的語句。

創建表的例子

一個簡單的創建表的示例如下所示。它創建類型爲int和varchar類型,兩個參數ID和name的表。

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會被創建。

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

執行事務:

事務是確保數據一致性的機制。事務應該具有以下四個特性:

  • 原子性:事務要麼都完成或都沒有任何變化發生。

  • 一致性:事務必須啓動一個一致的狀態,讓系統處於一致的狀態。

  • 隔離:一個事務的中間結果是不是當前事務外可見。

  • 持久性:當一個事務被提交,這個效果是持久的,即使在系統出現故障。

事務開始START TRANSACTION;和commit或rollback語句結束。

開始事務

爲了啓動一個事務,我們需要執行在Lua下面執行語句,假設conn是一個開放的MySQL連接。

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

回滾事務

我們需要做執行下面的語句來回滾執行開始事務後所做的更改。

conn:execute([[ROLLBACK;]])

提交事務

我們需要做執行以下語句提交執行開始事務後所做的更改。

conn:execute([[COMMIT;]])

我們已經在上面知道關於MySQL和下節介紹基本的SQL操作。請記住事務,但sqlite3不會再解釋了,但相同的語句在sqlite3也能正常工作。

SQLite導入

我們可以用一個簡單語句導入SQLite庫,假設Lua中正確實現並已完成。在安裝過程中,文件夾libsql包含數據庫相關的文件。

sqlite3 = require "luasql.sqlite3"

變量sqlite3將提供通過參照主sqlite3表訪問該功能。

建立連接

我們成立了發起sqlite環境,然後創建環境的連接。它如下所示。

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

上述連接將連接到現有的SQLite文件或創建一個新的源碼文件,並建立與新創建的文件的連接。

執行函數

有可用的,這將有助於我們執行創建,插入,刪除,更新等,所有的數據庫操作基於連接執行簡單的功能。語法如下所示

conn:execute([[ 'SQLite3STATEMENT' ]])

在上面的語法,我們需要確保conn是開放的及現有的sqlite3連接,代替「SQLite3STATEMENT」使用正確的語句。

創建表的例子

一個簡單的創建表的示例如下所示。它創建類型爲int和varchar類型,兩個參數ID和name的表。

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會被創建。

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

如果有錯誤,會返回nil的錯誤語句。下面一個簡單的錯誤語句如下所示。

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

Insert語句的例子

SQLite的一個INSERT語句如下所示。

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

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 是一個開放的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支持DB提供各種查詢語句。