導入MySQL
我們可以用一個簡單語句導入SQLite庫,假設Lua中正確實現并已完成。在安裝過程中,文件夾libsql包含數據庫相關的文件。
復制代碼 代碼如下:
mysql = require "luasql.mysql"
可變的MySQL將提供通過參照主MySQL表訪問該功能。
建立連接
我們可以設立一個啟動MySQL的環(huán)境,然后創(chuàng)建環(huán)境的連接。如下所示。
復制代碼 代碼如下:
local env = mysql.mysql()
local conn = env:connect('test','root','123456')
上面的連接將連接到現有的MySQL文件并建立與新創(chuàng)建的文件的連接。
執(zhí)行函數
這將有助于我們做的創(chuàng)建,插入,刪除,更新等,所有的數據庫操作執(zhí)行簡單的功能。語法如下所示
復制代碼 代碼如下:
conn:execute([[ 'MySQLSTATEMENT' ]])
在上面的語法,我們需要確保conn是開放的和現有的MySQL連接并替換“MySQLSTATEMENT”使用正確的語句。
創(chuàng)建表的例子
一個簡單的創(chuàng)建表的示例如下所示。它創(chuàng)建類型為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會被創(chuàng)建。
復制代碼 代碼如下:
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連接。由執(zhí)行語句返回游標,可以通過表的反應返回獲取所需的選擇數據。
一個完整的例子
所有上述聲明一個完整的例子給出下面的參考。
復制代碼 代碼如下:
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
執(zhí)行事務:
事務是確保數據一致性的機制。事務應該具有以下四個特性:
- 原子性:事務要么都完成或都沒有任何變化發(fā)生。
- 一致性:事務必須啟動一個一致的狀態(tài),讓系統(tǒng)處于一致的狀態(tài)。
- 隔離:一個事務的中間結果是不是當前事務外可見。
- 持久性:當一個事務被提交,這個效果是持久的,即使在系統(tǒng)出現故障。
事務開始START TRANSACTION;和commit或rollback語句結束。
開始事務
為了啟動一個事務,我們需要執(zhí)行在Lua下面執(zhí)行語句,假設conn是一個開放的MySQL連接。
復制代碼 代碼如下:
conn:execute([[START TRANSACTION;]])
回滾事務
我們需要做執(zhí)行下面的語句來回滾執(zhí)行開始事務后所做的更改。
復制代碼 代碼如下:
conn:execute([[ROLLBACK;]])
提交事務
我們需要做執(zhí)行以下語句提交執(zhí)行開始事務后所做的更改。
復制代碼 代碼如下:
conn:execute([[COMMIT;]])
我們已經在上面知道關于MySQL和下節(jié)介紹基本的SQL操作。請記住事務,但sqlite3不會再解釋了,但相同的語句在sqlite3也能正常工作。