com.northconcepts.datapipeline.sql.mysql

Class Upsert

java.lang.Object

com.northconcepts.datapipeline.jdbc.sql.SqlPart

com.northconcepts.datapipeline.sql.mysql.MySqlPart

com.northconcepts.datapipeline.sql.mysql.Upsert

public class Upsert
extends MySqlPart

Generates an upsert statement for MySQL.

Sample Generated SQL:

INSERT INTO `tableName` (`col1`, `col2`)
VALUES (val1, val2),

       (val1, val2,

       (val1, val2)

ON DUPLICATE KEY UPDATE `col1` = VALUES(`col1`), `col2` = VALUES(`col2`);

Constructor Summary

Constructors

Constructor and Description
Upsert(String table)

Method Summary

Modifier and Type	Method and Description
Upsert	add(String columnName, Object value)
void	collectSqlFragment(CodeWriter writer)
InsertRow	getLastRow()
List<InsertRow>	getRows()
String	getTable()
Upsert	nextRow()
Upsert	setPretty(boolean pretty) Indicates if line breaks and indentations should be added to output upsert statement (default false). Example output (pretty = true): INSERT INTO `tableName` (`col1`, `col2`) VALUES (val1, val2),

Methods inherited from class com.northconcepts.datapipeline.sql.mysql.MySqlPart

escapeKeyword, placeBackTicks

Methods inherited from class com.northconcepts.datapipeline.jdbc.sql.SqlPart

collectParameterValues, getParameterValues, getSqlFragment, isPretty, printSqlParts, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

Upsert

public Upsert(String table)

Method Detail

setPretty

public Upsert setPretty(boolean pretty)

Indicates if line breaks and indentations should be added to output upsert statement (default false).

Example output (pretty = true):
INSERT INTO `tableName` (`col1`, `col2`)
VALUES (val1, val2),

       (val1, val2),

       (val1, val2)

ON DUPLICATE KEY UPDATE `col1` = VALUES(`col1`), `col2` = VALUES(`col2`);
Example output (pretty = false):
INSERT INTO `tableName` (`col1`, `col2`) VALUES (val1, val2), (val1, val2), (val1, val2) ON DUPLICATE KEY UPDATE `col1` = VALUES(`col1`), `col2` = VALUES(`col2`);

Overrides:

setPretty in class SqlPart

getTable

public String getTable()

nextRow

public Upsert nextRow()

add

public Upsert add(String columnName,
                  Object value)

getRows

public List<InsertRow> getRows()

getLastRow

public InsertRow getLastRow()

collectSqlFragment

public void collectSqlFragment(CodeWriter writer)

Specified by:

collectSqlFragment in class SqlPart