com.freedomoss.crowdcontrol.webharvest.plugin.datastore.service

Class DatabaseDataStoreService

java.lang.Object

com.freedomoss.crowdcontrol.webharvest.plugin.datastore.service.DatabaseDataStoreService

All Implemented Interfaces:

IDatabaseDataStoreService

Direct Known Subclasses:

RemoteDataStoreService

public class DatabaseDataStoreService
extends java.lang.Object
implements IDatabaseDataStoreService

Constructor Summary

Constructors

Constructor and Description
DatabaseDataStoreService(javax.sql.DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
boolean	executeQuery(java.lang.String query)
boolean	executeQuery(java.lang.String query, java.sql.Connection connection)
java.util.List<DbRowDTO>	executeSelectQuery(int maxRows, java.lang.String query)
java.util.List<DbRowDTO>	executeSelectQuery(int maxRows, java.lang.String query, java.sql.Connection connection)
int	executeUpdateQuery(java.lang.String query, java.lang.String dataStoreName, java.sql.Connection connection, DataStoreAuditContext auditContext)
int	executeUpdateQuery(java.lang.String query, java.lang.String dataStoreName, DataStoreAuditContext auditContext)
java.lang.Long	insertRow(java.lang.String dataStoreName, DataStoreRow row, java.sql.Connection connection, DataStoreAuditContext auditContext)
java.lang.Long	insertRow(java.lang.String dataStoreName, DataStoreRow row, DataStoreAuditContext auditContext)
boolean	isDeleteQuery(java.lang.String query)
boolean	isSelectQuery(java.lang.String query)
boolean	isUpdateQuery(java.lang.String query)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseDataStoreService

public DatabaseDataStoreService(javax.sql.DataSource dataSource)

Method Detail

executeSelectQuery

public java.util.List<DbRowDTO> executeSelectQuery(int maxRows,
                                                   java.lang.String query)
                                            throws java.sql.SQLException

Specified by:

executeSelectQuery in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

executeSelectQuery

public java.util.List<DbRowDTO> executeSelectQuery(int maxRows,
                                                   java.lang.String query,
                                                   java.sql.Connection connection)
                                            throws java.sql.SQLException

Specified by:

executeSelectQuery in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

executeQuery

public boolean executeQuery(java.lang.String query)
                     throws java.sql.SQLException

Specified by:

executeQuery in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

executeQuery

public boolean executeQuery(java.lang.String query,
                            java.sql.Connection connection)
                     throws java.sql.SQLException

Specified by:

executeQuery in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

executeUpdateQuery

public int executeUpdateQuery(java.lang.String query,
                              java.lang.String dataStoreName,
                              DataStoreAuditContext auditContext)
                       throws java.sql.SQLException

Specified by:

executeUpdateQuery in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

executeUpdateQuery

public int executeUpdateQuery(java.lang.String query,
                              java.lang.String dataStoreName,
                              java.sql.Connection connection,
                              DataStoreAuditContext auditContext)
                       throws java.sql.SQLException

Specified by:

executeUpdateQuery in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

insertRow

public java.lang.Long insertRow(java.lang.String dataStoreName,
                                DataStoreRow row,
                                DataStoreAuditContext auditContext)
                         throws java.sql.SQLException,
                                java.text.ParseException

Specified by:

insertRow in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

java.text.ParseException

insertRow

public java.lang.Long insertRow(java.lang.String dataStoreName,
                                DataStoreRow row,
                                java.sql.Connection connection,
                                DataStoreAuditContext auditContext)
                         throws java.sql.SQLException,
                                java.text.ParseException

Specified by:

insertRow in interface IDatabaseDataStoreService

Throws:

java.sql.SQLException

java.text.ParseException

isSelectQuery

public boolean isSelectQuery(java.lang.String query)

Specified by:

isSelectQuery in interface IDatabaseDataStoreService

isUpdateQuery

public boolean isUpdateQuery(java.lang.String query)

Specified by:

isUpdateQuery in interface IDatabaseDataStoreService

isDeleteQuery

public boolean isDeleteQuery(java.lang.String query)

Specified by:

isDeleteQuery in interface IDatabaseDataStoreService