Example of Executing Database Operation Statements

Inserting Data

import std.database.sql.*

main() {
    // Example of obtaining the database connection
    let drv = DriverManager.getDriver("opengauss") ?? return
    let ds = drv.open("opengauss://testuser:testpwd@localhost:5432/testdb", [])
    let conn = ds.connect()

    // Example one of inserting data
    var stmt = conn.prepareStatement("INSERT INTO test VALUES(?, ?)")
    stmt.set<String>(0, "li lei")
    stmt.set<Int32>(1, 12)
    var ur = stmt.update()
    println("Update Result: ${ur.rowCount} ${ur.lastInsertId}")

    // Example two of inserting data
    stmt.set<String>(0, "han meimei")
    stmt.set<Int32>(1, 13)
    ur = stmt.update()
    println("Update Result: ${ur.rowCount} ${ur.lastInsertId}")

    // Performs the following operations to return the inserted ID after data is inserted:
    let sql = "INSERT INTO test (name, age) VALUES (?,?) RETURNING id, name"
    try (stmt = conn.prepareStatement(sql)) {
        stmt.set<String>(0, "li lei")
        stmt.set<Int32>(1, 12)
        let qr = stmt.query()
        while (qr.next()) {
            println("id = ${qr.get<Int32>(0)}, name=${qr.get<String>(1)}")
        }
    } catch (e: Exception) {
        e.printStackTrace()
    }
    stmt.close()
}

Querying Data

import std.database.sql.*

main() {
    // Example of obtaining the database connection
    let drv = DriverManager.getDriver("opengauss") ?? return
    let ds = drv.open("opengauss://testuser:testpwd@localhost:5432/testdb", [])
    let conn = ds.connect()

    // Example of the query operation
    var stmt = conn.prepareStatement("select * from test where name = ?")
    stmt.set<String>(0, "li lei")
    let qr = stmt.query()
    while (qr.next()) {
        println("id = ${qr.get<Int32>(0)}, name = ${qr.get<String>(1)}, age=${qr.get<Int32>(2)}")
    }
    stmt.close()
}

Updating Data

import std.database.sql.*

main() {
    // Example of obtaining the database connection
    let drv = DriverManager.getDriver("opengauss") ?? return
    let ds = drv.open("opengauss://testuser:testpwd@localhost:5432/testdb", [])
    let conn = ds.connect()

    // Example of the update operation
    var stmt = conn.prepareStatement("update test set age = ? where name = ?")
    stmt.set<Int32>(0, 15)
    stmt.set<String>(1, "li lei")
    var ur = stmt.update()
    println("Update Result: ${ur.rowCount} ${ur.lastInsertId}")
    stmt.close()
}

Deleting Data

import std.database.sql.*

main() {
    // Example of obtaining the database connection
    let drv = DriverManager.getDriver("opengauss") ?? return
    let ds = drv.open("opengauss://testuser:testpwd@localhost:5432/testdb", [])
    let conn = ds.connect()

    // Example of the deletion operation
    var stmt = conn.prepareStatement("delete from test where name = ?")
    stmt.set<String>(0, "li lei")
    var ur = stmt.update()
    println("Update Result: ${ur.rowCount} ${ur.lastInsertId}")
    stmt.close()
}