de.ipcon.schema.generators

Class AbstractSQL

java.lang.Object

de.ipcon.schema.generators.AbstractSQL

All Implemented Interfaces:

CBOGeneratorI, DatabaseConnectingCBOGeneratorI, java.io.Serializable

Direct Known Subclasses:

DiscriminatorSync, DoubleIdFixer, FirstNodeStart, IntegrityCheck, PostgreSQL

public abstract class AbstractSQL
extends java.lang.Object
implements DatabaseConnectingCBOGeneratorI

Abstract base class for database-connecting schema generators.

Provides core functionality for JDBC connection management, connection pooling, parallel task execution (via ScatterGatherManager), and SQL operations (DDL/DML).

Architectural Notes & JDBC Best Practices:

• Shared Default Connection: getConn() and getStmtForChanging() use a single, shared connection. This must ONLY be used for sequential, single-threaded "fire-and-forget" updates.
• Thread-Safe Connections: For parallel execution, threads MUST acquire an isolated connection via getConnection(boolean) and return it via freeConnection(Connection).
• ResultSets: To prevent silent closures by the JDBC driver, any query that iterates over a ResultSet must create its own local Statement and close it in a finally block.

See Also:

Serialized Form

Field Summary

Fields inherited from interface de.ipcon.schema.CBOGeneratorI

SCOPE_GLOBAL, SCOPE_LOCAL

Constructor Summary

Constructors

Constructor and Description
AbstractSQL() Constructs a new instance and parses configuration from the provided XML element.
AbstractSQL(electric.xml.Element e)

Method Summary

Modifier and Type	Method and Description
CBOGeneratorResult	generate(SchemaI _schema, SchemaI _newSchema) Triggers the schema generation or migration process.
abstract void	generateImpl(SchemaI _schema, SchemaI _newSchema) The core implementation of the schema generation logic.
java.lang.String	getDriver()
abstract java.lang.String	getName() Returns the implementation-specific name of the generator (e.g.
java.lang.String	getPass()
java.lang.String	getUrl()
java.lang.String	getUser()
void	initDatabaseConnectionParameters(java.lang.String _driver, java.lang.String _url, java.lang.String _user, java.lang.String _pass) Initializes the parameters required to establish a database connection.
void	setDriver(java.lang.String $40)
void	setPass(java.lang.String $43)
void	setUrl(java.lang.String $41)
void	setUser(java.lang.String $42)
void	shutdown() Signals a shutdown flag and immediately shuts down the connection pool.

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.ipcon.schema.CBOGeneratorI

generate

Constructor Detail

AbstractSQL

public AbstractSQL()

Constructs a new instance and parses configuration from the provided XML element.

Parameters:

e - Optional XML Element containing initial configuration attributes like driver, url, user, etc.

AbstractSQL

public AbstractSQL(electric.xml.Element e)

Method Detail

initDatabaseConnectionParameters

public void initDatabaseConnectionParameters(java.lang.String _driver,
                                             java.lang.String _url,
                                             java.lang.String _user,
                                             java.lang.String _pass)

Initializes the parameters required to establish a database connection. Overrides interface definition.

Specified by:

initDatabaseConnectionParameters in interface DatabaseConnectingCBOGeneratorI

Parameters:

_driver - The fully qualified name of the JDBC driver class.

_url - The database connection URL.

_user - The database username.

_pass - The database password.

generate

public CBOGeneratorResult generate(SchemaI _schema,
                                   SchemaI _newSchema)

Triggers the schema generation or migration process. Connects to the database, executes the implementation-specific generation, and ensures safe disconnection.

Specified by:

generate in interface CBOGeneratorI

Parameters:

_schema - The target schema definition.

_newSchema - An optional new schema.

Returns:

The generator result (currently always null).

getName

public abstract java.lang.String getName()

Returns the implementation-specific name of the generator (e.g. "PostgreSQL metadata maintenance").

Specified by:

getName in interface CBOGeneratorI

Returns:

the name.

generateImpl

public abstract void generateImpl(SchemaI _schema,
                                  SchemaI _newSchema)

The core implementation of the schema generation logic. Must be provided by subclasses.

Parameters:

_schema - The schema to base the generation on.

_newSchema - An optional new schema.

shutdown

public void shutdown()

Signals a shutdown flag and immediately shuts down the connection pool.

getDriver

public java.lang.String getDriver()

setDriver

public void setDriver(java.lang.String $40)

getUrl

public java.lang.String getUrl()

setUrl

public void setUrl(java.lang.String $41)

getUser

public java.lang.String getUser()

setUser

public void setUser(java.lang.String $42)

getPass

public java.lang.String getPass()

setPass

public void setPass(java.lang.String $43)