// EXEC: cjc %import-path %L %l %f
// EXEC: ./main
import mysqlclient_ffi.*
import std.unittest.*
import std.unittest.testmacro.*
import std.database.sql.*
import std.time.*

main(): Int64 {
    let mysqlVarcharLongTest: MysqlVarcharLongTest = MysqlVarcharLongTest()

    mysqlVarcharLongTest.deleteDB()
    mysqlVarcharLongTest.createDB()

    mysqlVarcharLongTest.mysqlVarcharLongTest01()

    return 0
}

/*
 * +---------------+---------------+------+-----+---------+-------+
 * | Field         | Type          | Null | Key | Default | Extra |
 * +---------------+---------------+------+-----+---------+-------+
 * | varcharValue1 | varchar(5500) | NO   |     | NULL    |       |
 * +---------------+---------------+------+-----+---------+-------+
 */
@Test
public class MysqlVarcharLongTest {
    func deleteDB() {
        // 初始化数据库驱动
        let mysqlDriver: MysqlDriver = MysqlDriver("mysql")

        // 通过connectionString和选项打开数据源
        let mysqlDatasource: MysqlDatasource = mysqlDriver.open(
            "HOST=127.0.0.1;USER=root;PASSWD=123;DB=mysql;PORT=3306;UNIX_SOCKET=;CLIENT_FLAG=0",
            Array<(String, String)>()
        )

        // 返回一个可用的链接
        let mysqlConnection: MysqlConnection = mysqlDatasource.connect()

        // 删除t_test名称数据表
        var mysqlStatement: MysqlStatement = mysqlConnection.prepareStatement(
            "drop table if exists t_test_varchar_long")
        mysqlStatement.update([])

        mysqlStatement.close()
        mysqlConnection.close()
    }

    func createDB() {
        // 初始化数据库驱动
        let mysqlDriver: MysqlDriver = MysqlDriver("mysql")

        // 通过connectionString和选项打开数据源
        let mysqlDatasource: MysqlDatasource = mysqlDriver.open(
            "HOST=127.0.0.1;USER=root;PASSWD=123;DB=mysql;PORT=3306;UNIX_SOCKET=;CLIENT_FLAG=0",
            Array<(String, String)>()
        )

        // 返回一个可用的链接
        let mysqlConnection: MysqlConnection = mysqlDatasource.connect()

        // 创建t_test名称数据表
        var mysqlStatement: MysqlStatement = mysqlConnection.prepareStatement(
            "create table t_test_varchar_long(varcharValue1 varchar(5500) not null)")
        mysqlStatement.update([])

        mysqlStatement.close()
        mysqlConnection.close()
    }

