数据库访问 3个月前

简单的数据操作，我们用文件就可以处理。但是，某些时候文件操作存在性能、扩展性等问题。这时候，我们就需要使用数据库。LuaSQL 是一个提供数据库操作的库，它支持多种 SQL 数据库的操作。包括：

• SQLite
• MySQL
• ODBC

MySQL 数据库环境设置

为了下面的例子可以正确演示，我们需要首先初始化数据库设置。我们假设你已经完成了如下的工作：

• 安装 MySQL 数据库，使用默认用户名 root， 默认密码为： 123456。
• 已经创建数据库 test。
• 已经阅读过关于 MySQL 的基本教程，并掌握了 MySQL 的基本知识。

导入 MySQL

假设你已经安装配置正确了，那么我们可以使用 require 语句导入 sqlite 库。安装过程中会产生一个存储数据相关文件的目录 libsql。

copy
mysql = require "luasql.mysql"

我们可以通过 mysql 变量访问 luasql.mysql 中的 mysql 表，该表中存存储数据库操作相关的函数。

建立连接

先初始化 MySQL 的环境，再建立一个连接。如下所示：

copy
local env  = mysql.mysql()
local conn = env:connect('test','root','123456')

上面的程序会与已存在的 MySQL 数据库 test 建立连接。

执行函数

LuaSQL 库中有一个 execute 函数，此函数可以完成所有数据加操作，包括创建、插入、更新等操作。其语法如下所示：

copy
conn:execute([[ 'MySQLSTATEMENT' ]])

执行上面的语句这前，我们需要保证与 MySQL 数据库的连接 conn 是打开的，同时将 MySQLSTATEMENT 更改为合法的 SQL 语句。

创建表

下面的示例演示如何创建一个数据库表。例子中为表创建了两个属性分别为 id 和 name，其类型分别为整数和 vchar。

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

copy
MySQL environment (004BB178)    MySQL connection (004BE3C8)
0    nil

如果发生错误，则函数将返回一个错误消息，成功执行则返回 nil。下面是错误消息的一个例子：

copy
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

插入语句

ＭySQL 插入语句的示例如下所示：

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

更新语句

ＭySQL 更新语句的示例如下所示：

copy
conn:execute([[UPDATE sample3 SET name='John' where id ='12']])

删除语句

ＭySQL 删除语句的示例如下所示：

copy
conn:execute([[DELETE from sample3 where id ='12']])

查找语句

成功查找返回后，我们需要循环遍历返回的所有行以取得我们需要的数据。查找语句的示例如下：

copy
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

上面的代码中，我们先打开了一个 MySQL 连接。通过 execute 函数返回的游标(cursor)，我们可以使用游标遍历返回的表，取得我们查找的数据。

完整示例

下面这个例子用到了所有上面提到的数据的操作函数，请看下面这个完整的例子：

copy
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()

运行上面的程序，我们可以得到如下的输出结果：

copy
MySQL environment (0037B178)    MySQL connection (0037EBA8)
0    nil
1    nil
MySQL cursor (003778A8)    nil
Id: 12, Name: Raj

执行事务

事务是数据库中保证数据一致性的一种机制。事务有以下四个性质：

• 原子性：一个事务要么全部执行要么全部不执行。
• 一致性：事务开始前数据库是一致状态，事务结束后数据库状态也应该是一致的。
• 隔离性：多个事务并发访问时，事务之间是隔离的，一个事务的中间状态不能被其它事务可见。
• 持久性： 在事务完成以后，该事务所对数据库所做的更改便持久的保存在数据库之中，并不会被回滚。

事务开始

为了初始化一个事务，我们需要先打开一个 MySQL 连接，再执行如下的语句：

copy
conn:execute([[START TRANSACTION;]])

事务回滚

当需要取消事务执行时，我们需要执行如下的语句回滚至更改前的状态。

copy
conn:execute([[ROLLBACK;]])

提交事务

开始执行事务后，我们需要使用 commit 语句提交完成的修改内容。

copy
conn:execute([[COMMIT;]])

前面我们已经了解了 MySQL 的基本知识。接下来，我们将解释一下基本的 SQL 操作。请记住事务的概念，虽然我们在 SQLite3 中我们不在解释它，但是它的概念在 SQLite3 中同样适用。

导入 SQLite

假设你已经安装配置正确了，那么就可以使用 require 语句导入 sqlite 库。安装过程中会产生一个存储数据相关文件的目录 libsql。

copy
sqlite3 = require "luasql.sqlite3"

通过 sqlite3 变量可以访问提供的所有数据库操作相关函数。

建立连接

我们先初始化 sqlite 环境，然后为该环境创建一个连接。语法如下：

copy
local env  = sqlite3.sqlite3()
local conn = env:connect('mydb.sqlite')

上面的代码会与一个 sqlite 文件建立连接，如果文件不存在则创建新的 sqlite 文件并与该新文件建立连接。

执行函数

LuaSQL 库中有一个 execute 函数，此函数可以完成所有数据加操作，包括创建、插入、更新等操作。其语法如下所示：

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

执行上面的语句这前，我们需要保证与 MySQL 数据库的连接 conn 是打开的，同时将 SQLite3STATEMENT 更改为合法的 SQL 语句。

创建表

下面的示例演示如何创建一个数据库表。例子中为表创建了两个属性分别为 id 和 name，其类型分别为整数和 vchar。

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

copy
SQLite3 environment (003EC918)    SQLite3 connection (00421F08)
0    nil

如果发生错误，则函数将而一个错误消息；若成功执行则返回 nil。下面是错误消息的一个例子：

copy
LuaSQL: unrecognized token: ""'id' INTEGER, 'name' TEXT)"

插入语句

插入语句的示例如下所示：

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

查找语句

查找返回后，我们需要循环遍历每行以取得我们需要的数据。查找语句的示例如下：

copy
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

上面的代码中，我们先打开了一个 sqlite3 连接。通过 execute 函数返回的游标(cursor)，我们可以遍历返回的表，以取得我们查找的数据。

完整示例

下面这个例子用到了所有上面提到的数据的操作函数，请看下面这个完整的例子：

copy
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()

运行上面的程序，我们可以得到如下的输出结果：

copy
SQLite3 environment (005EC918)    SQLite3 connection (005E77B0)
0    nil
1    nil
SQLite3 cursor (005E9200)    nil
Id: 1, Name: Raj

使用 libsql 库我们可以执行所有的数据库操作。所以，看完这些例子后，请自己多做一些练习。