Package one.microstream.afs.sql

Class SqlProvider.Abstract

java.lang.Object

one.microstream.afs.sql.SqlProvider.Abstract

All Implemented Interfaces:

SqlProvider

Direct Known Subclasses:

SqlProviderMySql.Default, SqlProviderOracle.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.SqlProvider

SqlProvider.Abstract

Field Summary

Fields inherited from interface one.microstream.afs.sql.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

Constructor	Description
Abstract()

Method Summary

Modifier and Type	Method	Description
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' = ?
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)
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.SqlProvider

createDirectoryQueries

Constructor Details

Abstract

public Abstract()

Method Details

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