📌往期推文全新看点（文中附带最新·鸿蒙全栈学习笔记）

📃 鸿蒙（HarmonyOS）北向开发知识点记录~

📃 鸿蒙（OpenHarmony）南向开发保姆级知识点汇总~

📃 鸿蒙应用开发与鸿蒙系统开发哪个更有前景？

📃 嵌入式开发适不适合做鸿蒙南向开发？看完这篇你就了解了~

📃 对于大前端开发来说，转鸿蒙开发究竟是福还是祸？

📃 鸿蒙岗位需求突增！移动端、PC端、IoT到底该怎么选？

📃 记录一场鸿蒙开发岗位面试经历~

📃 持续更新中……

介绍

opengauss-driver是纯仓颉语言实现的 openGauss 和 PostgreSQL 数据库驱动。

软件架构

前后端通信协议模块: proto3

前后端连接管理模块: pgconn

驱动接口实现模块: driver

简单数据库连接池模块: sqlpool

使用说明

先使用data目录里面的sql文件创建样例表

from opengauss import driver.*
from std import database.sql.*

func do_insert(db: Datasource): Unit {
    let cn = db.connect()
    let sql = 
        #"INSERT INTO "some_types" ("created_at","updated_at","deleted_at","source") VALUES ('2022-12-29 11:02:25.566','2022-12-29 11:02:25.566',NULL,'Dec 15 11:02:25') RETURNING "id""#
    try (st = cn.prepareStmt(sql)) {
        if (let Update(ur) = st.execute()) {
            logger.debug("${ur.rowCount}, ${ur.lastInsertId}")
        }
    } catch (e: Exception) {
        logger.error(e.message)
        e.printStackTrace()
    }
}

func do_query_single(db: Datasource): Unit {
    let cn = db.connect()
    let sql = "SELECT * FROM public.change_logs ORDER BY id ASC"
    try (st = cn.prepareStmt(sql)) {
        if (let Query(qr) = st.execute()) {
            while (qr.next()) {
                logger.debug(
                    "${qr.getString(0)} ${qr.getTime(1)} ${qr.getString(2)} ${qr.getString(3)} ${qr.getString(6)}")
            }
            qr.close()
        }
    } catch (e: Exception) {
        logger.debug("exception ${e.message}")
        e.printStackTrace()
    }
}
func test_og(): Unit {
    var url = "opengauss://gorm:pass@7.212.133.32:5432/loggable?sslmode=disable"
    let db = sqlpool.openDb("opengauss", url)
    let p = db.ping()
    println("ping opengauss OK.")
    do_insert(db)
    do_query_single(db)
}
func test_pg(): Unit {
    logger.level = LogLevel.DEBUG
    var url = "postgres://gorm:pass@127.0.0.1:5432/loggable?sslmode=disable"
    let db = sqlpool.openDb("postgres", url)
    let p = db.ping()
    println("ping postgres OK.")
    do_insert(db)
    do_query_single(db)
}
main() {
	test_og()
	test_pg()
}