Bolt

The wrapper library for executing INSERT/UPDATE/DELETE sql query on Google Cloud Spanner.

INSERT/UPDATE/DELETE Syntax

INSERT

UPDATE

DELETE

How to use

In Scala,

Write library dependency to .sbt file

libraryDependencies += "com.sopranoworks" %% "bolt" % "0.14"

And then,

import Bolt._

dbClinet.executeQuery("INSERT INTO test_tbl01 VALUES(103,'test insert');")

It uses implicit conversion.

You can use it as explicitly like this.

Nut(dbClient).executeQuery("INSERT INTO test_tbl01 VALUES(103,'test insert');")

A transaction query can be used as this.

dbClient.beginTransaction {
  tr =>
    tr.executeQuery("INSERT INTO test_tbl01 VALUES(103,'test insert');")
}

Other functions

ResultSet can be used as Iterator.

dbClient.executeQuery("SELECT * FROM test_tbl01").map {
  resultSet =>
    (resultSet.getString("id"),resultSet.getString("name"))
}

And also

dbClient.executeQuery("SELECT * FROM test_tbl01").headOption

You can use ResultSet safely like this.

dbClient.executeQuery("SELECT * FROM test_tbl01").autoclose(
  resultSet =>
      ...
)

In Java,

import com.sopranoworks.bolt.Bolt;

Bolt.Nut nut = Bolt.Nut(client);
nut.executeQuery("INSERT INTO TEST_TABLE (ID,NAME) VALUES(101,'test');");

spanner-cli

This project also contains console spanner client application, spanne-cli.

dist/spanner-cli-0.14.zip

MD5:c27ac438bdec370cbe78b3f148f71bb3

spanner-dump

This is a bonus program. It will dump a spanner database to sql text code.

dist/spanner-dump-0.14.zip

MD5:42c488cee2c40d77c46caa4042826433

Notice

A Nut instance is not thread safe. You must create a instance per thread.

Limitations

• Bytes type is currently not supported in an INSERT/UPDATE query.
• Only few functions are usable in an INSERT/UPDATE query.
• CASE Conditional expression is currently not supported in an INSERT/UPDATE query.
• UNNEST operation is currently not supported in an INSERT/UPDATE query.

There is no such a limitation in SELECT and subquery.

• Referencing outside (INSERT/UPDATE statement's) alias in subquery is not supported in an INSERT/UPDATE query.
• Some lterals are currently not supported.

Licence

MIT