summary refs log tree commit diff stats
path: root/lib/impure/db_sqlite.nim
diff options
context:
space:
mode:
authorAdam Strzelecki <ono@java.pl>2015-09-04 23:03:56 +0200
committerAdam Strzelecki <ono@java.pl>2015-09-04 23:03:56 +0200
commit43bddf62dd982e64cd7350eabbbc5d04c5adab21 (patch)
tree30d912ddcdf47201ea5b650d8a0064949fc0472e /lib/impure/db_sqlite.nim
parentd68181246571de5799059cf6402f1c578cd9421c (diff)
downloadNim-43bddf62dd982e64cd7350eabbbc5d04c5adab21.tar.gz
lib: Trim .nim files trailing whitespace
via OSX: find . -name '*.nim' -exec sed -i '' -E 's/[[:space:]]+$//' {} +
Diffstat (limited to 'lib/impure/db_sqlite.nim')
-rw-r--r--lib/impure/db_sqlite.nim84
1 files changed, 42 insertions, 42 deletions
diff --git a/lib/impure/db_sqlite.nim b/lib/impure/db_sqlite.nim
index 1a037becc..66276e9a4 100644
--- a/lib/impure/db_sqlite.nim
+++ b/lib/impure/db_sqlite.nim
@@ -7,7 +7,7 @@
 #    distribution, for details about the copyright.
 #
 
-## A higher level `SQLite`:idx: database wrapper. This interface 
+## A higher level `SQLite`:idx: database wrapper. This interface
 ## is implemented for other databases too.
 
 import strutils, sqlite3
@@ -19,31 +19,31 @@ type
   InstantRow* = Pstmt  ## a handle that can be used to get a row's column
                        ## text on demand
   EDb* = object of IOError ## exception that is raised if a database error occurs
-  
+
   SqlQuery* = distinct string ## an SQL query string
-  
+
   FDb* = object of IOEffect ## effect that denotes a database operation
   FReadDb* = object of FDb   ## effect that denotes a read operation
   FWriteDb* = object of FDb  ## effect that denotes a write operation
 {.deprecated: [TRow: Row, TSqlQuery: SqlQuery, TDbConn: DbConn].}
-  
-proc sql*(query: string): SqlQuery {.noSideEffect, inline.} =  
-  ## constructs a SqlQuery from the string `query`. This is supposed to be 
+
+proc sql*(query: string): SqlQuery {.noSideEffect, inline.} =
+  ## constructs a SqlQuery from the string `query`. This is supposed to be
   ## used as a raw-string-literal modifier:
   ## ``sql"update user set counter = counter + 1"``
   ##
-  ## If assertions are turned off, it does nothing. If assertions are turned 
+  ## If assertions are turned off, it does nothing. If assertions are turned
   ## on, later versions will check the string for valid syntax.
   result = SqlQuery(query)
- 
-proc dbError(db: DbConn) {.noreturn.} = 
+
+proc dbError(db: DbConn) {.noreturn.} =
   ## raises an EDb exception.
   var e: ref EDb
   new(e)
   e.msg = $sqlite3.errmsg(db)
   raise e
 
-proc dbError*(msg: string) {.noreturn.} = 
+proc dbError*(msg: string) {.noreturn.} =
   ## raises an EDb exception with message `msg`.
   var e: ref EDb
   new(e)
@@ -67,8 +67,8 @@ proc dbFormat(formatstr: SqlQuery, args: varargs[string]): string =
       inc(a)
     else:
       add(result, c)
