org.kuali.common.impex.service
Class MySqlProducer

java.lang.Object
  org.kuali.common.impex.service.AbstractSqlProducer
      org.kuali.common.impex.service.MySqlProducer

All Implemented Interfaces:

SqlProducer

public class MySqlProducer
extends AbstractSqlProducer

Field Summary

static String

DATE_VALUE_SUFFIX

Fields inherited from class org.kuali.common.impex.service.AbstractSqlProducer

DEFAULT_BATCH_ROW_COUNT_LIMIT, DEFAULT_DATA_SIZE_LIMIT, OUTPUT_DATE_FORMAT

Constructor Summary

MySqlProducer()

Method Summary

protected String	buildBatchSql(List<DataBean> rowBeans)
protected String	getEscapedValue(Column column, String token)
protected String	getPrefix(Table table)
List<String>	getSql(Table table, BufferedReader reader) Read data lines from the .mpx file and combine them into batched up, INSERT INTO sql statements.
protected String	getSqlValue(DataBean data, SimpleDateFormat dateFormat)

Methods inherited from class org.kuali.common.impex.service.AbstractSqlProducer

batchLimitReached, buildRowData, getBatchDataSizeLimit, getBatchRowCountLimit, getColumnNamesCSV, getDate, processToken, readLineSkipHeader, setBatchDataSizeLimit, setBatchRowCountLimit

Methods inherited from class java.lang.Object

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

Field Detail

DATE_VALUE_SUFFIX

public static final String DATE_VALUE_SUFFIX

See Also:

Constant Field Values

Constructor Detail

MySqlProducer

public MySqlProducer()

Method Detail

getSql

public List<String> getSql(Table table,
                           BufferedReader reader)
                    throws IOException

Read data lines from the .mpx file and combine them into batched up, INSERT INTO sql statements. Individual data lines are merged together into SQL statements 50 lines at a time or 50K in length whichever comes first.

Throws:

IOException

buildBatchSql

protected String buildBatchSql(List<DataBean> rowBeans)

getSqlValue

protected String getSqlValue(DataBean data,
                             SimpleDateFormat dateFormat)

getPrefix

protected String getPrefix(Table table)

getEscapedValue

protected String getEscapedValue(Column column,
                                 String token)

Specified by:

getEscapedValue in class AbstractSqlProducer