Package org.jumpmind.db.platform.kafka
Class KafkaSqlTemplate
java.lang.Object
org.jumpmind.db.sql.AbstractSqlTemplate
org.jumpmind.db.sql.AbstractJavaDriverSqlTemplate
org.jumpmind.db.platform.kafka.KafkaSqlTemplate
- All Implemented Interfaces:
ISqlTemplate
-
Field Summary
Fields inherited from class org.jumpmind.db.sql.AbstractSqlTemplate
dateOverrideToTimestamp, identifierQuoteString, log, logSqlBuilder
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.jumpmind.db.sql.AbstractJavaDriverSqlTemplate
getDatabaseMajorVersion, getDatabaseMinorVersion, getDatabaseProductVersion, getDriverName, getDriverVersion, getSqlKeywords, insertWithGeneratedKey, isDataTruncationViolation, isForeignKeyChildExistsViolation, isForeignKeyViolation, isStoresLowerCaseIdentifiers, isStoresMixedCaseQuotedIdentifiers, isStoresUpperCaseIdentifiers, isUniqueKeyViolation, queryForBlob, queryForClob, queryForCursor, queryForCursor, queryForMap, queryForObject, startSqlTransaction, startSqlTransaction, supportsGetGeneratedKeys, testConnection, update, update, update, update
Methods inherited from class org.jumpmind.db.sql.AbstractSqlTemplate
doesObjectAlreadyExist, doesObjectNotExist, expandArgs, expandSql, getUniqueKeyViolationIndexName, isDeadlock, query, query, query, query, query, query, query, query, query, query, query, query, queryForCursor, queryForCursor, queryForCursor, queryForInt, queryForInt, queryForLong, queryForMap, queryForMap, queryForObject, queryForRow, queryForString, queryWithHandler, translate, translate, update
-
Constructor Details
-
KafkaSqlTemplate
public KafkaSqlTemplate()
-
-
Method Details
-
getDatabaseProductName
- Specified by:
getDatabaseProductName
in interfaceISqlTemplate
- Specified by:
getDatabaseProductName
in classAbstractJavaDriverSqlTemplate
-