squash

adapter-jdbc/src/main/java/io/nosqlbench/adapter/jdbc/JDBCOpMapper.java

@@ -70,7 +70,7 @@ public class JDBCOpMapper implements OpMapper<JDBCOp> {
 
                 // SELECT uses 'executeQuery' and returns a 'ResultSet'
                 // https://jdbc.postgresql.org/documentation/query/#example51processing-a-simple-query-in-jdbc
-                case executeQuery ->
+                case query ->
                     new JDBCExecuteQueryOpDispenser(adapter, connectionLongFunc, op, opType.targetFunction);
 
                 // INSERT|UPDATE|DELETE uses 'executeUpdate' and returns an 'int'
@@ -78,7 +78,7 @@ public class JDBCOpMapper implements OpMapper<JDBCOp> {
 
                 // CREATE|DROP TABLE|VIEW uses 'execute' (as opposed to 'executeQuery' which returns a 'ResultSet')
                 // https://jdbc.postgresql.org/documentation/query/#example54dropping-a-table-in-jdbc
-                case execute, executeUpdate ->
+                case execute, update ->
                     new JDBCExecuteOpDispenser(adapter, connectionLongFunc, op, opType.targetFunction);
             };
         }

adapter-jdbc/src/main/java/io/nosqlbench/adapter/jdbc/JDBCOpType.java

@@ -26,6 +26,6 @@ package io.nosqlbench.adapter.jdbc;
 public enum JDBCOpType {
     //See https://jdbc.postgresql.org/documentation/query/
     execute, // Used for CREATE|DROP DATABASE|TABLE operation. Returns nothing.
-    executeQuery, // Used for SELECT operation. Returns a ResultSet object.
-    executeUpdate // Used for updating records such as INSERT|UPDATE|DELETE. Returns the number of rows affected.
+    query, // Used for SELECT operation. Returns a ResultSet object.
+    update // Used for updating records such as INSERT|UPDATE|DELETE. Returns the number of rows affected.
 }

adapter-jdbc/src/main/java/io/nosqlbench/adapter/jdbc/JDBCSpace.java

