代码拉取完成,页面将自动刷新
通过仓颉数据标准接口实现mysql驱动程序的纯仓颉实现
🚀 连接管理
🚀 事务管理
🚀 数据类型映射
🚀 异常处理
💪 数据库元数据
🛠️ 预处理语句
🌍 批处理
💡 结果集处理
├─doc
├─src
│ ├─cjdbc
│ ├─conf
│ ├─exceptions
│ ├─expansion
│ ├─log
│ ├─message
│ ├─protocol
│ ├─socket
│ └─util
└─test
doc
存放库的设计文档、使用文档、LLT 用例覆盖报告src
是库源码目录test
存放测试文件1.导入驱动
import mysql.CJMySqlDriver
2.注册驱动
2.1 使用DriverUtil调用驱动注册
from mysql import com.qy.cj.DriverUtil
DriverUtil.register(name)
2.2 使用DriverManager调用驱动注册
let driver = CJMySqlDriver()
DriverManager.register("mysql", driver)
2.3 直接使用驱动类
let drv = CJMySqlDriver()
3.打开数据源
let opts = [
(SqlOption.Username, "root"),
(SqlOption.Password, "....")
]
var ds = drv.open(
"cjdbc:mysql://127.0.0.1:3306/dbtest",
opts
)
4.获取连接
let conn = ds.connect()
5.执行sql
let stmt = conn.prepareStatement("select * from test")
let u = stmt.query()
6.获取结果
var id: SqlInteger = SqlInteger(-1)
var name: SqlVarchar = SqlVarchar("")
//必须严格遵守查询字段的顺序和个数
while (u.next(name, id)) {
println("id:${id.value} name:${name.value} ")
}
7.关闭连接
conn.close()
扩展接口查看 doc/doc.md
//导入依赖
import mysql.*
//使用DriverUtil类的getConnection方法获取连接
try (conn = DriverUtil.getConnection("cjdbc:mysql://127.0.0.1:3072/dbtest", "root", "....")) {
let stmt = conn.createStatement()
println(stmt.execute("insert into test (id,name) values (1,'test')"))
let res = stmt.executeQuery("select * from test")
while (res.next()) {
println("id:${res.getInterger("id")} name:${res.getString("name")}")
println("id:${res.getInterger(1)} name:${res.getString(2)}")
}
conn.close()
} catch (e: Exception) {
println(e)
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。