Package org.fastnate.generator.statements

Class LiquibaseStatementsWriter

java.lang.Object

org.fastnate.generator.statements.AbstractStatementsWriter

org.fastnate.generator.statements.LiquibaseStatementsWriter

All Implemented Interfaces:

Closeable, AutoCloseable, StatementsWriter

public class LiquibaseStatementsWriter
extends AbstractStatementsWriter

Generates statements for the Liquibase changelog file.

Author:

Tobias Liefke

See Also:

• Liquibase on the web

Nested Class Summary

Nested classes/interfaces inherited from class org.fastnate.generator.statements.AbstractStatementsWriter

AbstractStatementsWriter.AbstractTableStatement, AbstractStatementsWriter.InsertStatement, AbstractStatementsWriter.PlainStatement, AbstractStatementsWriter.UpdateStatement

Field Summary

Fields

Modifier and Type	Field	Description
private String	changeSetAuthour	The author of the next created change set.
private String	changeSetComment	The comment of the next created change set.
private String	changeSetId	The ID of the next created change set.
private boolean	changeSetStarted	Indicates if we are currently in a changeSet.
private static final RelativeDate.Precision[]	DATE_PRECISIONS
private final GeneratorDialect	dialect	The current database dialect (in case any plain SQL statement needs to be written).
private static final org.apache.commons.lang3.time.FastDateFormat	ISO_DATETIMESECONDS_FORMAT
static final String	OUTPUT_FILE_KEY	Settings key for the generated XML file, if not given in the constructor.
private OutputStream	outputStream	The outputstream to close, if this writer is closed.
private final boolean	relativeDatesSupported	Indicates if our liquibase version supports relative dates.
static final String	VERSION_KEY	Settings key for the generated liquibase version, if not given in the constructor.
private final XMLStreamWriter	writer	The receiver of our XML elements.

Constructor Summary

Constructors

Constructor	Description
LiquibaseStatementsWriter(OutputStream outputStream, String version)	Creates a new writer which generates an XML file with "UTF-8" encoding and use the H2 dialect for any plain statement.
LiquibaseStatementsWriter(XMLStreamWriter writer, String version)	Creates a new writer which uses H2 for any plain statement.
LiquibaseStatementsWriter(GeneratorContext context)	Creates a new writer which generates an XML file with "UTF-8" encoding.
LiquibaseStatementsWriter(GeneratorDialect dialect, OutputStream outputStream, String version)	Creates a new writer which generates an XML file with "UTF-8" encoding.
LiquibaseStatementsWriter(GeneratorDialect dialect, XMLStreamWriter writer, String version)	Creates a new writer.

Method Summary

Modifier and Type	Method	Description
void	close()	Writes the remaining elements.
private void	ensureChangeSetStarted()
void	flush()	Flushes any open statements.
String	getChangeSetAuthour()	The author of the next created change set.
String	getChangeSetComment()	The comment of the next created change set.
String	getChangeSetId()	The ID of the next created change set.
GeneratorDialect	getDialect()	The current database dialect (in case any plain SQL statement needs to be written).
XMLStreamWriter	getWriter()	The receiver of our XML elements.
boolean	isChangeSetStarted()	Indicates if we are currently in a changeSet.
boolean	isRelativeDatesSupported()	Indicates if our liquibase version supports relative dates.
void	startNextChangeSet(String id, String author, String comment)	Closes the current change set (if any was started) and sets the infos of the next change set.
private void	writeColumnExpression(ColumnExpression expression)
void	writeComment(String comment)	Writes a SQL comment to the target.
private void	writeDateExpression(ColumnExpression expression, Date value, Date databaseValue)
void	writePlainStatement(GeneratorDialect currentDialect, String sql)	Writes a plain SQL statement.
private void	writePrimitiveExpression(PrimitiveColumnExpression<?> expression)
private void	writeRelativeDateExpression(ColumnExpression expression, Date value)
void	writeSectionSeparator()	Writes a new line to the target file to separate different sections in the SQL file.
private void	writeSequenceExpression(SequenceValueExpression expression)
void	writeStatement(EntityStatement statement)	Writes the given statement to a file or database.
private void	writeString(ColumnExpression expression, String value)
private void	writeTableStatement(AbstractStatementsWriter.AbstractTableStatement insert)

