基本配置和连接
var conn = OHMySQLStoreCoordinator() //初始化OHMySQL连接器
let context = OHMySQLQueryContext() //初始化上下文
let db = “test” //mysql数据库名字
let table = “username” //数据库表名
let User = “root” //数据库用户名
let dbPassword = “123456” //数据库密码
let host = “localhost” //数据库地址
let Port: UInt = 3306 //数据库端口
let user = OHMySQLUser(userName: User, password: dbPassword, serverName: host, dbName: test, port: Port, socket: nil) //初始化连接参数
conn = OHMySQLStoreCoordinator(user: user!)
conn.encoding = .UTF8MB4 //编码方式
conn..connect() //连接数据库
let sqlConnected: Bool = conn.isConnected //判断数据库是否连接成功
if sqlConnected = true {
print “连接成功”
} else {
print “连接失败”
}
context.storeCoordinator = conn //连接成功存储连接到context，这样子不用每次操作数据库命令的时候都要重新连接一次。
conn.disconnect() //断开数据库连接
增删改查操作语句变量定义
//SELECT – 查询
let SELECT = OHMySQLQueryRequestFactory.select(table, condition: “username = ‘root'”)
//INSERT – 增
let INSERT = OHMySQLQueryRequestFactory.insert(table, set: [“username”: “root”, “password”: “123456”])
//DELETE – 删
let DELETE = OHMySQLQueryRequestFactory.delete(table, condition: “username = ‘root'”)
//UPDATE – 改
let UPDATE = OHMySQLQueryRequestFactory.update(table, set: [“password”: “123123”], condition: “username = ‘root'”)
执行sql语句
do {
//执行查询输出结果
let response = try context.executeQueryRequestAndFetchResult(SELECT)
print(“response:\(response as Any)”)
//增、删、改
try context.execute(INSERT)
try context.execute(DELETE)
try context.execute(UPDATE)
}catch {
print(“MySQL_Error:\(error)”)
}