// 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.*
@Test
public class MysqlListApi02Test {
@TestCase
public func mysqlListApiTest001(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(true, retRows != 0)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("columns_priv", cString.toString())
} else if (i == 1) {
@Assert("component", cString.toString())
} else if (i == 2) {
@Assert("db", cString.toString())
} else if (i == 3) {
@Assert("default_roles", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest002(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("m")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(0, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("information_schema", cString.toString())
} else if (i == 1) {
@Assert("mysql", cString.toString())
} else if (i == 2) {
@Assert("performance_schema", cString.toString())
} else if (i == 3) {
@Assert("sys", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest003(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("123")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(0, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("information_schema", cString.toString())
} else if (i == 1) {
@Assert("mysql", cString.toString())
} else if (i == 2) {
@Assert("performance_schema", cString.toString())
} else if (i == 3) {
@Assert("sys", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest004(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("你好")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(0, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("information_schema", cString.toString())
} else if (i == 1) {
@Assert("mysql", cString.toString())
} else if (i == 2) {
@Assert("performance_schema", cString.toString())
} else if (i == 3) {
@Assert("sys", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest005(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("你1232qda!@好")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(0, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("information_schema", cString.toString())
} else if (i == 1) {
@Assert("mysql", cString.toString())
} else if (i == 2) {
@Assert("performance_schema", cString.toString())
} else if (i == 3) {
@Assert("sys", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest006(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("你1232qda!@好")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(0, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("information_schema", cString.toString())
} else if (i == 1) {
@Assert("mysql", cString.toString())
} else if (i == 2) {
@Assert("performance_schema", cString.toString())
} else if (i == 3) {
@Assert("sys", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest007(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("columns_priv")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(1, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("columns_priv", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest008(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("help_keyword")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(1, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("help_keyword", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest009(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("server_cost")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(1, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("server_cost", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
@TestCase
public func mysqlListApiTest010(): 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 mysqlListApi: MysqlListApi = MysqlListApi(mysqlConnection)
let mysqlRecordApi: MysqlRecordApi = MysqlRecordApi(mysqlConnection)
let cp1: CPointer<Unit> = mysqlListApi.mysqlListTables("user")
let retFields: UInt32 = mysqlRecordApi.mysqlNumFields(cp1)
@Assert(1, retFields)
let retEof: Bool = mysqlRecordApi.mysqlEof(cp1)
@Assert(true, retEof)
let retRows: UInt64 = mysqlRecordApi.mysqlNumRows(cp1)
@Assert(1, retRows)
unsafe {
for (i in 0..retRows) {
var cpCString: CPointer<CString> = mysqlRecordApi.mysqlFetchRow(cp1)
for (j in 0..retFields) {
var cString: CString = cpCString.read(Int64(j))
if (i == 0) {
@Assert("user", cString.toString())
}
}
}
}
mysqlRecordApi.mysqlFreeResult(cp1)
mysqlConnection.close()
}
}