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提供各種查詢語句。