org.waarp.gateway.kernel.database.model

Class DbModelMysqlKernel

java.lang.Object

org.waarp.common.database.model.DbModelAbstract

org.waarp.common.database.model.DbModelCommonMariadbMySql

org.waarp.common.database.model.DbModelMysql

org.waarp.gateway.kernel.database.model.DbModelMysqlKernel

All Implemented Interfaces:

DbModel

public class DbModelMysqlKernel
extends DbModelMysql

MySQL Database Model implementation

Nested Class Summary

Nested classes/interfaces inherited from class org.waarp.common.database.model.DbModelMysql

DbModelMysql.DbTypeResolverMySQL

Nested classes/interfaces inherited from class org.waarp.common.database.model.DbModelCommonMariadbMySql

DbModelCommonMariadbMySql.DBType

Nested classes/interfaces inherited from class org.waarp.common.database.model.DbModelAbstract

DbModelAbstract.DbTypeResolver

Field Summary

Fields inherited from class org.waarp.common.database.model.DbModelMysql

mysqlConnectionPoolDataSource, pool

Fields inherited from class org.waarp.common.database.model.DbModelAbstract

dbTypeResolver

Constructor Summary

Constructors

Constructor and Description
DbModelMysqlKernel(String dbserver, String dbuser, String dbpasswd) Create the object and initialize if necessary the driver

Method Summary

Modifier and Type	Method and Description
static void	createTableMonitoring(DbSession session)
void	createTables(DbSession session) Create all necessary tables into the database
boolean	needUpgradeDb(DbSession session, String version, boolean tryFix) Check if Database is ok from version
long	nextSequence(DbSession dbSession)
static long	nextSequenceMonitoring(DbSession dbSession, ReentrantLock lock)
void	resetSequence(DbSession session, long newvalue) Reset the sequence (example)
static void	resetSequenceMonitoring(DbSession session, long newvalue)
boolean	upgradeDb(DbSession session, String version) Upgrade Database from version

Methods inherited from class org.waarp.common.database.model.DbModelMysql

currentNumberOfPooledConnections, getDbConnection, getDbType, releaseResources

Methods inherited from class org.waarp.common.database.model.DbModelCommonMariadbMySql

limitRequest, validConnectionString

Methods inherited from class org.waarp.common.database.model.DbModelAbstract

closeInternalConnection, getDbTypeResolver, validConnection, validConnectionSelect

Methods inherited from class java.lang.Object

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

Constructor Detail

DbModelMysqlKernel

public DbModelMysqlKernel(String dbserver,
                          String dbuser,
                          String dbpasswd)
                   throws WaarpDatabaseNoConnectionException

Create the object and initialize if necessary the driver

Parameters:

dbserver -

dbuser -

dbpasswd -

Throws:

WaarpDatabaseNoConnectionException

Method Detail

createTables

public void createTables(DbSession session)
                  throws WaarpDatabaseNoConnectionException

Description copied from interface: DbModel

Create all necessary tables into the database

Parameters:

session - SQL session

Throws:

WaarpDatabaseNoConnectionException

createTableMonitoring

public static void createTableMonitoring(DbSession session)
                                  throws WaarpDatabaseNoConnectionException

Throws:

WaarpDatabaseNoConnectionException

resetSequence

public void resetSequence(DbSession session,
                          long newvalue)
                   throws WaarpDatabaseNoConnectionException

Description copied from interface: DbModel

Reset the sequence (example)

Specified by:

resetSequence in interface DbModel

Overrides:

resetSequence in class DbModelCommonMariadbMySql

Parameters:

session - SQL session

Throws:

WaarpDatabaseNoConnectionException

resetSequenceMonitoring

public static void resetSequenceMonitoring(DbSession session,
                                           long newvalue)
                                    throws WaarpDatabaseNoConnectionException

Throws:

WaarpDatabaseNoConnectionException

nextSequence

public long nextSequence(DbSession dbSession)
                  throws WaarpDatabaseNoConnectionException,
                         WaarpDatabaseSqlException,
                         WaarpDatabaseNoDataException

Specified by:

nextSequence in interface DbModel

Overrides:

nextSequence in class DbModelCommonMariadbMySql

Returns:

The next unique specialId

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

WaarpDatabaseNoDataException

nextSequenceMonitoring

public static long nextSequenceMonitoring(DbSession dbSession,
                                          ReentrantLock lock)
                                   throws WaarpDatabaseNoConnectionException,
                                          WaarpDatabaseSqlException,
                                          WaarpDatabaseNoDataException

Throws:

WaarpDatabaseNoConnectionException

WaarpDatabaseSqlException

WaarpDatabaseNoDataException

upgradeDb

public boolean upgradeDb(DbSession session,
                         String version)
                  throws WaarpDatabaseNoConnectionException

Description copied from interface: DbModel

Upgrade Database from version

Returns:

True if the Database is upgraded

Throws:

WaarpDatabaseNoConnectionException

needUpgradeDb

public boolean needUpgradeDb(DbSession session,
                             String version,
                             boolean tryFix)
                      throws WaarpDatabaseNoConnectionException

Description copied from interface: DbModel

Check if Database is ok from version

tryFix - True will imply a try to fix if possible

Returns:

True if the Database needs an upgrade

Throws:

WaarpDatabaseNoConnectionException