java.lang.Object

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

All Implemented Interfaces:: SqlProvider

Direct Known Subclasses:: SqlProviderHana.Default, SqlProviderMariaDb.Default, SqlProviderOracle.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`	`countFilesQuery(String tableName)`	select count(*) from [tableName]
`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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- listFilesQuery
  
  public String listFilesQuery(String tableName)
  
  Description copied from interface: SqlProvider
  select distinct 'identifier' from [tableName]
  Specified by:
  
  listFilesQuery in interface SqlProvider
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- countFilesQuery
  
  public String countFilesQuery(String tableName)
  
  Description copied from interface: SqlProvider
  select count(*) from [tableName]
  Specified by:
  
  countFilesQuery 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- fileExistsQuery
  
  public String fileExistsQuery(String tableName)
  
  Description copied from interface: SqlProvider
  select count(*) from [tableName] where 'identifier' = ?
  Specified by:
  
  fileExistsQuery in interface SqlProvider
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- deleteFileQuery
  
  public String deleteFileQuery(String tableName)
  
  Description copied from interface: SqlProvider
  delete from [tableName] where 'identifier' = ?
  Specified by:
  
  deleteFileQuery in interface SqlProvider
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- deleteFileQueryFromStart
  
  public String deleteFileQueryFromStart(String tableName)
  
  Description copied from interface: SqlProvider
  delete from [tableName] where 'identifier' = ? and 'start' >= ?
  Specified by:
  
  deleteFileQueryFromStart in interface SqlProvider
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- deleteFileQueryFromEnd
  
  public String deleteFileQueryFromEnd(String tableName)
  
  Description copied from interface: SqlProvider
  delete from [tableName] where 'identifier' = ? and 'end' >= ?
  Specified by:
  
  deleteFileQueryFromEnd in interface SqlProvider
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- moveFileQuerySameParent
  
  public String moveFileQuerySameParent(String tableName)
  
  Description copied from interface: SqlProvider
  update [tableName] set 'identifier' = ? where 'identifier' = ?
  Specified by:
  
  moveFileQuerySameParent in interface SqlProvider
  
  Parameters:
  
  tableName - the table to query
  
  Returns:
  
  the native query string
- 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
  
  Parameters:
  
  sourceTableName - the source table name to query
  
  targetTableName - the target table name to query
  
  Returns:
  
  the native query string

Class SqlProvider.Abstract

Nested Class Summary

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

Field Summary

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

Method Details