Methods inherited from class org.fastnate.generator.statements.AbstractStatementsWriter

createInsertStatement, createPlainStatement, createUpdateStatement

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.fastnate.generator.statements.StatementsWriter

truncateTables

Field Details

OUTPUT_FILE_KEY

public static final String OUTPUT_FILE_KEY

Settings key for the generated XML file, if not given in the constructor.

See Also:

• Constant Field Values

VERSION_KEY

public static final String VERSION_KEY

Settings key for the generated liquibase version, if not given in the constructor.

See Also:

• Constant Field Values

DATE_PRECISIONS

private static final RelativeDate.Precision[] DATE_PRECISIONS

ISO_DATETIMESECONDS_FORMAT

private static final org.apache.commons.lang3.time.FastDateFormat ISO_DATETIMESECONDS_FORMAT

dialect

private final GeneratorDialect dialect

The current database dialect (in case any plain SQL statement needs to be written).

writer

private final XMLStreamWriter writer

The receiver of our XML elements.

relativeDatesSupported

private final boolean relativeDatesSupported

Indicates if our liquibase version supports relative dates.

outputStream

private OutputStream outputStream

The outputstream to close, if this writer is closed.

changeSetId

private String changeSetId

The ID of the next created change set.

changeSetAuthour

private String changeSetAuthour

The author of the next created change set.

changeSetComment

private String changeSetComment

The comment of the next created change set.

changeSetStarted

private boolean changeSetStarted

Indicates if we are currently in a changeSet.

Constructor Details

LiquibaseStatementsWriter

public LiquibaseStatementsWriter(GeneratorContext context)
                          throws XMLStreamException,
FileNotFoundException

Creates a new writer which generates an XML file with "UTF-8" encoding.

Parameters:

context - contains all the settings that we need to build the file

Throws:

XMLStreamException - if already the root element could not be created

FileNotFoundException - if the parent directory does not exist

LiquibaseStatementsWriter

public LiquibaseStatementsWriter(GeneratorDialect dialect,
 OutputStream outputStream,
 String version)
                          throws XMLStreamException

Creates a new writer which generates an XML file with "UTF-8" encoding.

Parameters:

dialect - the database dialect for any plain SQL statement

outputStream - the target stream, will be close when this wirter is closed

version - the liquibase version - this is only for the referenced schema and won't change anything else

Throws:

XMLStreamException - if already the root element could not be created

LiquibaseStatementsWriter

public LiquibaseStatementsWriter(GeneratorDialect dialect,
 XMLStreamWriter writer,
 String version)
                          throws XMLStreamException

Creates a new writer.

Parameters:

dialect - the database dialect for any plain SQL statement

writer - the stream writer for generating the XML

version - the liquibase version - this is only for the referenced schema and won't change anything else

Throws:

XMLStreamException - if already the root element could not be created

LiquibaseStatementsWriter

public LiquibaseStatementsWriter(OutputStream outputStream,
 String version)
                          throws XMLStreamException

Creates a new writer which generates an XML file with "UTF-8" encoding and use the H2 dialect for any plain statement.

Parameters:

outputStream - the target stream, will be close when this wirter is closed

version - the liquibase version - this is only for the referenced schema and won't change anything else

Throws:

XMLStreamException - if already the root element could not be created

LiquibaseStatementsWriter

public LiquibaseStatementsWriter(XMLStreamWriter writer,
 String version)
                          throws XMLStreamException

Creates a new writer which uses H2 for any plain statement.

Parameters:

writer - the stream writer for generating the XML

version - the liquibase version - this is only for the referenced schema and won't change anything else

Throws:

XMLStreamException - if already the root element could not be created

Method Details

close

public void close()
           throws IOException

