org.jsimpledb.kv.cockroach

Class CockroachKVDatabase

java.lang.Object

org.jsimpledb.kv.sql.SQLKVDatabase

org.jsimpledb.kv.cockroach.CockroachKVDatabase

All Implemented Interfaces:

KVDatabase

public class CockroachKVDatabase
extends SQLKVDatabase

KVDatabase implementation based on CockroachDB.

Automatically creates the key/value table on startup if it doesn't already exist.

WARNING: not fully working yet; see issue #1962.

Field Summary

Fields inherited from class org.jsimpledb.kv.sql.SQLKVDatabase

dataSource, DEFAULT_KEY_COLUMN_NAME, DEFAULT_TABLE_NAME, DEFAULT_VALUE_COLUMN_NAME, isolationLevel, keyColumnName, log, OPTION_ISOLATION, tableName, valueColumnName

Constructor Summary

Constructors

Constructor and Description
CockroachKVDatabase()

Method Summary

Modifier and Type	Method and Description
protected void	beginTransaction(Connection connection)
String	createPutStatement()
protected org.jsimpledb.kv.cockroach.CockroachKVTransaction	createSQLKVTransaction(Connection connection)
protected void	initializeDatabaseIfNecessary(Connection connection)
String	limitSingleRow(String sql) Appends LIMIT 1 to the statement.
protected void	postBeginTransaction(Connection connection)
String	quote(String name) Encloses the given name in backticks.
KVTransactionException	wrapException(SQLKVTransaction tx, SQLException e)

Methods inherited from class org.jsimpledb.kv.sql.SQLKVDatabase

configureConnection, createGetAllStatement, createGetAtLeastStatement, createGetAtMostStatement, createGetRangeStatement, createGetStatement, createRemoveAllStatement, createRemoveAtLeastStatement, createRemoveAtMostStatement, createRemoveRangeStatement, createRemoveStatement, createTransaction, createTransaction, createTransactionConnection, getDataSource, getIsolationLevel, getIsolationLevel, getKeyColumnName, getTableName, getValueColumnName, isRollbackForReadOnly, preBeginTransaction, setDataSource, setIsolationLevel, setKeyColumnName, setRollbackForReadOnly, setTableName, setValueColumnName, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CockroachKVDatabase

public CockroachKVDatabase()

Method Detail

initializeDatabaseIfNecessary

protected void initializeDatabaseIfNecessary(Connection connection)
                                      throws SQLException

Overrides:

initializeDatabaseIfNecessary in class SQLKVDatabase

Throws:

SQLException

beginTransaction

protected void beginTransaction(Connection connection)
                         throws SQLException

Overrides:

beginTransaction in class SQLKVDatabase

Throws:

SQLException

postBeginTransaction

protected void postBeginTransaction(Connection connection)
                             throws SQLException

Overrides:

postBeginTransaction in class SQLKVDatabase

Throws:

SQLException

createSQLKVTransaction

protected org.jsimpledb.kv.cockroach.CockroachKVTransaction createSQLKVTransaction(Connection connection)
                                                                            throws SQLException

Overrides:

createSQLKVTransaction in class SQLKVDatabase

Throws:

SQLException

createPutStatement

public String createPutStatement()

Overrides:

createPutStatement in class SQLKVDatabase

quote

public String quote(String name)

Encloses the given name in backticks.

Overrides:

quote in class SQLKVDatabase

limitSingleRow

public String limitSingleRow(String sql)

Appends LIMIT 1 to the statement.

Overrides:

limitSingleRow in class SQLKVDatabase

wrapException

public KVTransactionException wrapException(SQLKVTransaction tx,
                                            SQLException e)

Overrides:

wrapException in class SQLKVDatabase