update

target/mysql/pool.lua

@@ -0,0 +1,93 @@
+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 conn = require("mysql.conn")
+
+
+
+local mysql_pool = {}
+mysql_pool.__index = mysql_pool
+
+--[[
+    创建一个新的 fw_mysql_pool 对象
+    @return 返回一个新的 fw_mysql_pool 对象
+]]
+function mysql_pool.new(pool)
+    local instance = setmetatable({}, mysql_pool)
+    if pool == nil then
+        instance.module = fw_mysql_pool.new()
+    else
+        instance.module = pool
+    end
+    return instance
+end
+
+--[[
+    启动 MySQL 连接池
+    @param ipaddress IP 地址
+    @param username 用户名
+    @param password 密码
+    @param database 数据库名称
+    @param charset 字符集
+    @param port 端口号
+    @param size 连接池大小
+    @return 是否成功启动
+]]
+function mysql_pool:start(ipaddress, username, password, database, charset, port, size)
+    return self.module:start(ipaddress, username, password, database, charset, port, size)
+end
+
+--[[
+    关闭 MySQL 连接池
+]]
+function mysql_pool:close()
+    self.module:close()
+end
+
+--[[
+    获取一个 select 对象
+    @return 返回一个 select 对象
+]]
+function mysql_pool:select()
+    return select.new(self.module:select())
+    --return self.module:select()
+end
+
+--[[
+    获取一个 insert 对象
+    @return 返回一个 insert 对象
+]]
+function mysql_pool:insert()
+    return insert.new(self.module:insert())
+end
+
+--[[
+    获取一个 update 对象
+    @return 返回一个 update 对象
+]]
+function mysql_pool:update()
+    return update.new(self.module:update())
+end
+
+--[[
+    获取一个 delete 对象
+    @return 返回一个 delete 对象
+]]
+function mysql_pool:delete()
+    return delete(self.module:delete())
+end
+
+--[[
+    获取一个 mysql_conn 对象
+    @return 返回一个 mysql_conn 对象
+]]
+function mysql_pool:get()
+    return conn.new(self.module:get())
+end
+
+function mysql_pool:self()
+    return self.module:self()
+end
+
+return mysql_pool