test: add integration test

Author: grdsdev

Sources/Sqlite/Sqlite.swift

@@ -30,8 +30,7 @@ public final class Sqlite {
     )
   }
 
-  @discardableResult
-  public func run(_ sql: String, _ bindings: Datatype...) throws -> [[Datatype]] {
+  public func run(_ sql: String, _ bindings: [Datatype]) throws -> [[Datatype]] {
     var stmt: OpaquePointer?
     try self.validate(sqlite3_prepare_v2(self.handle, sql, -1, &stmt, nil))
     defer { sqlite3_finalize(stmt) }
@@ -74,6 +73,11 @@ public final class Sqlite {
     return rows
   }
 
+  @discardableResult
+  public func run(_ sql: String, _ bindings: Datatype...) throws -> [[Datatype]] {
+    try self.run(sql, bindings)
+  }
+
   public var lastInsertRowid: Int64 {
     sqlite3_last_insert_rowid(self.handle)
   }
@@ -105,3 +109,40 @@ extension Sqlite.Error {
     self.description = String(cString: sqlite3_errstr(code))
   }
 }
+
+extension Sqlite.Datatype {
+
+  public var blobValue: [UInt8]? {
+    guard case let .blob(value) = self else {
+      return nil
+    }
+
+    return value
+  }
+
+  public var integerValue: Int64? {
+    guard case let .integer(value) = self else {
+      return nil
+    }
+
+    return value
+  }
+
+  public var realValue: Double? {
+    guard case let .real(value) = self else {
+      return nil
+    }
+
+    return value
+  }
+
+  public var textValue: String? {
+    guard case let .text(value) = self else {
+      return nil
+    }
+
+    return value
+  }
+
+  public var isNull: Bool { self == .null }
+}

Tests/SqliteTests/SqliteTests.swift

@@ -3,4 +3,76 @@ import XCTest
 @testable import Sqlite
 
 final class SqliteTests: XCTestCase {
+
+  func test_Sqlite_CreateTable_InsertAndQueryData() throws {
+    let sqlite = try Sqlite(path: "")
+
+    try sqlite.execute(
+      """
+          CREATE TABLE IF NOT EXISTS "logs" (
+            "id" INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL UNIQUE,
+            "inserted_at" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+            "level" INTEGER NOT NULL,
+            "msg" TEXT
+          );
+      """)
+
+    try Log.create(in: sqlite, level: .warning, msg: "This is a warning message")
+    try Log.create(in: sqlite, level: .error, msg: "This is an error message")
+
+    let allLogs = try Log.fetchAll(in: sqlite)
+
+    XCTAssertEqual(allLogs.count, 2)
+
+    XCTAssertEqual(allLogs[0].level, .warning)
+    XCTAssertEqual(allLogs[0].msg, "This is a warning message")
+
+    XCTAssertEqual(allLogs[1].level, .error)
+    XCTAssertEqual(allLogs[1].msg, "This is an error message")
+  }
+}
+
+struct Log {
+  let id: Int64
+  let insertedAt: Date
+  let level: Level
+  let msg: String
+
+  enum Level: Int {
+    case warning, error
+  }
+
+  static func create(in sqlite: Sqlite, level: Level, msg: String) throws {
+    try sqlite.run(
+      """
+          INSERT INTO "logs" (
+              "level", "msg"
+          )
+          VALUES (
+              ?, ?
+          );
+      """,
+      .integer(Int64(level.rawValue)),
+      .text(msg)
+    )
+  }
+
+  static func fetchAll(in sqlite: Sqlite) throws -> [Log] {
+    try sqlite.run(
+      """
+      SELECT
+          "id", "inserted_at", "level", "msg"
+      FROM
+          "logs"
+      """
+    )
+    .map { row in
+      Log(
+        id: row[0].integerValue ?? 0,
+        insertedAt: row[1].realValue.flatMap(Date.init(timeIntervalSince1970:)) ?? Date(),
+        level: row[2].integerValue.map { Int($0) }.flatMap(Level.init(rawValue:)) ?? .warning,
+        msg: row[3].textValue ?? ""
+      )
+    }
+  }
 }