📌  相关文章
📜  Lua-数据库访问

📅  最后修改于: 2020-10-16 05:19:56             🧑  作者: Mango

对于简单的数据操作，我们可以使用文件，但有时，这些文件操作可能不是高效，可伸缩且功能强大的。为此，我们可能经常切换到使用数据库。 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和其他受支持的数据库中尝试各种查询语句。