Package one.microstream.afs.sql

Interface SqlProvider

All Known Subinterfaces:

SqlProviderMySql, SqlProviderOracle, SqlProviderSqlite

All Known Implementing Classes:

SqlProvider.Abstract, SqlProviderMySql.Default, SqlProviderOracle.Default, SqlProviderSqlite.Default

public interface SqlProvider

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	SqlProvider.Abstract

Field Summary

Fields

Modifier and Type	Field	Description
static String	DATA_COLUMN_NAME
static int	DATA_COLUMN_TYPE
static String	END_COLUMN_NAME
static int	END_COLUMN_TYPE
static int	IDENTIFIER_COLUMN_LENGTH
static String	IDENTIFIER_COLUMN_NAME
static int	IDENTIFIER_COLUMN_TYPE
static String	START_COLUMN_NAME
static int	START_COLUMN_TYPE

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' = ?
Iterable<String>	createDirectoryQueries(String tableName)	create table [tableName] ( 'identifier' varchar(IDENTIFIER_COLUMN_LENGTH) not null, 'start' bigint not null, 'end' bigint not null, 'blob' not null, primary key ('identifier', 'start') )
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 (?, ?, ?, ?)

Field Details

IDENTIFIER_COLUMN_NAME

static final String IDENTIFIER_COLUMN_NAME

See Also:

Constant Field Values

IDENTIFIER_COLUMN_TYPE

static final int IDENTIFIER_COLUMN_TYPE

See Also:

Constant Field Values

IDENTIFIER_COLUMN_LENGTH

static final int IDENTIFIER_COLUMN_LENGTH

See Also:

Constant Field Values

START_COLUMN_NAME

static final String START_COLUMN_NAME

See Also:

Constant Field Values

START_COLUMN_TYPE

static final int START_COLUMN_TYPE

See Also:

Constant Field Values

END_COLUMN_NAME

static final String END_COLUMN_NAME

See Also:

Constant Field Values

END_COLUMN_TYPE

static final int END_COLUMN_TYPE

See Also:

Constant Field Values

DATA_COLUMN_NAME

static final String DATA_COLUMN_NAME

See Also:

Constant Field Values

DATA_COLUMN_TYPE

static final int DATA_COLUMN_TYPE

See Also:

Constant Field Values

Method Details

catalog

String catalog()

schema

String schema()

execute

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

setBlob

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

Throws:

SQLException

queryDirectoryExists

boolean queryDirectoryExists(Connection connection, String tableName) throws SQLException

Throws:

SQLException

queryDirectories

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

Throws:

SQLException

fileSizeQuery

String fileSizeQuery(String tableName)

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

listFilesQuery

String listFilesQuery(String tableName)

 select distinct 'identifier'
 from [tableName]
 

readMetadataQuery

String readMetadataQuery(String tableName)

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

readMetadataQuerySingleSegment

String readMetadataQuerySingleSegment(String tableName)

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

readDataQuery

String readDataQuery(String tableName)

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

readDataQueryWithLength

String readDataQueryWithLength(String tableName)

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

readDataQueryWithOffset

String readDataQueryWithOffset(String tableName)

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

readDataQueryWithRange

String readDataQueryWithRange(String tableName)

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

fileExistsQuery

String fileExistsQuery(String tableName)

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

createDirectoryQueries

Iterable<String> createDirectoryQueries(String tableName)

 create table [tableName] (
 'identifier' varchar(IDENTIFIER_COLUMN_LENGTH) not null,
 'start' bigint not null,
 'end' bigint not null,
 'blob' not null,
 primary key ('identifier', 'start')
 )
 

deleteFileQuery

String deleteFileQuery(String tableName)

 delete from [tableName]
 where 'identifier' = ?
 

deleteFileQueryFromStart

String deleteFileQueryFromStart(String tableName)

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

deleteFileQueryFromEnd

String deleteFileQueryFromEnd(String tableName)

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

writeDataQuery

String writeDataQuery(String tableName)

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

moveFileQuerySameParent

String moveFileQuerySameParent(String tableName)

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

copyFileQuery

String copyFileQuery(String sourceTableName, String targetTableName)

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