Package one.microstream.afs.sql.types

Class SqlProvider.Abstract

java.lang.Object

one.microstream.afs.sql.types.SqlProvider.Abstract

All Implemented Interfaces:

SqlProvider

Direct Known Subclasses:

SqlProviderMariaDb.Default, SqlProviderPostgres.Default, SqlProviderSqlite.Default

Enclosing interface:

SqlProvider

public abstract static class SqlProvider.Abstract
extends Object
implements SqlProvider

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.afs.sql.types.SqlProvider

SqlProvider.Abstract

Field Summary

Fields inherited from interface one.microstream.afs.sql.types.SqlProvider

DATA_COLUMN_NAME, DATA_COLUMN_TYPE, END_COLUMN_NAME, END_COLUMN_TYPE, IDENTIFIER_COLUMN_LENGTH, IDENTIFIER_COLUMN_NAME, IDENTIFIER_COLUMN_TYPE, START_COLUMN_NAME, START_COLUMN_TYPE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Abstract(String catalog, String schema, DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
protected VarString	addNameQuoted(VarString vs, String name)
protected VarString	addSqlColumnName(VarString vs, String columnName)
protected VarString	addSqlTableName(VarString vs, String tableName)
String	catalog()
String	copyFileQuery(String sourceTableName, String targetTableName)	insert into [targetTableName] ('identifier', 'start', 'end', 'data') select ?, 'start', 'end', 'data' from [sourceTableName] where 'identifier' = ?
String	deleteFileQuery(String tableName)	delete from [tableName] where 'identifier' = ?
String	deleteFileQueryFromEnd(String tableName)	delete from [tableName] where 'identifier' = ? and 'end' >= ?
String	deleteFileQueryFromStart(String tableName)	delete from [tableName] where 'identifier' = ? and 'start' >= ?
<T> T	execute(SqlOperation<T> operation)
String	fileExistsQuery(String tableName)	select count(*) from [tableName] where 'identifier' = ?
String	fileSizeQuery(String tableName)	select count(*), max('end') from [tableName] where 'identifier' = ?
protected String	internalReadDataQuery(String tableName, VarString... conditions)
String	listFilesQuery(String tableName)	select distinct 'identifier' from [tableName]
String	moveFileQuerySameParent(String tableName)	update [tableName] set 'identifier' = ? where 'identifier' = ?
Set<String>	queryDirectories(Connection connection, String prefix)
boolean	queryDirectoryExists(Connection connection, String tableName)
protected char	quoteClose()
protected char	quoteOpen()
String	readDataQuery(String tableName)	select * from [tableName] where 'identifier' = ? order by 'end' desc
String	readDataQueryWithLength(String tableName)	select * from [tableName] where 'identifier' = ? and 'start' < ? order by 'end' desc
String	readDataQueryWithOffset(String tableName)	select * from [tableName] where 'identifier' = ? and 'end' >= ? order by 'end' desc
String	readDataQueryWithRange(String tableName)	select * from [tableName] where 'identifier' = ? and 'end' >= ? and 'start' <= ? order by 'end' desc
String	readMetadataQuery(String tableName)	select 'start', 'end' from [tableName] where 'identifier' = ?
String	readMetadataQuerySingleSegment(String tableName)	select 'start', 'end' from [tableName] where 'identifier' = ? and start <= ? and end >= ?
String	schema()
void	setBlob(PreparedStatement statement, int index, InputStream inputStream, long length)
String	writeDataQuery(String tableName)	insert into [tableName] ('identifier', 'start', 'end', 'data') values (?, ?, ?, ?)

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.afs.sql.types.SqlProvider

createDirectoryQueries

Constructor Details

Abstract

protected Abstract(String catalog, String schema, DataSource dataSource)

Method Details

quoteOpen

protected char quoteOpen()

quoteClose

protected char quoteClose()

addSqlTableName

protected VarString addSqlTableName(VarString vs, String tableName)

addSqlColumnName

protected VarString addSqlColumnName(VarString vs, String columnName)

addNameQuoted

protected VarString addNameQuoted(VarString vs, String name)

internalReadDataQuery

protected String internalReadDataQuery(String tableName, VarString... conditions)

catalog

public String catalog()

Specified by:

catalog in interface SqlProvider

schema

public String schema()

Specified by:

schema in interface SqlProvider

execute

public <T> T execute(SqlOperation<T> operation)

Specified by:

execute in interface SqlProvider

setBlob

public void setBlob(PreparedStatement statement, int index, InputStream inputStream, long length) throws SQLException

Specified by:

setBlob in interface SqlProvider

Throws:

SQLException

queryDirectoryExists

public boolean queryDirectoryExists(Connection connection, String tableName) throws SQLException

Specified by:

queryDirectoryExists in interface SqlProvider

Throws:

SQLException

queryDirectories

public Set<String> queryDirectories(Connection connection, String prefix) throws SQLException

Specified by:

queryDirectories in interface SqlProvider

Throws:

SQLException

fileSizeQuery

public String fileSizeQuery(String tableName)

Description copied from interface: SqlProvider

 select count(*), max('end')
 from [tableName]
 where 'identifier' = ?
 

Specified by:

fileSizeQuery in interface SqlProvider

listFilesQuery

public String listFilesQuery(String tableName)

Description copied from interface: SqlProvider

 select distinct 'identifier'
 from [tableName]
 

Specified by:

listFilesQuery in interface SqlProvider

readMetadataQuery

public String readMetadataQuery(String tableName)

Description copied from interface: SqlProvider

 select 'start', 'end'
 from [tableName]
 where 'identifier' = ?
 

Specified by:

readMetadataQuery in interface SqlProvider

readMetadataQuerySingleSegment

public String readMetadataQuerySingleSegment(String tableName)

Description copied from interface: SqlProvider

 select 'start', 'end'
 from [tableName]
 where 'identifier' = ?
 and start <= ? and end >= ?
 

Specified by:

readMetadataQuerySingleSegment in interface SqlProvider

readDataQuery

public String readDataQuery(String tableName)

Description copied from interface: SqlProvider

 select *
 from [tableName]
 where 'identifier' = ?
 order by 'end' desc
 

Specified by:

readDataQuery in interface SqlProvider

readDataQueryWithLength

public String readDataQueryWithLength(String tableName)

Description copied from interface: SqlProvider

 select *
 from [tableName]
 where 'identifier' = ?
 and 'start' < ?
 order by 'end' desc
 

Specified by:

readDataQueryWithLength in interface SqlProvider

readDataQueryWithOffset

public String readDataQueryWithOffset(String tableName)

Description copied from interface: SqlProvider

 select *
 from [tableName]
 where 'identifier' = ?
 and 'end' >= ?
 order by 'end' desc
 

Specified by:

readDataQueryWithOffset in interface SqlProvider

readDataQueryWithRange

public String readDataQueryWithRange(String tableName)

Description copied from interface: SqlProvider

 select *
 from [tableName]
 where 'identifier' = ?
 and 'end' >= ?
 and 'start' <= ?
 order by 'end' desc
 

Specified by:

readDataQueryWithRange in interface SqlProvider

fileExistsQuery

public String fileExistsQuery(String tableName)

Description copied from interface: SqlProvider

 select count(*)
 from [tableName]
 where 'identifier' = ?
 

Specified by:

fileExistsQuery in interface SqlProvider

deleteFileQuery

public String deleteFileQuery(String tableName)

Description copied from interface: SqlProvider

 delete from [tableName]
 where 'identifier' = ?
 

Specified by:

deleteFileQuery in interface SqlProvider

deleteFileQueryFromStart

public String deleteFileQueryFromStart(String tableName)

Description copied from interface: SqlProvider

 delete from [tableName]
 where 'identifier' = ?
 and 'start' >= ?
 

Specified by:

deleteFileQueryFromStart in interface SqlProvider

deleteFileQueryFromEnd

public String deleteFileQueryFromEnd(String tableName)

Description copied from interface: SqlProvider

 delete from [tableName]
 where 'identifier' = ?
 and 'end' >= ?
 

Specified by:

deleteFileQueryFromEnd in interface SqlProvider

writeDataQuery

public String writeDataQuery(String tableName)

Description copied from interface: SqlProvider

 insert into [tableName]
 ('identifier', 'start', 'end', 'data')
 values (?, ?, ?, ?)
 

Specified by:

writeDataQuery in interface SqlProvider

moveFileQuerySameParent

public String moveFileQuerySameParent(String tableName)

Description copied from interface: SqlProvider

 update [tableName]
 set 'identifier' = ?
 where 'identifier' = ?
 

Specified by:

moveFileQuerySameParent in interface SqlProvider

copyFileQuery

public String copyFileQuery(String sourceTableName, String targetTableName)

Description copied from interface: SqlProvider

 insert into [targetTableName]
 ('identifier', 'start', 'end', 'data')
 select ?, 'start', 'end', 'data'
 from [sourceTableName]
 where 'identifier' = ?
 

Specified by:

copyFileQuery in interface SqlProvider