@@ -129,45 +129,113 @@ public class JDBCSpace implements AutoCloseable {
 
     public static NBConfigModel getConfigModel() {
         return ConfigModel.of(JDBCSpace.class)
-            .add(Param.defaultTo("url", "jdbc:postgresql:/").setDescription("The connection URL used to connect to the DBMS. Defaults to 'jdbc:postgresql:/'"))
-            .add(Param.defaultTo("serverName", "localhost").setDescription("The host name of the server. Defaults to 'localhost'"))
-            .add(Param.optional("databaseName").setDescription("The database name. The default is to connect to a database with the same name as the user name used to connect to the server."))
+            .add(Param.defaultTo("url", "jdbc:postgresql:/")
+                .setDescription("The connection URL used to connect to the DBMS. Defaults to 'jdbc:postgresql:/'"))
+            .add(Param.defaultTo("serverName", "localhost")
+                .setDescription("The host name of the server. Defaults to 'localhost'"))
+            .add(Param.optional("databaseName")
+                .setDescription("The database name. The default is to connect to a database with the same name as the user name used to connect to the server."))
             // See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby & https://jdbc.postgresql.org/documentation/use/
-            .add(Param.defaultTo("portNumber", "5432").setDescription("The port number the server is listening on. Defaults to the PostgreSQL® standard port number (5432)."))
-            .add(Param.optional("user").setDescription("The database user on whose behalf the connection is being made."))
-            .add(Param.optional("password").setDescription("The database user’s password."))
-            .add(Param.optional("ssl").setDescription("Whether to connect using SSL. Default is false."))
-            .add(Param.optional("sslmode").setDescription("Possible values include disable , allow , prefer , require , verify-ca and verify-full . require , allow and prefer all default to a non-validating SSL factory and do not check the validity of the certificate or the host name. verify-ca validates the certificate, but does not verify the hostname. verify-full will validate that the certificate is correct and verify the host connected to has the same hostname as the certificate. Default is prefer."))
-            .add(Param.optional("sslcert").setDescription("Provide the full path for the certificate file. Defaults to defaultdir/postgresql.crt, where defaultdir is ${user.home}/.postgresql/ in *nix systems and %appdata%/postgresql/ on windows."))
-            .add(Param.optional("sslrootcert").setDescription("File name of the SSL root certificate."))
-            .add(Param.defaultTo("applicationName", "NoSQLBench").setDescription("The application name to be used. Default is 'NoSQLBench'."))
-            .add(Param.optional("rewriteBatchedInserts").setDescription("This will change batch inserts from insert into foo (col1, col2, col3) values (1, 2, 3) into insert into foo (col1, col2, col3) values (1, 2, 3), (4, 5, 6) this provides 2-3x performance improvement. Default is true"))
-            .add(Param.optional("autoCommit").setDescription("This property controls the default auto-commit behavior of connections returned from the pool. It is a boolean value. Default: false. This cannot be changed."))
-            .add(Param.optional("connectionTimeout").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("idleTimeout").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.defaultTo("keepaliveTime", "150000").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("maxLifetime").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("connectionTestQuery").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("minimumIdle").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.defaultTo("maximumPoolSize", "40").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. Default value is 40 and cannot be changed."))
-            .add(Param.optional("metricRegistry").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("healthCheckRegistry").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("poolName").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("initializationFailTimeout").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("isolateInternalQueries").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("allowPoolSuspension").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("readOnly").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("registerMbeans").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("catalog").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("connectionInitSql").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("driverClassName").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("transactionIsolation").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("validationTimeout").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("leakDetectionThreshold").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("dataSource").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("schema").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("threadFactory").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
-            .add(Param.optional("scheduledExecutor").setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. This property is not exposed and hence cannot be changed."))
+            .add(Param.defaultTo("portNumber", "5432")
+                .setDescription("The port number the server is listening on. Defaults to the PostgreSQL® standard port number (5432)."))
+            .add(Param.optional("user")
+                .setDescription("The database user on whose behalf the connection is being made."))
+            .add(Param.optional("password")
+                .setDescription("The database user’s password."))
+            .add(Param.optional("ssl")
+                .setDescription("Whether to connect using SSL. Default is false."))
+            .add(Param.optional("sslmode")
+                .setDescription("Possible values include disable , allow , prefer , require , verify-ca and verify-full." +
+                    " require , allow and prefer all default to a non-validating SSL factory and do not check the validity of the certificate or the host name." +
+                    " verify-ca validates the certificate, but does not verify the hostname." +
+                    " verify-full will validate that the certificate is correct and verify the host connected to has the same hostname as the certificate." +
+                    " Default is prefer."))
+            .add(Param.optional("sslcert")
+                .setDescription("Provide the full path for the certificate file. Defaults to defaultdir/postgresql.crt, where defaultdir is ${user.home}/.postgresql/ in *nix systems and %appdata%/postgresql/ on windows."))
+            .add(Param.optional("sslrootcert")
+                .setDescription("File name of the SSL root certificate."))
+            .add(Param.defaultTo("applicationName", "NoSQLBench")
+                .setDescription("The application name to be used. Default is 'NoSQLBench'."))
+            .add(Param.optional("rewriteBatchedInserts")
+                .setDescription("This will change batch inserts from insert into foo (col1, col2, col3) values (1, 2, 3) into insert into foo (col1, col2, col3) values (1, 2, 3), (4, 5, 6) this provides 2-3x performance improvement. " +
+                    "Default is true"))
+            .add(Param.optional("autoCommit")
+                .setDescription("This property controls the default auto-commit behavior of connections returned from the pool. " +
+                    "It is a boolean value. Default: false. This cannot be changed."))
+            .add(Param.optional("connectionTimeout")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("idleTimeout")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.defaultTo("keepaliveTime", "150000")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("maxLifetime")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("connectionTestQuery")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("minimumIdle")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.defaultTo("maximumPoolSize", "40")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. Default value is 40 and cannot be changed."))
+            .add(Param.optional("metricRegistry")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("healthCheckRegistry")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("poolName")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("initializationFailTimeout")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("isolateInternalQueries")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("allowPoolSuspension")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("readOnly")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("registerMbeans")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("catalog")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("connectionInitSql")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("driverClassName")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("transactionIsolation")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("validationTimeout")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("leakDetectionThreshold")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("dataSource")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("schema")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("threadFactory")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
+            .add(Param.optional("scheduledExecutor")
+                .setDescription("See https://github.com/brettwooldridge/HikariCP/tree/dev#gear-configuration-knobs-baby for details. " +
+                     "This property is not exposed and hence cannot be changed."))
             .asReadOnly();
     }
 

adapter-jdbc/src/main/resources/activities.baselinesv2/cockroachdb-keyvalue.yaml

@@ -41,7 +41,7 @@ blocks:
     params:
     ops:
       rampup-insert:
-        executeUpdate: |
+        update: |
           INSERT INTO TEMPLATE(database,baselines).TEMPLATE(table,keyvalue)
           (key, value) VALUES ({seq_key},{seq_value});
 
@@ -50,13 +50,13 @@ blocks:
       ratio: TEMPLATE(read_ratio,5)
     ops:
       main-select:
-        executeQuery: |
+        query: |
           SELECT * FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,keyvalue) WHERE key='{rw_key}';
   main-write:
     params:
       ratio: TEMPLATE(write_ratio,5)
     ops:
       main-insert:
-        executeUpdate: |
+        update: |
           INSERT INTO TEMPLATE(keyspace,baselines).TEMPLATE(table,keyvalue)
           (key, value) VALUES ('{rw_key}', '{rw_value}');

adapter-jdbc/src/main/resources/activities.baselinesv2/cockroachdb-tabular.yaml

@@ -88,7 +88,7 @@ blocks:
     params:
     ops:
       rampup-insert:
-        executeUpdate: |
+        update: |
           INSERT INTO TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           (part,clust,data0,data1,data2,data3,data4,data5,data6,data7)
           VALUES (
@@ -101,7 +101,7 @@ blocks:
       cl: TEMPLATE(read_cl,LOCAL_QUORUM)
     ops:
       verify-select:
-        executeQuery: |
+        query: |
           SELECT * FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_layout}'
           AND clust='{clust_layout}'
@@ -111,35 +111,35 @@ blocks:
       ratio: TEMPLATE(read_ratio,1)
     ops:
       main-select-all:
-        executeQuery: |
+        query: |
           SELECT * FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select-01:
-        executeQuery: |
+        query: |
           SELECT data0,data1 from TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select-0246:
-        executeQuery: |
+        query: |
           SELECT data0,data2,data4,data6 FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select-1357:
-        executeQuery: |
+        query: |
           SELECT data1,data3,data5,data7 FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select-0123:
-        executeQuery: |
+        query: |
           SELECT data0,data1,data2,data3 FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select-4567:
-        executeQuery: |
+        query: |
           SELECT data4,data5,data6,data7 FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select-67:
-        executeQuery: |
+        query: |
           SELECT data6,data7 FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
       main-select:
-        executeQuery: |
+        query: |
           SELECT data0,data1,data2,data3,data4,data5,data6,data7
           FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           WHERE part='{part_read}' LIMIT {limit};
@@ -148,7 +148,7 @@ blocks:
       ratio: TEMPLATE(write_ratio,8)
     ops:
       main-write:
-        executeUpdate: |
+        update: |
           INSERT INTO TEMPLATE(keyspace,baselines).TEMPLATE(table,tabular)
           (part, clust, data0,data1,data2,data3,data4,data5,data6,data7)
           VALUES (

adapter-jdbc/src/main/resources/activities.baselinesv2/cockroachdb-timeseries.yaml

@@ -51,7 +51,7 @@ blocks:
     params:
     ops:
       insert-rampup:
-        executeUpdate: |
+        update: |
           INSERT INTO TEMPLATE(keyspace,baselines).TEMPLATE(table,iot)
           (machine_id, sensor_name, time, sensor_value, station_id, data)
           VALUES (
@@ -65,7 +65,7 @@ blocks:
       ratio: TEMPLATE(read_ratio,1)
     ops:
       select-read:
-        executeQuery: |
+        query: |
           SELECT * FROM TEMPLATE(keyspace,baselines).TEMPLATE(table,iot)
           WHERE machine_id='{machine_id}' and sensor_name='{sensor_name}'
           LIMIT TEMPLATE(limit,10);
@@ -74,7 +74,7 @@ blocks:
       ratio: TEMPLATE(write_ratio,9)
     ops:
       insert-main:
-        executeUpdate: |
+        update: |
           INSERT INTO TEMPLATE(keyspace,baselines).TEMPLATE(table,iot)
           (machine_id, sensor_name, time, sensor_value, station_id, data)
           VALUES (

adapter-jdbc/src/main/resources/jdbc.md

@@ -19,10 +19,32 @@ Other NB engine parameters are straight forward:
 * `<nb_cmd>`: is `./nb` (using binary) or the `java -jar nb5.jar`.
 
 # Configuration
-There are the below main configuratios with which we could issue a query and process the results back based on the [PostgreSQL® Query](https://jdbc.postgresql.org/documentation/query/) pattern.
+These are the main configurations with which we could issue a query and process the results back based on the [PostgreSQL® Query](https://jdbc.postgresql.org/documentation/query/) pattern.
 ## Config Sources
 * `execute`: This is to issue any DDL statements such `CREATE DATABASE|TABLE` or `DROP DATABASE|TABLE` operations which returns nothing.
-* `executeQuery`: This is to issue DML statement such as `SELECT` operation which would return a `ResultSet` object to process.
-* `executeUpdate`: This is to issue DML statements such as `INSERT|UPDATE|DELETE` operations that will return how many number of rows were affected by that operation.
+* `query`: This is to issue DML statement such as `SELECT` operation which would return a `ResultSet` object to process.
+* `update`: This is to issue DML statements such as `INSERT|UPDATE|DELETE` operations that will return how many number of rows were affected by that operation.
+
+## Statement Forms
+The syntax for specifying these types is simplified as well, using only a single `type` field which allows values of `execute`, `query`, & `update`
+and specifying the raw statements in the `stmt`. Alternatively, one could directly use one of the types and provide the raw query directly.
+
 ### Examples
 Check out the default activities under the [activities.baselinesv2](./activities.baselinesv2) directory.
+#### Op Template Examples
+````yaml
+ops:
+  drop-database:
+    type: execute
+    stmt: |
+      DROP DATABASE IF EXISTS TEMPLATE(database,baselines);
+  create-table:
+    execute: |
+      CREATE TABLE IF NOT EXISTS TEMPLATE(database,baselines).TEMPLATE(table,keyvalue);
+  select-table:
+    query: |
+      SELECT one, two, three FROM TEMPLATE(database,baselines).TEMPLATE(table,keyvalue) WHERE ...;
+  insert-table:
+    update: |
+      UPDATE TABLE TEMPLATE(database,baselines).TEMPLATE(table,keyvalue) SET key = 'value' WHERE ...;
+````