com.northconcepts.datapipeline.sql.postgresql

Class Upsert

java.lang.Object

com.northconcepts.datapipeline.jdbc.sql.SqlPart

com.northconcepts.datapipeline.sql.postgresql.PostgresSqlPart

com.northconcepts.datapipeline.sql.postgresql.Upsert

public class Upsert
extends PostgresSqlPart

Generates an upsert statement for PostgreSQL.

Sample Generated SQL:

INSERT INTO "tableName" ("col1", "col2", "col3")
VALUES (val1, val2, val3),

       (val1, val2, val3),

       (val1, val2, val3)

ON CONFLICT ("id") DO UPDATE SET "col1" = EXCLUDED."col1", "col2" = EXCLUDED."col2", "col3" = EXCLUDED."col3"

Constructor Summary

Constructors

Constructor and Description
Upsert(String table, List<String> keyFieldNames)
Upsert(String table, String... keyFieldNames)

Method Summary

Modifier and Type	Method and Description
Upsert	add(String columnName, Object value)
void	collectSqlFragment(CodeWriter writer)
ConflictAction	getConflictAction() Indicates the action to perform on conflict (default ConflictAction.UPDATE).
List<String>	getKeyFieldNames()
InsertRow	getLastRow()
List<InsertRow>	getRows()
String	getTable()
Upsert	nextRow()
Upsert	setConflictAction(ConflictAction action)
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", "col3") VALUES (val1, val2, val3),

Methods inherited from class com.northconcepts.datapipeline.sql.postgresql.PostgresSqlPart

escapeKeyword

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,
              String... keyFieldNames)

Upsert

public Upsert(String table,
              List<String> keyFieldNames)

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", "col3")
VALUES (val1, val2, val3),

       (val1, val2, val3),

       (val1, val2, val3)

ON CONFLICT ("id") DO UPDATE SET "col1" = EXCLUDED."col1", "col2" = EXCLUDED."col2", "col3" = EXCLUDED."col3"
Example output (pretty = false):
INSERT INTO "tableName" ("col1", "col2", "col3") VALUES (val1, val2, val3), (val1, val2, val3), (val1, val2, val3) ON CONFLICT ("id") DO UPDATE SET "col1" = EXCLUDED."col1", "col2" = EXCLUDED."col2", "col3" = EXCLUDED."col3"

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

getKeyFieldNames

public List<String> getKeyFieldNames()

setConflictAction

public Upsert setConflictAction(ConflictAction action)

getConflictAction

public ConflictAction getConflictAction()

Indicates the action to perform on conflict (default ConflictAction.UPDATE).