org.eclipse.smila.jdbc.internal

Class JdbcAccessServiceImpl

java.lang.Object

org.eclipse.smila.jdbc.internal.JdbcAccessServiceImpl

All Implemented Interfaces:

JdbcAccessService

public class JdbcAccessServiceImpl
extends java.lang.Object
implements JdbcAccessService

Implementation of JdbcAccessService via JDBC.

Constructor Summary

Constructors

Constructor and Description
JdbcAccessServiceImpl()

Method Summary

Methods

Modifier and Type	Method and Description
SqlExecutor	executePrepared(java.lang.String url, AnyMap dbProperties, java.lang.String sql, long maxAttachmentSize, MessageCollector messages) For executing an SQL statement multiple times with different parameters.
SqlExecutor	executePrepared(java.lang.String url, java.util.Properties dbProperties, java.lang.String sql, long maxAttachmentSize, MessageCollector messages)
java.util.Collection<Record>	executeSql(java.lang.String url, AnyMap dbProperties, java.lang.String sql, long maxAttachmentSize, MessageCollector messages) Executes single SQL statement.
java.util.Collection<Record>	executeSql(java.lang.String url, java.util.Properties dbProperties, java.lang.String sql, long maxAttachmentSize, MessageCollector messages)
void	setJdbcProvider(JdbcProvider jdbcProvider) DS service reference injection method.
void	unsetJdbcProvider(JdbcProvider jdbcProvider) DS service reference removal method.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcAccessServiceImpl

public JdbcAccessServiceImpl()

Method Detail

executeSql

public java.util.Collection<Record> executeSql(java.lang.String url,
                                      AnyMap dbProperties,
                                      java.lang.String sql,
                                      long maxAttachmentSize,
                                      MessageCollector messages)
                                        throws java.sql.SQLException,
                                               java.io.IOException

Description copied from interface: JdbcAccessService

Executes single SQL statement.

Specified by:

executeSql in interface JdbcAccessService

Parameters:

url - the database connection URL of the form jdbc:subprotocol:subname

dbProperties - connection properties, e.g. "user" and "password"

sql - the SQL statement to execute

Returns:

the SQL result as collection of records, one row -> one record

Throws:

java.sql.SQLException

java.io.IOException

executeSql

public java.util.Collection<Record> executeSql(java.lang.String url,
                                      java.util.Properties dbProperties,
                                      java.lang.String sql,
                                      long maxAttachmentSize,
                                      MessageCollector messages)
                                        throws java.sql.SQLException,
                                               java.io.IOException

Specified by:

executeSql in interface JdbcAccessService

Throws:

java.sql.SQLException

java.io.IOException

See Also:

DbAccessService.executeSql(String, AnyMap, String), we just use Properties instead of AnyMap here

executePrepared

public SqlExecutor executePrepared(java.lang.String url,
                          AnyMap dbProperties,
                          java.lang.String sql,
                          long maxAttachmentSize,
                          MessageCollector messages)
                            throws java.sql.SQLException

Description copied from interface: JdbcAccessService

For executing an SQL statement multiple times with different parameters. The given SQL statement is used as PreparedStatement. An SqlExecutor is returned which allows multiple executions of the same statement with different parameters.

Specified by:

executePrepared in interface JdbcAccessService

Parameters:

url - the database connection URL of the form jdbc:subprotocol:subname

dbProperties - connection properties, e.g. "user" and "password"

sql - the SQL statement to execute, used as PreparedStatement

Returns:

An SqlExecutor for multiple execution of the given sql statement with different parameters.

Throws:

java.sql.SQLException

executePrepared

public SqlExecutor executePrepared(java.lang.String url,
                          java.util.Properties dbProperties,
                          java.lang.String sql,
                          long maxAttachmentSize,
                          MessageCollector messages)
                            throws java.sql.SQLException

Specified by:

executePrepared in interface JdbcAccessService

Throws:

java.sql.SQLException

See Also:

DbAccessService.executePrepared(String, AnyMap, String), we just use Properties instead of AnyMap here

setJdbcProvider

public void setJdbcProvider(JdbcProvider jdbcProvider)

DS service reference injection method.

unsetJdbcProvider

public void unsetJdbcProvider(JdbcProvider jdbcProvider)

DS service reference removal method.