pdo.phel

(ns phel\tests\pdo-initail
  (:require phel\test :refer [deftest is])
  (:require phel\pdo)
  (:require phel\pdo\statement))

(deftest test-initial
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (struct? conn))
    (is (not= nil conn))))

(deftest test-simple-select
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (let [stmt (pdo/query conn "select * from t1 where id = 1")]
      (is (= {:id 1 :name "phel"} (statement/fetch stmt))))))

(deftest test-simple-prepare-select
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (pdo/begin conn))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (is (pdo/commit conn))
    (let [stmt (pdo/query conn "select count(*) from t1 where id = 1")]
      (is (= 1 (statement/fetch-column stmt))))))

(deftest test-simple-prepare-select-with-params
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (pdo/begin conn))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (is (pdo/commit conn))
    (let [stmt (pdo/prepare conn "select count(*) from t1 where id = :id")
          stmt (statement/execute stmt {:id 1})]
      (is (= 1 (statement/fetch-column stmt))))))

(deftest test-simple-rollback
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (pdo/begin conn))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (is (pdo/rollback conn))
    (let [stmt (pdo/query conn "select count(*) from t1 where id = 1")]
      (is (= 0 (statement/fetch-column stmt))))))

(deftest test-simple-commit
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (pdo/begin conn))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (is (pdo/commit conn))
    (let [stmt (pdo/query conn "select count(*) from t1 where id = 1")]
      (is (= 1 (statement/fetch-column stmt))))))

(deftest test-quote
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= "'I''m fine.'" (pdo/quote conn "I'm fine.")))))

(deftest test-last-insert-id
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (is (= 1 (pdo/last-insert-id conn)))))

(deftest test-error-code
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (try
      (pdo/exec
        conn
        "insert into t1 (id, name) values (1, 'php')")
      (catch \PDOException e "error"))
    (is (= 23000 (pdo/error-code conn)))))

(deftest test-error-info
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= 0 (pdo/exec
               conn
               "create table t1 (id integer primary key autoincrement, name varchr(10))")))
    (is (= 1 (pdo/exec
               conn
               "insert into t1 (name) values ('phel')")))
    (try
      (pdo/exec
        conn
        "insert into t1 (id, name) values (1, 'php')")
      (catch \PDOException e "error"))
    (is (= [23000 19 "UNIQUE constraint failed: t1.id"] (pdo/error-info conn)))))

(deftest test-attribute
  (let [conn (pdo/connect "sqlite::memory:")]
    (pdo/set-attribute
               conn
               (php/:: \PDO ATTR_ERRMODE)
               (php/:: \PDO ERRMODE_SILENT))
    (is (= (php/:: \PDO ERRMODE_SILENT)
           (pdo/get-attribute
             conn
             (php/:: \PDO ATTR_ERRMODE))))))

(deftest test-in-transaction
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (= false (pdo/in-transaction conn)))
    (is (pdo/begin conn))
    (is (= true (pdo/in-transaction conn)))
    (is (pdo/commit conn))
    (is (= false (pdo/in-transaction conn)))))

(deftest test-get-available-drivers
  (let [conn (pdo/connect "sqlite::memory:")]
    (is (contains-value? (pdo/get-available-drivers conn) "sqlite"))))