Module service.database

Package service.database

Class SQLDatabaseService

java.lang.Object

service.AbstractService

service.IdentifyableService

service.database.AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

service.database.SQLDatabaseService

All Implemented Interfaces:

java.lang.AutoCloseable, service.Service

public class SQLDatabaseService
extends AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SQLDatabaseService.Column
static class	SQLDatabaseService.DataChanged
static class	SQLDatabaseService.Info
static class	SQLDatabaseService.QueryParameter
static class	SQLDatabaseService.QueryResponse
static class	SQLDatabaseService.Row
static class	SQLDatabaseService.SchemaParameter
static class	SQLDatabaseService.Table
static class	SQLDatabaseService.UpdateParameter

Nested classes/interfaces inherited from class service.database.AbstractDatabaseService

AbstractDatabaseService.Subscription

Nested classes/interfaces inherited from class service.IdentifyableService

service.IdentifyableService.Status

Nested classes/interfaces inherited from class service.AbstractService

service.AbstractService.InvalidCommandException, service.AbstractService.InvalidFormatException

Nested classes/interfaces inherited from interface service.Service

service.Service.Port

Field Summary

Fields inherited from class service.database.AbstractDatabaseService

LOGGER

Constructor Summary

Constructors

Constructor	Description
SQLDatabaseService(service.Service.Port port, int clientLimit, api.sql.SQLDatabaseConnection databaseConnection)

Method Summary

Modifier and Type	Method	Description
protected AbstractDatabaseService.DataChanged<SQLDatabaseService.QueryResponse>	dataChanged(java.lang.String operation, api.sql.SQLDatabaseConnection.Row oldData, api.sql.SQLDatabaseConnection.Row newData)
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info>	deleteFromDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)
protected java.lang.String	getDatabaseType()
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info>	init(AbstractDatabaseService.QueryParameter<SQLDatabaseService.SchemaParameter> parameter)
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info>	insertIntoDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.QueryResponse>	queryDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info>	subscriptionDone(java.util.List<AbstractDatabaseService.Subscription> subscriptionsAdded)
protected java.util.function.Predicate<api.sql.SQLDatabaseConnection.Row>	translate(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info>	unsubscriptionDone(java.util.List<AbstractDatabaseService.Subscription> subscriptionsToRemmove)
protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info>	updateDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.UpdateParameter> parameter)

Methods inherited from class service.database.AbstractDatabaseService

getServiceType, onCustomCommand, subscribe, unsubscribe

Methods inherited from class service.IdentifyableService

onMessageReceived

Methods inherited from class service.AbstractService

close, getStatus, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

SQLDatabaseService

public SQLDatabaseService(service.Service.Port port, int clientLimit, api.sql.SQLDatabaseConnection databaseConnection)

Method Details

getDatabaseType

protected java.lang.String getDatabaseType()

Specified by:

getDatabaseType in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

dataChanged

protected AbstractDatabaseService.DataChanged<SQLDatabaseService.QueryResponse> dataChanged(java.lang.String operation, api.sql.SQLDatabaseConnection.Row oldData, api.sql.SQLDatabaseConnection.Row newData)

Specified by:

dataChanged in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

translate

protected java.util.function.Predicate<api.sql.SQLDatabaseConnection.Row> translate(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)

Specified by:

translate in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

unsubscriptionDone

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info> unsubscriptionDone(java.util.List<AbstractDatabaseService.Subscription> subscriptionsToRemmove)

Specified by:

unsubscriptionDone in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

subscriptionDone

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info> subscriptionDone(java.util.List<AbstractDatabaseService.Subscription> subscriptionsAdded)

Specified by:

subscriptionDone in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

init

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info> init(AbstractDatabaseService.QueryParameter<SQLDatabaseService.SchemaParameter> parameter)

Specified by:

init in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

insertIntoDatabase

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info> insertIntoDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)

Specified by:

insertIntoDatabase in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

updateDatabase

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info> updateDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.UpdateParameter> parameter)

Specified by:

updateDatabase in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

deleteFromDatabase

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.Info> deleteFromDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)

Specified by:

deleteFromDatabase in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>

queryDatabase

protected service.JsonResponse<service.IdentifyableService.Status,SQLDatabaseService.QueryResponse> queryDatabase(AbstractDatabaseService.QueryParameter<SQLDatabaseService.QueryParameter> parameter)

Specified by:

queryDatabase in class AbstractDatabaseService<api.sql.SQLSchema,api.sql.SQLDatabaseConnection.Row,SQLDatabaseService.QueryResponse,SQLDatabaseService.SchemaParameter,SQLDatabaseService.QueryParameter,SQLDatabaseService.UpdateParameter,SQLDatabaseService.Info>