Categories
Lua

Lua-数据库访问

Lua-数据库访问


对于简单的数据操作,我们可以使用文件,但有时,这些文件操作可能不是高效,可伸缩且功能强大的。为此,我们可能经常切换到使用数据库。 LuaSQL是从Lua到许多数据库管理系统的简单接口。 LuaSQL是库,它提供对不同类型的SQL的支持。这包括

  • SQLite的
  • MySQL的
  • ODBC

在本教程中,我们将介绍Lua中MySQL和SQLite的MySQL数据库处理。这两者都使用通用接口,并且应该有可能将此实现移植到其他类型的数据库。首先让我们看看如何在MySQL中进行操作。

MySQL数据库设置

为了使用以下示例按预期工作,我们需要初始数据库设置。这些假设在下面列出。

  • 您已经安装并设置了MySQL,默认用户为root,密码为“ 123456”。

  • 您已经创建了数据库测试。

  • 您已经阅读了MySQL教程,以了解MySQL基础。

导入MySQL

假设您的Lua实现正确完成,我们可以使用简单的require语句导入sqlite库。

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”。

创建表示例

一个简单的创建表示例如下所示。它创建一个带有两个参数ID(整数类型)和varchar类型名称的表。

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

插入语句示例

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语句而言,我们需要遍历每一行并提取所需的数据。一个简单的选择语句如下所示。

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连接。借助execute语句返回的游标,您可以遍历表响应并获取所需的选择数据。

一个完整的例子

下面给出了包含上述所有语句的完整示例。

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;]])

回滚交易

我们需要执行以下语句来回滚执行start事务后所做的更改。

conn:execute([[ROLLBACK;]])

提交交易

我们需要执行以下语句来提交执行启动事务后所做的更改。

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文件,并与新创建的文件建立连接。

执行功能

连接中有一个简单的执行函数,它将帮助我们执行从创建,插入,删除,更新等所有的数据库操作。语法如下所示-

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

在以上语法中,我们需要确保conn已打开并且存在现有的sqlite3连接,并用正确的语句替换“ SQLite3STATEMENT”。

创建表示例

一个简单的创建表示例如下所示。它创建一个带有两个参数ID(整数类型)和varchar类型名称的表。

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)"

插入语句示例

SQLite的插入语句如下所示。

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

选择语句示例

就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连接。借助execute语句返回的游标,您可以遍历表响应并获取所需的选择数据。

一个完整的例子

下面给出了包含上述所有语句的完整示例。

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库的帮助下执行所有可用的查询。因此,请不要仅仅停留在这些例子上。在Lua中的各个MySQL,SQLite3和其他受支持的数据库中尝试各种查询语句。

蜀ICP备20006366号
error: 内容受到保护 !!