public class JdbcWriterImpl extends AbstractRecordWriter implements JdbcWriter
| Constructor and Description |
|---|
JdbcWriterImpl(JdbcRecordStore recordStore) |
JdbcWriterImpl(JdbcRecordStore recordStore,
StatisticsMap statistics) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
commit() |
protected void |
doClose() |
void |
flush() |
int |
getBatchSize() |
String |
getHints() |
String |
getLabel() |
String |
getSqlPrefix() |
String |
getSqlSuffix() |
boolean |
isFlushBetweenTypes() |
boolean |
isQuoteColumnNames() |
boolean |
isThrowExceptions() |
void |
setBatchSize(int batchSize) |
void |
setFlushBetweenTypes(boolean flushBetweenTypes) |
void |
setHints(String hints) |
void |
setLabel(String label) |
void |
setQuoteColumnNames(boolean quoteColumnNames) |
void |
setSqlPrefix(String sqlPrefix) |
void |
setSqlSuffix(String sqlSuffix) |
void |
setThrowExceptions(boolean throwExceptions) |
String |
toString() |
void |
write(Record object) |
getRecordDefinition, isIndent, isWritable, isWriteNulls, setIndent, setProperty, setWriteNullsclose, close, close, openclearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setPropertySoft, setPropertyWeakclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitclearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeakpublic JdbcWriterImpl(JdbcRecordStore recordStore)
public JdbcWriterImpl(JdbcRecordStore recordStore, StatisticsMap statistics)
@PreDestroy public void close()
close in interface Writer<Record>close in interface AutoCloseableclose in class AbstractWriter<Record>public void commit()
protected void doClose()
public void flush()
flush in interface Writer<Record>flush in interface JdbcWriterflush in class AbstractWriter<Record>public int getBatchSize()
public String getHints()
public String getLabel()
public String getSqlPrefix()
public String getSqlSuffix()
public boolean isFlushBetweenTypes()
public boolean isQuoteColumnNames()
public boolean isThrowExceptions()
public void setBatchSize(int batchSize)
public void setFlushBetweenTypes(boolean flushBetweenTypes)
public void setHints(String hints)
hints - the hints to setpublic void setLabel(String label)
public void setQuoteColumnNames(boolean quoteColumnNames)
public void setSqlPrefix(String sqlPrefix)
public void setSqlSuffix(String sqlSuffix)
public void setThrowExceptions(boolean throwExceptions)
Copyright © 2015 Revolution Systems Inc.. All rights reserved.