From 246b6e3ae0eb21406c7029db9d20afa8a060543d Mon Sep 17 00:00:00 2001 From: Bung <535670947@qq.com> Date: Sat, 23 May 2020 01:24:52 +0800 Subject: [PATCH] add insert,tryInsert unify for postgres that need pk name (#14416) * add insert,tryInsert unify for postgres that need pk name * add ReadDbEffect to new procs * add .since and changelog * change since to 1.3 * Update src/db_postgres.nim Co-authored-by: bung87 Co-authored-by: Andreas Rumpf Co-authored-by: alaviss --- src/db_odbc.nim | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/src/db_odbc.nim b/src/db_odbc.nim index 9ff050bfa3..863cf6c8c5 100644 --- a/src/db_odbc.nim +++ b/src/db_odbc.nim @@ -92,6 +92,8 @@ import strutils, odbcsql import db_common export db_common +import std/private/since + type OdbcConnTyp = tuple[hDb: SqlHDBC, env: SqlHEnv, stmt: SqlHStmt] DbConn* = OdbcConnTyp ## encapsulates a database connection @@ -451,6 +453,19 @@ proc insertId*(db: var DbConn, query: SqlQuery, result = tryInsertID(db, query, args) if result < 0: dbError(db) +proc tryInsert*(db: var DbConn, query: SqlQuery,pkName: string, + args: varargs[string, `$`]): int64 + {.tags: [ReadDbEffect, WriteDbEffect], raises: [], since: (1, 3).} = + ## same as tryInsertID + tryInsertID(db, query, args) + +proc insert*(db: var DbConn, query: SqlQuery, pkName: string, + args: varargs[string, `$`]): int64 + {.tags: [ReadDbEffect, WriteDbEffect], since: (1, 3).} = + ## same as insertId + result = tryInsert(db, query,pkName, args) + if result < 0: dbError(db) + proc execAffectedRows*(db: var DbConn, query: SqlQuery, args: varargs[string, `$`]): int64 {. tags: [ReadDbEffect, WriteDbEffect], raises: [DbError].} =