Choose data engine to use

Fix setting data engine broken in commit "Rewrite client in a register
workload" 3214905 and add option validation.

Blocked by tarantool/tarantool-java#63

Closes #52

Author: ligurio

src/tarantool/counter.clj

@@ -28,6 +28,7 @@
       (Thread/sleep 10000) ; wait for leader election and joining to a cluster
       (when (= node (first (db/primaries test)))
         (cl/with-conn-failure-retry conn
+          (j/execute! conn [(str "SET SESSION \"sql_default_engine\" = '" (:engine test) "'")])
           (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
                             " (id INT NOT NULL PRIMARY KEY,
                             count INT NOT NULL)")]))

src/tarantool/register.clj

@@ -37,6 +37,7 @@
       (Thread/sleep 10000) ; wait for leader election and joining to a cluster
       (if (= node (first (db/primaries test)))
         (cl/with-conn-failure-retry conn
+          (j/execute! conn [(str "SET SESSION \"sql_default_engine\" = '" (:engine test) "'")])
           (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
                             " (id INT NOT NULL PRIMARY KEY,
                             value INT NOT NULL)")])

src/tarantool/runner.clj

@@ -26,6 +26,10 @@
 (def minimal-concurrency
   10)
 
+(def engines
+  "Types of engines."
+  #{:memtx :vinyl})
+
 (def workloads
   "A map of workload names to functions that can take opts and construct
   workloads.
@@ -96,7 +100,9 @@
      :validate [#(and (number? %) (pos? %)) "must be a positive number"]]
     ["-e" "--engine NAME"
      "What Tarantool data engine should we use?"
-     :default "memtx"]])
+     :parse-fn keyword
+     :validate [engines (cli/one-of engines)]
+     :default :memtx]])
 
 (def test-all-opts
   "Command line options for testing everything."
@@ -178,7 +184,7 @@
             :name      (str "tarantool-" (:version opts))
             :os        ubuntu/os
             :db        (db/db (:version opts))
-            :engine    (:engine opts)
+            :engine    (name (:engine opts))
             :mvcc      (:mvcc opts)
             :pure-generators true
             :concurrency (if (and (< (:concurrency opts) minimal-concurrency)

src/tarantool/sets.clj

@@ -30,6 +30,7 @@
       (Thread/sleep 10000) ; wait for leader election and joining to a cluster
       (if (= node (first (db/primaries test)))
         (cl/with-conn-failure-retry conn
+          (j/execute! conn [(str "SET SESSION \"sql_default_engine\" = '" (:engine test) "'")])
           (j/execute! conn [(str "CREATE TABLE IF NOT EXISTS " table-name
                             " (id INT NOT NULL PRIMARY KEY AUTOINCREMENT,
                             value INT NOT NULL)")])