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 and 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 RelativeDate.Precision[]	DATE_PRECISIONS
private static org.apache.commons.lang.time.FastDateFormat	ISO_DATETIMESECONDS_FORMAT
static 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 boolean	relativeDatesSupported Indicates if our liquibase version supports relative dates.
static String	VERSION_KEY Settings key for the generated liquibase version, if not given in the constructor.
private XMLStreamWriter	writer The receiver of our XML elements.

Constructor Summary

Constructors

Constructor and Description
LiquibaseStatementsWriter(GeneratorContext context) Creates a new writer which generates an XML file with "UTF-8" encoding.
LiquibaseStatementsWriter(OutputStream outputStream, String version) Creates a new writer which generates an XML file with "UTF-8" encoding.
LiquibaseStatementsWriter(XMLStreamWriter writer, String version) Creates a new instance of LiquibaseStatementsWriter.

Method Summary

Modifier and Type	Method and 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.
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 dialect, 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 Detail

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.lang.time.FastDateFormat ISO_DATETIMESECONDS_FORMAT

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 Detail

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(OutputStream outputStream,
                                 String version)
                          throws XMLStreamException

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

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 instance of LiquibaseStatementsWriter.

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 Detail

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 Closeable

Specified by:

close in interface AutoCloseable

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 dialect,
                                String sql)
                         throws IOException

Description copied from interface: StatementsWriter

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

Parameters:

dialect - 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

getWriter

@Generated(value="lombok")
public XMLStreamWriter getWriter()

The receiver of our XML elements.

isRelativeDatesSupported

@Generated(value="lombok")
public boolean isRelativeDatesSupported()

Indicates if our liquibase version supports relative dates.

getChangeSetId

@Generated(value="lombok")
public String getChangeSetId()

The ID of the next created change set.

getChangeSetAuthour

@Generated(value="lombok")
public String getChangeSetAuthour()

The author of the next created change set.

getChangeSetComment

@Generated(value="lombok")
public String getChangeSetComment()

The comment of the next created change set.

isChangeSetStarted

@Generated(value="lombok")
public boolean isChangeSetStarted()

Indicates if we are currently in a changeSet.