-  
-proc tryExec*(db: DbConn, query: SqlQuery, 
+
+proc tryExec*(db: DbConn, query: SqlQuery,
               args: varargs[string, `$`]): bool {.tags: [FReadDb, FWriteDb].} =
   ## tries to execute the query and returns true if successful, false otherwise.
   var q = dbFormat(query, args)
@@ -81,32 +81,32 @@ proc exec*(db: DbConn, query: SqlQuery, args: varargs[string, `$`])  {.
   tags: [FReadDb, FWriteDb].} =
   ## executes the query and raises EDB if not successful.
   if not tryExec(db, query, args): dbError(db)
-  
+
 proc newRow(L: int): Row =
   newSeq(result, L)
   for i in 0..L-1: result[i] = ""
-  
-proc setupQuery(db: DbConn, query: SqlQuery, 
-                args: varargs[string]): Pstmt = 
+
+proc setupQuery(db: DbConn, query: SqlQuery,
+                args: varargs[string]): Pstmt =
   var q = dbFormat(query, args)
   if prepare_v2(db, q, q.len.cint, result, nil) != SQLITE_OK: dbError(db)
-  
+
 proc setRow(stmt: Pstmt, r: var Row, cols: cint) =
   for col in 0..cols-1:
     setLen(r[col], column_bytes(stmt, col)) # set capacity
     setLen(r[col], 0)
     let x = column_text(stmt, col)
     if not isNil(x): add(r[col], x)
-  
+
 iterator fastRows*(db: DbConn, query: SqlQuery,
                    args: varargs[string, `$`]): Row  {.tags: [FReadDb].} =
-  ## executes the query and iterates over the result dataset. This is very 
+  ## executes the query and iterates over the result dataset. This is very
   ## fast, but potenially dangerous: If the for-loop-body executes another
   ## query, the results can be undefined. For Sqlite it is safe though.
   var stmt = setupQuery(db, query, args)
   var L = (column_count(stmt))
   var result = newRow(L)
-  while step(stmt) == SQLITE_ROW: 
+  while step(stmt) == SQLITE_ROW:
     setRow(stmt, result, L)
     yield result
   if finalize(stmt) != SQLITE_OK: dbError(db)
@@ -136,31 +136,31 @@ proc getRow*(db: DbConn, query: SqlQuery,
   var stmt = setupQuery(db, query, args)
   var L = (column_count(stmt))
   result = newRow(L)
-  if step(stmt) == SQLITE_ROW: 
+  if step(stmt) == SQLITE_ROW:
     setRow(stmt, result, L)
   if finalize(stmt) != SQLITE_OK: dbError(db)
 
-proc getAllRows*(db: DbConn, query: SqlQuery, 
+proc getAllRows*(db: DbConn, query: SqlQuery,
                  args: varargs[string, `$`]): seq[Row] {.tags: [FReadDb].} =
   ## executes the query and returns the whole result dataset.
   result = @[]
   for r in fastRows(db, query, args):
     result.add(r)
 
-iterator rows*(db: DbConn, query: SqlQuery, 
+iterator rows*(db: DbConn, query: SqlQuery,
                args: varargs[string, `$`]): Row {.tags: [FReadDb].} =
   ## same as `FastRows`, but slower and safe.
   for r in fastRows(db, query, args): yield r
 
-proc getValue*(db: DbConn, query: SqlQuery, 
-               args: varargs[string, `$`]): string {.tags: [FReadDb].} = 
+proc getValue*(db: DbConn, query: SqlQuery,
+               args: varargs[string, `$`]): string {.tags: [FReadDb].} =
   ## executes the query and returns the first column of the first row of the
   ## result dataset. Returns "" if the dataset contains no rows or the database
   ## value is NULL.
   var stmt = setupQuery(db, query, args)
   if step(stmt) == SQLITE_ROW:
     let cb = column_bytes(stmt, 0)
-    if cb == 0: 
+    if cb == 0:
       result = ""
     else:
       result = newStringOfCap(cb)
@@ -168,12 +168,12 @@ proc getValue*(db: DbConn, query: SqlQuery,
   else:
     result = ""
   if finalize(stmt) != SQLITE_OK: dbError(db)
-  
-proc tryInsertID*(db: DbConn, query: SqlQuery, 
+
+proc tryInsertID*(db: DbConn, query: SqlQuery,
                   args: varargs[string, `$`]): int64
                   {.tags: [FWriteDb], raises: [].} =
-  ## executes the query (typically "INSERT") and returns the 
-  ## generated ID for the row or -1 in case of an error. 
+  ## executes the query (typically "INSERT") and returns the
+  ## generated ID for the row or -1 in case of an error.
   var q = dbFormat(query, args)
   var stmt: sqlite3.Pstmt
   result = -1
@@ -183,27 +183,27 @@ proc tryInsertID*(db: DbConn, query: SqlQuery,
     if finalize(stmt) != SQLITE_OK:
       result = -1
 
-proc insertID*(db: DbConn, query: SqlQuery, 
-               args: varargs[string, `$`]): int64 {.tags: [FWriteDb].} = 
-  ## executes the query (typically "INSERT") and returns the 
+proc insertID*(db: DbConn, query: SqlQuery,
+               args: varargs[string, `$`]): int64 {.tags: [FWriteDb].} =
+  ## executes the query (typically "INSERT") and returns the
   ## generated ID for the row. For Postgre this adds
   ## ``RETURNING id`` to the query, so it only works if your primary key is
-  ## named ``id``. 
+  ## named ``id``.
   result = tryInsertID(db, query, args)
   if result < 0: dbError(db)
-  
-proc execAffectedRows*(db: DbConn, query: SqlQuery, 
+
+proc execAffectedRows*(db: DbConn, query: SqlQuery,
                        args: varargs[string, `$`]): int64 {.
-                       tags: [FReadDb, FWriteDb].} = 
+                       tags: [FReadDb, FWriteDb].} =
   ## executes the query (typically "UPDATE") and returns the
   ## number of affected rows.
   exec(db, query, args)
   result = changes(db)
 
-proc close*(db: DbConn) {.tags: [FDb].} = 
+proc close*(db: DbConn) {.tags: [FDb].} =
   ## closes the database connection.
   if sqlite3.close(db) != SQLITE_OK: dbError(db)
-    
+
 proc open*(connection, user, password, database: string): DbConn {.
   tags: [FDb].} =
   ## opens a database connection. Raises `EDb` if the connection could not
@@ -216,12 +216,12 @@ proc open*(connection, user, password, database: string): DbConn {.
 
 proc setEncoding*(connection: DbConn, encoding: string): bool {.
   tags: [FDb].} =
-  ## sets the encoding of a database connection, returns true for 
+  ## sets the encoding of a database connection, returns true for
   ## success, false for failure.
   ##
   ## Note that the encoding cannot be changed once it's been set.
-  ## According to SQLite3 documentation, any attempt to change 
-  ## the encoding after the database is created will be silently 
+  ## According to SQLite3 documentation, any attempt to change
+  ## the encoding after the database is created will be silently
   ## ignored.
   exec(connection, sql"PRAGMA encoding = ?", [encoding])
   result = connection.getValue(sql"PRAGMA encoding") == encoding