    @TestCase
    public func mysqlVarcharLongTest01(): Unit {
        // 初始化数据库驱动
        let mysqlDriver: MysqlDriver = MysqlDriver("mysql")

        // 通过connectionString和选项打开数据源
        let mysqlDatasource: MysqlDatasource = mysqlDriver.open(
            "HOST=127.0.0.1;USER=root;PASSWD=123;DB=mysql;PORT=3306;UNIX_SOCKET=;CLIENT_FLAG=0",
            Array<(String, String)>()
        )

        // 返回一个可用的链接
        let mysqlConnection: MysqlConnection = mysqlDatasource.connect()

        // 插入数据预执行语句
        var mysqlStatement1: MysqlStatement = mysqlConnection.prepareStatement(
            "insert into  t_test_varchar_long(varcharValue1)  VALUES(?)")
        @Assert(1, mysqlStatement1.parameterCount)

        // 插入一条数据
        var varcharValueOne1: SqlVarchar = SqlVarchar("lihao")
        var arrDb1: Array<SqlDbType> = [varcharValueOne1]
        var mysqlUpdateResult1: MysqlUpdateResult = mysqlStatement1.update(arrDb1)
        @Assert(1, mysqlUpdateResult1.rowCount)

        // 插入一条数据
        // 长度过长bug
        let longStr: String = "01234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789"
        var varcharValueOne2: SqlVarchar = SqlVarchar(longStr)
        var arrDb2: Array<SqlDbType> = [varcharValueOne2]
        var mysqlUpdateResult2: MysqlUpdateResult = mysqlStatement1.update(arrDb2)
        @Assert(1, mysqlUpdateResult2.rowCount)

        // 插入一条数据
        var varcharValueOne3: SqlVarchar = SqlVarchar("菜鸟课程")
        var arrDb3: Array<SqlDbType> = [varcharValueOne3]
        var mysqlUpdateResult3: MysqlUpdateResult = mysqlStatement1.update(arrDb3)
        @Assert(1, mysqlUpdateResult3.rowCount)
        mysqlStatement1.close()

        // 查询语句预执行语句
        var mysqlStatement2: MysqlStatement = mysqlConnection.prepareStatement(
            "select * from t_test_varchar_long where varcharValue1 = ?")
        @Assert(1, mysqlStatement2.parameterCount)

        var varcharValueOne4: SqlVarchar = SqlVarchar(longStr)
        var arrDb4: Array<SqlDbType> = [varcharValueOne4]

        var mysqlQueryResult1: MysqlQueryResult = mysqlStatement2.query(arrDb4)

        let mysqlColumnInfos1: Array<MysqlColumnInfo> = mysqlQueryResult1.mysqlColumnInfos
        @Assert(1, mysqlColumnInfos1.size)

        @Assert("varcharValue1", mysqlColumnInfos1[0].name)
        @Assert("SqlVarchar", mysqlColumnInfos1[0].typeName)
        @Assert(0, mysqlColumnInfos1[0].displaySize)
        @Assert(22000, mysqlColumnInfos1[0].length)
        @Assert(0, mysqlColumnInfos1[0].scale)
        @Assert(true, mysqlColumnInfos1[0].nullable)

        var varcharValueOne5: SqlVarchar = SqlVarchar("")
        var arrDb5: Array<SqlDbType> = [varcharValueOne5]
        var isBool1: Bool = mysqlQueryResult1.next(arrDb5)
        @Assert(true, isBool1)
        @Assert(longStr, (arrDb5[0] as SqlVarchar).getOrThrow().value)
        mysqlStatement2.close()

        // 删除语句预执行语句
        var mysqlStatement3: MysqlStatement = mysqlConnection.prepareStatement(
            "delete from t_test_varchar_long where varcharValue1 = ?")
        @Assert(1, mysqlStatement3.parameterCount)
        var varcharValueOne6: SqlVarchar = SqlVarchar(longStr)
        var arrDb6: Array<SqlDbType> = [varcharValueOne6]
        var mysqlUpdateResult4: MysqlUpdateResult = mysqlStatement3.update(arrDb6)
        @Assert(1, mysqlUpdateResult4.rowCount)
        mysqlStatement3.close()

        // 查询语句预执行语句
        var mysqlStatement4: MysqlStatement = mysqlConnection.prepareStatement(
            "select * from t_test_varchar_long where varcharValue1 = ?")
        @Assert(1, mysqlStatement4.parameterCount)
        var varcharValueOne7: SqlVarchar = SqlVarchar(longStr)
        var arrDb7: Array<SqlDbType> = [varcharValueOne7]
        var mysqlQueryResult2: MysqlQueryResult = mysqlStatement4.query(arrDb7)
        var varcharValueOne8: SqlVarchar = SqlVarchar("")
        var arrDb8: Array<SqlDbType> = [varcharValueOne8]
        var isBool2: Bool = mysqlQueryResult2.next(arrDb8)
        @Assert(false, isBool2)
        mysqlStatement4.close()

        // 更新语句预执行语句
        let mysqlStatement7: MysqlStatement = mysqlConnection.prepareStatement(
            "update t_test_varchar_long set varcharValue1 = ?  where varcharValue1 = ?")
        @Assert(2, mysqlStatement7.parameterCount)

        var varcharValueOne9: SqlVarchar = SqlVarchar("lihao")
        var varcharValueOne90: SqlVarchar = SqlVarchar(
            "11111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111"
        )
        var arrDb9: Array<SqlDbType> = [varcharValueOne90, varcharValueOne9]

        // 执行更新语句
        let mysqlUpdateResult5: MysqlUpdateResult = mysqlStatement7.update(arrDb9)
        @Assert(1, mysqlUpdateResult5.rowCount)
        mysqlStatement7.close()

        // 查询语句预执行语句
        let mysqlStatement8: MysqlStatement = mysqlConnection.prepareStatement(
            "select * from t_test_varchar_long where varcharValue1 = '11111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111111'"
        )

        // 执行查询语句
        var mysqlQueryResult3: MysqlQueryResult = mysqlStatement8.query([])

        var varcharValueOne10: SqlVarchar = SqlVarchar("")
        var arrDb10: Array<SqlDbType> = [varcharValueOne10]

        // 获取数据
        let isBool10: Bool = mysqlQueryResult3.next(arrDb10)
        @Assert(true, isBool10)
        mysqlStatement8.close()

        // 删除t_test名称数据表
        let mysqlStatement9: MysqlStatement = mysqlConnection.prepareStatement(
            "drop table if exists t_test_varchar_long")
        mysqlStatement9.update([])
        mysqlStatement9.close()

        // 关闭链接
        mysqlConnection.close()
    }
}