diff --git a/target/mysql/conn.lua b/target/mysql/conn.lua index 0e9b336..06f6012 100644 --- a/target/mysql/conn.lua +++ b/target/mysql/conn.lua @@ -1,141 +1,148 @@ -local select = require("mysql.builder_select") -local update = require("mysql.builder_update") -local insert = require("mysql.builder_insert") -local delete = require("mysql.builder_delete") -local ppst = require("mysql.prepare_statement") - - -local mysql_conn = {} -mysql_conn.__index = mysql_conn - ---[[ - 创建一个新的 fw_mysql_conn 对象 - @return 返回一个新的 fw_mysql_conn 对象 -]] -function mysql_conn.new(__module) - local instance = setmetatable({}, mysql_conn) - if __module == nil then - instance.module = fw_mysql_conn.new() - else - instance.module = __module - end - return instance -end ---[[ - 连接到 MySQL 数据库 - @param ipaddress IP 地址 - @param username 用户名 - @param password 密码 - @param database 数据库名称 - @param charset 字符集 - @param port 端口号 - @return 返回连接状态码 -]] -function mysql_conn:connect(ipaddress, username, password, database, charset, port) - return self.module:connect(ipaddress, username, password, database, charset, port) -end - ---[[ - 清空连接 -]] -function mysql_conn:clear() - self.module:clear() -end - ---[[ - 设置 SQL 语句 - @param sql SQL 语句 - @return 返回 mysql_prepare_statement 对象 -]] -function mysql_conn:setsql(sql) - return ppst.new(self.module:setsql(sql)) -end - ---[[ - 获取上一次插入操作的 ID - @return 返回上一次插入操作的 ID -]] -function mysql_conn:insert_id() - return self.module:insert_id() -end - ---[[ - 开始事务 - @param autocommit 是否自动提交 -]] -function mysql_conn:begin(autocommit) - if autocommit == nil then - autocommit = false - end - self.module:begin(autocommit) -end - ---[[ - 提交事务 -]] -function mysql_conn:commit() - self.module:commit() -end - ---[[ - 回滚事务 -]] -function mysql_conn:rollback() - self.module:rollback() -end - ---[[ - 设置数据库名称 - @param name 数据库名称 -]] -function mysql_conn:setDatabase(name) - self.module:setDatabase(name) -end - ---[[ - 获取最后的错误信息 - @return 返回错误信息字符串 -]] -function mysql_conn:last_error() - return self.module:last_error() -end - ---[[ - 获取一个 select 对象 - @return 返回一个 select 对象 -]] -function mysql_conn:select() - return select.new(self.module:select()) -end - ---[[ - 获取一个 insert 对象 - @return 返回一个 insert 对象 -]] -function mysql_conn:insert() - return insert.new(self.module:insert()) -end - ---[[ - 获取一个 update 对象 - @return 返回一个 update 对象 -]] -function mysql_conn:update() - return update.new(self.module:update()) -end - ---[[ - 获取一个 delete 对象 - @return 返回一个 delete 对象 -]] -function mysql_conn:delete() - return delete.new(self.module:delete()) -end - ---[[ - 释放连接 -]] -function mysql_conn:close() - self.module:close() -end -return mysql_conn +local select = require("mysql.builder_select") +local update = require("mysql.builder_update") +local insert = require("mysql.builder_insert") +local delete = require("mysql.builder_delete") +local ppst = require("mysql.prepare_statement") + + +local mysql_conn = {} +mysql_conn.__index = mysql_conn + +--[[ + 创建一个新的 fw_mysql_conn 对象 + @return 返回一个新的 fw_mysql_conn 对象 +]] +function mysql_conn.new(__module) + local instance = setmetatable({}, mysql_conn) + if __module == nil then + instance.module = fw_mysql_conn.new() + else + instance.module = __module + end + return instance +end +--[[ + 连接到 MySQL 数据库 + @param ipaddress IP 地址 + @param username 用户名 + @param password 密码 + @param database 数据库名称 + @param charset 字符集 + @param port 端口号 + @return 返回连接状态码 +]] +function mysql_conn:connect(ipaddress, username, password, database, charset, port) + return self.module:connect(ipaddress, username, password, database, charset, port) +end + +--[[ + 清空连接 +]] +function mysql_conn:clear() + self.module:clear() +end + +--[[ + 设置 SQL 语句 + @param sql SQL 语句 + @return 返回 mysql_prepare_statement 对象 +]] +function mysql_conn:setsql(sql) + return ppst.new(self.module:setsql(sql)) +end + +--[[ + 获取上一次插入操作的 ID + @return 返回上一次插入操作的 ID +]] +function mysql_conn:insert_id() + return self.module:insert_id() +end + +--[[ + 开始事务 + @param autocommit 是否自动提交 +]] +function mysql_conn:begin(autocommit) + if autocommit == nil then + autocommit = false + end + self.module:begin(autocommit) +end + +--[[ + 提交事务 +]] +function mysql_conn:commit() + self.module:commit() +end + +--[[ + 回滚事务 +]] +function mysql_conn:rollback() + self.module:rollback() +end + +--[[ + 设置数据库名称 + @param name 数据库名称 +]] +function mysql_conn:setDatabase(name) + self.module:setDatabase(name) +end + +--[[ + 获取最后的错误信息 + @return 返回错误信息字符串 +]] +function mysql_conn:last_error() + return self.module:last_error() +end + +--[[ + 获取一个 select 对象 + @return 返回一个 select 对象 +]] +function mysql_conn:select() + return select.new(self.module:select()) +end + +--[[ + 获取一个 insert 对象 + @return 返回一个 insert 对象 +]] +function mysql_conn:insert() + return insert.new(self.module:insert()) +end + +--[[ + 获取一个 update 对象 + @return 返回一个 update 对象 +]] +function mysql_conn:update() + return update.new(self.module:update()) +end + +--[[ + 获取一个 delete 对象 + @return 返回一个 delete 对象 +]] +function mysql_conn:delete() + return delete.new(self.module:delete()) +end + +--[[ + 释放连接 +]] +function mysql_conn:close() + self.module:close() +end +--[[ + 取自身指针 +]] +function mysql_conn:self() + return self.module:self() +end + +return mysql_conn