Package cz.o2.proxima.direct.jdbc

Interface SqlStatementFactory

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

RowAsJsonLogReaderStatementFactory

@Experimental
public interface SqlStatementFactory
extends java.io.Serializable

Method Summary

Modifier and Type	Method	Description
default void	close()
default java.sql.PreparedStatement	get(com.zaxxer.hikari.HikariDataSource dataSource, AttributeDescriptor<?> desc, java.lang.Object value)
default java.sql.PreparedStatement	list(com.zaxxer.hikari.HikariDataSource dataSource, RandomOffset offset, int limit)
default java.sql.PreparedStatement	scanAll(com.zaxxer.hikari.HikariDataSource dataSource)	Scan the complete content of table.
void	setup(EntityDescriptor entity, java.net.URI uri, java.util.Map<java.lang.String,java.lang.Object> cfg, com.zaxxer.hikari.HikariDataSource dataSource)
default java.sql.PreparedStatement	update(com.zaxxer.hikari.HikariDataSource dataSource, StreamElement element)

Method Detail

setup

void setup(EntityDescriptor entity,
           java.net.URI uri,
           java.util.Map<java.lang.String,java.lang.Object> cfg,
           com.zaxxer.hikari.HikariDataSource dataSource)
    throws java.sql.SQLException

Throws:

java.sql.SQLException

get

default java.sql.PreparedStatement get(com.zaxxer.hikari.HikariDataSource dataSource,
                                       AttributeDescriptor<?> desc,
                                       java.lang.Object value)
                                throws java.sql.SQLException

Throws:

java.sql.SQLException

list

default java.sql.PreparedStatement list(com.zaxxer.hikari.HikariDataSource dataSource,
                                        RandomOffset offset,
                                        int limit)
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

update

default java.sql.PreparedStatement update(com.zaxxer.hikari.HikariDataSource dataSource,
                                          StreamElement element)
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

scanAll

default java.sql.PreparedStatement scanAll(com.zaxxer.hikari.HikariDataSource dataSource)

Scan the complete content of table.

Parameters:

dataSource - the source

Returns:

prepared statement

close

default void close()