local LOG = require "logging"
local cf = require "cf"
local DB = require "DB"

local db = DB:new {
	host = 'localhost',
	port = 3306,
	database = 'test',
	username = 'root',
	password = '123456789',
	max = 1,
}

local ok = db:connect()
if not ok then
	return LOG:DEBUG("连接mysql失败")
end
LOG:DEBUG("连接成功")

--[[
    /* 复制下面语句到任意管理工具即可导入测试表进行测试 */

    SET NAMES utf8;
    SET FOREIGN_KEY_CHECKS = 0;
		CREATE DATABASE IF NOT EXISTS `test` DEFAULT CHARSET utf8 COLLATE utf8_general_ci;

    CREATE TABLE IF NOT EXISTS `test`.`user` (
      `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
      `name` varchar(255) CHARACTER SET utf8mb4 NOT NULL,
      `user` varchar(255) CHARACTER SET utf8mb4 NOT NULL,
      `passwd` varchar(255) CHARACTER SET utf8mb4 NOT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

    SET FOREIGN_KEY_CHECKS = 1;
--]]

-- 测试普通数据库语句
cf.fork(function ( ... )
    local ret, err = db:query("show variables like 'wait_timeout'")
    if not ret then
       return LOG:DEBUG(err)
    end
    LOG:DEBUG(ret)
end)

-- 测试预编译语句
cf.fork(function ( ... )
	local rkey = db:prepare([[SELECT version() AS version]])
	local ret, err = db:execute(rkey)
	if not ret then
		return LOG:DEBUG(err)
	end
	LOG:DEBUG(ret)
end)