// 3rd_party_lib:mysqlclient-ffi/build/mysqlclient
// 3rd_party_lib_ohos:mysqlclient-ffi/build/aarch64-linux-ohos/mysqlclient
import mysqlclient_ffi.*
import std.unittest.*
import std.unittest.testmacro.*
import std.database.sql.*
import std.time.*

@Test
public class MysqlRecordApi02Test {
    @TestCase
    func mysqlRecordApiTest001(): 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()

        // 删除t_test2名称数据表
        var mysqlStatement1: MysqlStatement = mysqlConnection.prepareStatement("drop table if exists t_test_time")
        mysqlStatement1.update()

        // 创建t_test2名称数据表
        var mysqlStatement2: MysqlStatement = mysqlConnection.prepareStatement(
            "create table t_test_time(id bigint not null, timeValue1 time not null, timeValue2 time)")
        mysqlStatement2.update()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        // 通过传入的 sql 语句，返回一个预执行的 Statement 对象实例
        var mysqlStatement3: MysqlStatement = mysqlConnection.prepareStatement(
            "insert into  t_test_time(id,timeValue1,timeValue2)  VALUES(?,?,?)")
        @Assert(3, mysqlStatement3.parameterCount)

        // 执行插入语句插入数据
        let dateTime1: DateTime = DateTime.of(year: 1, month: 1, dayOfMonth: 1, hour: 8, minute: 10, second: 30)
        mysqlStatement3.set<Int64>(0, 1)
        mysqlStatement3.set<MysqlTypeTime>(1, MysqlTypeTime(dateTime1))
        mysqlStatement3.setNull(2)
        var mysqlUpdateResult1: MysqlUpdateResult = mysqlStatement3.update()
        @Assert(1, mysqlUpdateResult1.rowCount)
        @Assert(0, mysqlUpdateResult1.lastInsertId)
        var rowUint64: UInt64 = mysqlRecordApi.mysqlAffectedRows()
        @Assert(1, rowUint64)
        var idUint64: UInt64 = mysqlRecordApi.mysqlInsertId()
        @Assert(0, idUint64)

        // 执行插入语句插入数据
        let dateTime2: DateTime = DateTime.of(year: 1, month: 1, dayOfMonth: 1, hour: 8, minute: 10, second: 30)
        let dateTime3: DateTime = DateTime.of(year: 1, month: 1, dayOfMonth: 1, hour: 12, minute: 5, second: 3)
        mysqlStatement3.set<Int64>(0, 2)
        mysqlStatement3.set<MysqlTypeTime>(1, MysqlTypeTime(dateTime2))
        mysqlStatement3.set<MysqlTypeTime>(2, MysqlTypeTime(dateTime3))
        var mysqlUpdateResult2: MysqlUpdateResult = mysqlStatement3.update()
        @Assert(1, mysqlUpdateResult2.rowCount)
        rowUint64 = mysqlRecordApi.mysqlAffectedRows()
        @Assert(1, rowUint64)
        idUint64 = mysqlRecordApi.mysqlInsertId()
        @Assert(0, idUint64)

        // 执行插入语句插入数据
        let dateTime4: DateTime = DateTime.of(year: 1, month: 1, dayOfMonth: 1, hour: 18, minute: 20, second: 40)
        let dateTime5: DateTime = DateTime.of(year: 1, month: 1, dayOfMonth: 1, hour: 22, minute: 35, second: 53)
        mysqlStatement3.set<Int64>(0, 3)
        mysqlStatement3.set<MysqlTypeTime>(1, MysqlTypeTime(dateTime4))
        mysqlStatement3.set<MysqlTypeTime>(2, MysqlTypeTime(dateTime5))
        var mysqlUpdateResult3: MysqlUpdateResult = mysqlStatement3.update()
        @Assert(1, mysqlUpdateResult3.rowCount)
        rowUint64 = mysqlRecordApi.mysqlAffectedRows()
        @Assert(1, rowUint64)
        idUint64 = mysqlRecordApi.mysqlInsertId()
        @Assert(0, idUint64)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("select * from t_test_time")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest002(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest003(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery(
            "select * from t_test_timet_test_timet_test_timet_test_timet_test_time")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest004(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("select * form t_test_time")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest005(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("drop table if exists t_test_time")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest006(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery(
            "create table t_test_time(id bigint not null, timeValue1 time not null, timeValue2 time)")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest007(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("desc t_test_time")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest008(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("alter table t_test_time add(name varchar(100))")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest009(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("alter table t_test_time modify name varchar(30)")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest010(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("alter table t_test_time change name charname varchar(30)")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest011(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("alter table t_test_time drop charname")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest012(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        var retInt32: Int32 = mysqlRecordApi.mysqlQuery("alter table t_test_time rename to t_test_time1")
        @Assert(0, retInt32)

        retInt32 = mysqlRecordApi.mysqlSendQuery("drop table if exists t_test_time1")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest013(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("create database if not exists mysql1")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest014(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        var retInt32: Int32 = mysqlRecordApi.mysqlQuery("use mysql1")
        @Assert(0, retInt32)

        retInt32 = mysqlRecordApi.mysqlSendQuery("alter database mysql1 character set utf8")
        @Assert(0, retInt32)

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

    @TestCase
    func mysqlRecordApiTest015(): 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()

        let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)

        let retInt32: Int32 = mysqlRecordApi.mysqlSendQuery("drop database if exists mysql1")
        @Assert(0, retInt32)

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