pg: add binding for PQfinish (close) (#6435)
parent
e429a77de2
commit
21c5ff681b
|
@ -37,6 +37,7 @@ fn C.PQnfields(voidptr) int
|
||||||
fn C.PQexec(voidptr) voidptr
|
fn C.PQexec(voidptr) voidptr
|
||||||
fn C.PQexecParams(voidptr) voidptr
|
fn C.PQexecParams(voidptr) voidptr
|
||||||
fn C.PQclear(voidptr) voidptr
|
fn C.PQclear(voidptr) voidptr
|
||||||
|
fn C.PQfinish(voidptr)
|
||||||
|
|
||||||
pub fn connect(config Config) ?DB {
|
pub fn connect(config Config) ?DB {
|
||||||
conninfo := 'host=$config.host port=$config.port user=$config.user dbname=$config.dbname password=$config.password'
|
conninfo := 'host=$config.host port=$config.port user=$config.user dbname=$config.dbname password=$config.password'
|
||||||
|
@ -67,6 +68,11 @@ fn res_to_rows(res voidptr) []Row {
|
||||||
return rows
|
return rows
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// close frees the underlaying resource allocated by the database connection
|
||||||
|
pub fn (db DB) close() {
|
||||||
|
C.PQfinish(db.conn)
|
||||||
|
}
|
||||||
|
|
||||||
pub fn (db DB) q_int(query string) int {
|
pub fn (db DB) q_int(query string) int {
|
||||||
rows := db.exec(query)
|
rows := db.exec(query)
|
||||||
if rows.len == 0 {
|
if rows.len == 0 {
|
||||||
|
|
Loading…
Reference in New Issue