更新 target/mysql/conn.lua

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