位置:首頁 > 腳本語言 > Lua教學 > Lua數據庫/MySQL操作

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