Back
table-exists? (clj)
(source)function
(table-exists? db table-name)
Checks whether the migrations table exists, by attempting to select from
it. Note that this appears to be the only truly portable way to determine
whether the table exists in a schema which the `db` configuration will find
via a `SELECT FROM` or `INSERT INTO` the table. (In particular, note that
attempting to find the table in the database meta-data as exposed by the JDBC
driver does *not* tell you whether the table is on the current schema search
path.)
Examples
migratus
;;;; Copyright © 2011 Paul Stadig
;;;;
;;;; Licensed under the Apache License, Version 2.0 (the "License"); you may not
;;;; use this file except in compliance with the License. You may obtain a copy
;;;; of the License at
;;;;
;;;; http://www.apache.org/licenses/LICENSE-2.0
;;;;
;;;; Unless required by applicable law or agreed to in writing, software
;;;; distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
;;;; WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
;;;; License for the specific language governing permissions and limitations
;;;; under the License.
(ns migratus.test.database
(:require [clojure.java.io :as io]
[next.jdbc :as jdbc]
[next.jdbc.result-set :as rs]
[next.jdbc.quoted :as q]
[next.jdbc.sql :as sql]
[migratus.protocols :as proto]
[migratus.core :as core]
[clojure.test :refer :all]
[migratus.database :refer :all :as db]
[clojure.tools.logging :as log]
[migratus.test.migration.edn :as test-edn]
[migratus.test.migration.sql :as test-sql]
[migratus.utils :as utils])
(:import java.io.File
java.sql.Connection
java.util.jar.JarFile
(java.util.concurrent CancellationException)))
(deftest test-make-store
(testing "should create default table name"
(is (not (test-sql/verify-table-exists?
(dissoc config :migration-table-name) default-migrations-table)))
(test-with-store
(proto/make-store (dissoc config :migration-table-name))
(fn [config]
(is (test-sql/verify-table-exists? config default-migrations-table)))))
(test-sql/reset-db)
(testing "should create schema_migrations table"
(is (not (test-sql/verify-table-exists? config "foo_bar")))
(test-with-store
(proto/make-store config)
(fn [config]
(is (test-sql/verify-table-exists? config "foo_bar")))))
(test-sql/reset-db)
(testing "should use complex table name"
(let [table-name "U&\"\\00d6ffnungszeit\""
config (assoc config :migration-table-name table-name)]
(is (not (test-sql/verify-table-exists? config table-name)))
(test-with-store
(proto/make-store config)
(fn [config]
(is (test-sql/verify-table-exists? config table-name)))))))
(deftest test-make-store-pass-conn
(testing "should create default table name"
(is (not (test-sql/verify-table-exists?
(dissoc config :migration-table-name) default-migrations-table)))
(test-with-store
(proto/make-store (-> (dissoc config :migration-table-name)
(assoc :db {:connection (jdbc/get-connection (:db config))})))
(fn [_]
(test-sql/verify-table-exists? (dissoc config :migration-table-name)
default-migrations-table))))
(test-sql/reset-db))
(deftest test-init
(testing "db init"
(let [config (assoc config :init-script "init.sql")]
(test-sql/reset-db)
(let [store (proto/make-store config)]
(proto/init store)
(is (test-sql/verify-table-exists? config "foo")))
(test-sql/reset-db)
(let [store (proto/make-store (assoc config :init-in-transaction? false))]
(proto/init store)
(is (test-sql/verify-table-exists? config "foo"))))))
(deftest test-migrate
(is (not (test-sql/verify-table-exists? config "foo")))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2")))
(core/migrate config)
(is (test-sql/verify-table-exists? config "foo"))
(is (test-sql/verify-table-exists? config "bar"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2"))
(core/down config 20111202110600)
(is (not (test-sql/verify-table-exists? config "foo")))
(is (test-sql/verify-table-exists? config "bar"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2"))
(core/migrate config)
(is (test-sql/verify-table-exists? config "foo"))
(is (test-sql/verify-table-exists? config "bar"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2"))
(core/down config 20111202110600 20120827170200)
(is (not (test-sql/verify-table-exists? config "foo")))
(is (test-sql/verify-table-exists? config "bar"))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2")))
(core/up config 20111202110600 20120827170200)
(is (test-sql/verify-table-exists? config "foo"))
(is (test-sql/verify-table-exists? config "bar"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2")))
(deftest test-migrate-with-modify-sql-fn
(is (not (test-sql/verify-table-exists? config "foo")))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2")))
(core/migrate (assoc config :modify-sql-fn comment-out-bar-statements))
(is (test-sql/verify-table-exists? config "foo"))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2")))
(deftest test-migrate-with-multi-statement-modify-sql-fn
(is (not (test-sql/verify-table-exists? config "foo")))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2")))
(core/migrate (assoc config :modify-sql-fn multi-bar-statements))
(is (test-sql/verify-table-exists? config "foo"))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (test-sql/verify-table-exists? config "bar1"))
(is (test-sql/verify-table-exists? config "bar2"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2")))
(deftest test-migrate-until-just-before
(is (not (test-sql/verify-table-exists? config "foo")))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2")))
(core/migrate-until-just-before config 20120827170200)
(is (test-sql/verify-table-exists? config "foo"))
(is (test-sql/verify-table-exists? config "bar"))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2")))
(core/migrate config)
(is (test-sql/verify-table-exists? config "foo"))
(is (test-sql/verify-table-exists? config "bar"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2")))
(deftest test-rollback-until-just-after
(core/migrate config)
(is (test-sql/verify-table-exists? config "foo"))
(is (test-sql/verify-table-exists? config "bar"))
(is (test-sql/verify-table-exists? config "quux"))
(is (test-sql/verify-table-exists? config "quux2"))
(core/rollback-until-just-after config 20111202110600)
(is (test-sql/verify-table-exists? config "foo"))
(is (not (test-sql/verify-table-exists? config "bar")))
(is (not (test-sql/verify-table-exists? config "quux")))
(is (not (test-sql/verify-table-exists? config "quux2"))))
(deftest test-migration-ignored-when-already-reserved
(test-with-store
(proto/make-store config)
(fn [{:keys [db migration-table-name] :as config}]
(testing "can only reserve once"
(is (mark-reserved db migration-table-name))
(is (not (mark-reserved db migration-table-name))))
(testing "migrations don't run when locked"
(is (not (test-sql/verify-table-exists? config "foo")))
(is (= :ignore (core/migrate config)))
(is (not (test-sql/verify-table-exists? config "foo"))))
(testing "migrations run once lock is freed"
(mark-unreserved db migration-table-name)
(is (nil? (core/migrate config)))
(is (test-sql/verify-table-exists? config "foo")))
(testing "rollback migration isn't run when locked"
(is (mark-reserved db migration-table-name))
(core/down config 20111202110600)
(is (test-sql/verify-table-exists? config "foo")))
(testing "rollback migration run once lock is freed"
(mark-unreserved db migration-table-name)
(core/down config 20111202110600)
(is (not (test-sql/verify-table-exists? config "foo")))))))
(is (not (test-sql/verify-table-exists? test-config "foo")))
(is (not (test-sql/verify-table-exists? test-config "bar")))
(is (not (test-sql/verify-table-exists? test-config "quux")))
(is (not (test-sql/verify-table-exists? test-config "quux2")))
(is (not (test-edn/test-file-exists?)))
(is (test-sql/verify-table-exists? test-config "foo"))
(is (test-sql/verify-table-exists? test-config "bar"))
(is (test-sql/verify-table-exists? test-config "quux"))
(is (test-sql/verify-table-exists? test-config "quux2"))
(is (test-edn/test-file-exists?))
(defn- test-backing-out* [test-config]
(let [{:keys [db migration-table-name]} test-config]
(testing "should fail")
(is (thrown? Throwable (core/migrate test-config)))
(testing "first statement in migration was backed out because second one failed")
(is (not (test-sql/verify-table-exists? test-config "quux2")))
(testing "third statement in migration was backed out because second one failed")
(is (not (test-sql/verify-table-exists? test-config "quux3")))
(testing "migration was not applied")
(is (not (complete? db migration-table-name 20120827170200)))
#_#_(testing "table should be unreserved after migration failure")
(is (false? (mark-reserved db migration-table-name)))))
(deftest test-no-tx-migration
(let [{:keys [db migration-table-name] :as test-config} (assoc config :migration-dir "migrations-no-tx")]
(is (not (test-sql/verify-table-exists? test-config "foo")))
(core/migrate test-config)
(is (test-sql/verify-table-exists? test-config "foo"))
(core/down test-config 20111202110600)
(is (not (test-sql/verify-table-exists? test-config "foo")))))
(deftest test-no-tx-migration-pass-conn
(with-open [conn (jdbc/get-connection (:db config))]
(let [test-config (assoc config
:migration-dir "migrations-no-tx"
:db {:connection conn :managed-connection? true})]
(is (not (test-sql/verify-table-exists? test-config "foo")))
(core/migrate test-config)
(is (test-sql/verify-table-exists? test-config "foo"))
(core/down test-config 20111202110600)
(is (not (test-sql/verify-table-exists? test-config "foo"))))))
migratus
(ns migratus.test.migration.sql
(:require [clojure.java.io :as io]
[clojure.test :refer :all]
[migratus.core :as core]
[migratus.database :as db]
[migratus.migration.sql :refer :all]
[next.jdbc :as jdbc]
[next.jdbc.result-set :as rs]))
(defn verify-table-exists? [config table-name]
(let [db (:db config)]
(db/table-exists? db table-name)))
(is (not (verify-table-exists? config "foo")))
(is (not (verify-table-exists? config "bar")))
(is (not (verify-table-exists? config "quux")))
(is (not (verify-table-exists? config "quux2")))
(is (verify-table-exists? config "foo"))
(is (verify-table-exists? config "bar"))
(is (verify-table-exists? config "quux"))
(is (verify-table-exists? config "quux2"))
(is (verify-table-exists? config "foo"))
(is (verify-table-exists? config "bar"))
(is (not (verify-table-exists? config "quux")))
(is (not (verify-table-exists? config "quux2")))))