org.fastnate.generator

Class ConnectedEntitySqlGenerator

java.lang.Object

org.fastnate.generator.EntitySqlGenerator

org.fastnate.generator.ConnectedEntitySqlGenerator

All Implemented Interfaces:

Closeable, AutoCloseable

public class ConnectedEntitySqlGenerator
extends EntitySqlGenerator

An extension of an EntitySqlGenerator which writes the SQL statements directly to a database connection.

Author:

Tobias Liefke

Constructor Summary

Constructors

Constructor and Description
ConnectedEntitySqlGenerator(Connection connection) Creates a new generator that writes to a database connection.
ConnectedEntitySqlGenerator(Connection connection, GeneratorContext context) Creates a new generator that writes to a database connection.

Method Summary

Modifier and Type	Method and Description
void	close() Writes any missing SQL and closes any open resources.
Connection	getConnection() The database connection that was used when creating this generator.
long	getStatementsCount() The count of statements that we executed up to now.
void	writeComment(String comment) Writes a SQL comment to the target writer.
void	writeSectionSeparator() Writes a new line to the target to separate different sections in the SQL file.
void	writeStatement(EntityStatement stmt)

Methods inherited from class org.fastnate.generator.EntitySqlGenerator

findEntity, flush, getContext, getWriter, markExistingEntities, markExistingEntity, write, write, writeAlignmentStatements, writePlainStatement

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectedEntitySqlGenerator

public ConnectedEntitySqlGenerator(Connection connection)
                            throws SQLException

Creates a new generator that writes to a database connection.

Parameters:

connection - the database connection

Throws:

SQLException - if the connection is invalid

ConnectedEntitySqlGenerator

public ConnectedEntitySqlGenerator(Connection connection,
                                   GeneratorContext context)
                            throws SQLException

Creates a new generator that writes to a database connection.

Parameters:

connection - the database connection

context - used to keep the state of indices and to store any configuration.

Throws:

SQLException - if the connection is invalid

Method Detail

close

public void close()
           throws IOException

Description copied from class: EntitySqlGenerator

Writes any missing SQL and closes any open resources.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class EntitySqlGenerator

Throws:

IOException - if the target writer throws one

writeComment

public void writeComment(String comment)
                  throws IOException

Description copied from class: EntitySqlGenerator

Writes a SQL comment to the target writer. Shortcut for getWriter().writeComment(comment).

Overrides:

writeComment in class EntitySqlGenerator

Parameters:

comment - the comment to write

Throws:

IOException - if the writer throws one

writeSectionSeparator

public void writeSectionSeparator()
                           throws IOException

Description copied from class: EntitySqlGenerator

Writes a new line to the target to separate different sections in the SQL file. Shortcut for getWriter().writeSectionSeparator().

Overrides:

writeSectionSeparator in class EntitySqlGenerator

Throws:

IOException - if the writer throws such an exception

writeStatement

public void writeStatement(EntityStatement stmt)
                    throws IOException

Throws:

IOException

getConnection

@Generated(value="lombok")
public Connection getConnection()

The database connection that was used when creating this generator.

getStatementsCount

@Generated(value="lombok")
public long getStatementsCount()

The count of statements that we executed up to now.