Writes the remaining elements. This will not close the output stream, you will need to close it manually.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractStatementsWriter

Throws:

IOException

ensureChangeSetStarted

private void ensureChangeSetStarted()
                             throws XMLStreamException

Throws:

XMLStreamException

flush

public void flush()
           throws IOException

Description copied from interface: StatementsWriter

Flushes any open statements.

Specified by:

flush in interface StatementsWriter

Overrides:

flush in class AbstractStatementsWriter

Throws:

IOException - if the target throws an exception

startNextChangeSet

public void startNextChangeSet(String id,
 String author,
 String comment)
                        throws XMLStreamException

Closes the current change set (if any was started) and sets the infos of the next change set.

Parameters:

id - the ID of the next change set

author - the author of the next change set

comment - the (optional) comment of the next change set

Throws:

XMLStreamException - if there is an error during closing the current change set

writeColumnExpression

private void writeColumnExpression(ColumnExpression expression)
                            throws XMLStreamException

Throws:

XMLStreamException

writeComment

public void writeComment(String comment)
                  throws IOException

Description copied from interface: StatementsWriter

Writes a SQL comment to the target.

Specified by:

writeComment in interface StatementsWriter

Overrides:

writeComment in class AbstractStatementsWriter

Parameters:

comment - the comment to write

Throws:

IOException - if the target throws an exception

writeDateExpression

private void writeDateExpression(ColumnExpression expression,
 Date value,
 Date databaseValue)
                          throws XMLStreamException

Throws:

XMLStreamException

writePlainStatement

public void writePlainStatement(GeneratorDialect currentDialect,
 String sql)
                         throws IOException

Description copied from interface: StatementsWriter

Writes a plain SQL statement. Shortcut for writeStatement(createPlainStatement(sql), dialect).

Parameters:

currentDialect - the current database dialect

sql - the content of the SQL statement

Throws:

IOException - if the file or database throws an exception

writePrimitiveExpression

private void writePrimitiveExpression(PrimitiveColumnExpression<?> expression)
                               throws XMLStreamException

Throws:

XMLStreamException

writeRelativeDateExpression

private void writeRelativeDateExpression(ColumnExpression expression,
 Date value)
                                  throws XMLStreamException

Throws:

XMLStreamException

writeSectionSeparator

public void writeSectionSeparator()
                           throws IOException

Description copied from interface: StatementsWriter

Writes a new line to the target file to separate different sections in the SQL file.

Specified by:

writeSectionSeparator in interface StatementsWriter

Overrides:

writeSectionSeparator in class AbstractStatementsWriter

Throws:

IOException - if the target throws such an exception

writeSequenceExpression

private void writeSequenceExpression(SequenceValueExpression expression)
                              throws XMLStreamException

Throws:

XMLStreamException

writeStatement

public void writeStatement(EntityStatement statement)
                    throws IOException

Description copied from interface: StatementsWriter

Writes the given statement to a file or database.

Parameters:

statement - contains the values to write

Throws:

IOException - if the file or database throws an exception

writeString

private void writeString(ColumnExpression expression,
 String value)
                  throws XMLStreamException

Throws:

XMLStreamException

writeTableStatement

private void writeTableStatement(AbstractStatementsWriter.AbstractTableStatement insert)
                          throws XMLStreamException

Throws:

XMLStreamException

getDialect

public GeneratorDialect getDialect()

The current database dialect (in case any plain SQL statement needs to be written).

getWriter

public XMLStreamWriter getWriter()

The receiver of our XML elements.

isRelativeDatesSupported

public boolean isRelativeDatesSupported()

Indicates if our liquibase version supports relative dates.

getChangeSetId

public String getChangeSetId()

The ID of the next created change set.

getChangeSetAuthour

public String getChangeSetAuthour()

The author of the next created change set.

getChangeSetComment

public String getChangeSetComment()

The comment of the next created change set.

isChangeSetStarted

public boolean isChangeSetStarted()

Indicates if we are currently in a changeSet.