public class Bcp extends ngmObject
name | required | default | description |
Application.LogFile | * | NA | log filename |
Application.Name | * | NA | application name |
Database.JDBCDriver | * | NA | jdbc driver class name. |
Database.ConnectionURL | * | NA | jdbc connection url |
Database.User | * | NA | table owner user name |
Database.Password | * | NA | table owner user password |
Database.Password.CipherProcessor | * | NA | CipherProcessor class name for password |
Bcp.AutoCommit | false | true/false | |
Bcp.Commit.ForEach | false | true/false. If true, bcp will call "commit" after each line. | |
Bcp.DebugMode | false | true/false | |
applicationname.PreProcess | - | DeleteAll / Truncate | |
Bcp.LineSeparator | depends on the platform | CR/LF/CRLF | |
Bcp.CRLFShuldBeRemoved | true | true/false | |
Bcp.ColumnDelimiter | , | delimiter character | |
Bcp.DontTrim | false | don't trim the read line when true | |
Bcp.QuateStringColumns | true | true/false | |
Bcp.QuateAllColumns | false | true/false | |
Bcp.Common.Date.Format | "yyyy/MM/dd HH:mm:ss" | common format for date columns | |
Bcp.Column.<column_name in lower case>.Date.Format | common format | format for the specified column | |
Bcp.VerboseCounter | 0 | count | |
Bcp.RushMode | false | true/false. if true, go through errors | |
Bcp.Foldername | - | the name of the folder which holds the target file | |
Bcp.SkippedRecords.Foldername | same as "Bcp.Foldername" | the name of the folder where skipped records file will be stored | |
Bcp.File.Encoding | - | file i/o encoding type name | |
Bcp.File.ReadBuffer.Size | 64 | file read buffer size in "KB" | |
Bcp.File.LeadingLinesToBeSkipped | 0 | number of lines to be skipped at the beginning of the input file. | |
applicationname.Condition | - | condition to extract | |
applicationname.SkippedRecordsFilename | filename.skipped | skipped records filename | |
Bcp.Initializer.Class | - | initializer class name. The initializer class must implements com.ngMAT.tools.BcpInitializer . | |
Bcp.RecordProcessor.Class | - | optional record processor class name. The optional record processor class must implements com.ngMAT.tools.BcpRecordProcessor. | |
Bcp.RecordProcessor.Timing | after | before/after. The timing for the optional record processor class to be called doProcess before/after the bcp in transaction. | |
Bcp.Wrapupper.Class | - | wrapupper class name. The wrapupper class must implements com.ngMAT.tools.BcpWrapupper . | |
Bcp.CleanupChars | - | enumeration of target chars to be removed | |
Bcp.TargetColumns | NA | csv list of target column names. | |
Bcp.Update.Keys | (*) | NA | csv list of key column names. This is required to process "update" |
Bcp.Update.EnableAutoInsert | true | If true, the record will be updated or inserted. | |
Bcp.Process.Limit.Count | NA | Maximum count to process. | |
Bcp.Process.Range.Index.From | NA | the index of first record to process. 1 or more. | |
Bcp.Process.Range.Index.To | NA | the last index of first record to process. 1 or more. | |
Bcp.Convert.<column name>.From | NA | "from" values dsv. values sould be delimited with "Bcp.ColumnDelimiter" char. | |
Bcp.Convert.<column name>.To | NA | "to" values dsv. values sould be delimited with "Bcp.ColumnDelimiter" char. |
修飾子とタイプ | クラスと説明 |
---|---|
class |
Bcp.ColumnInfo |
class |
Bcp.Counters |
class |
Bcp.DatabaseObjectNotFoundException |
class |
Bcp.Params |
修飾子とタイプ | フィールドと説明 |
---|---|
protected java.lang.String |
column_names_csv_string |
java.util.Vector<Bcp.ColumnInfo> |
columns |
java.util.Hashtable<java.lang.String,Bcp.ColumnInfo> |
columns_ht |
Bcp.Counters |
counter |
Log |
cout |
boolean |
has_lob_columns |
java.util.Vector<Bcp.ColumnInfo> |
lob_columns |
Bcp.Params |
param |
C_BACKSLASH, C_BLOCK_CLOSE, C_BLOCK_OPEN, C_COMMA, C_CR, C_DOUBLE_BYTE_SPACE, C_DOUBLE_QUATATION, C_DOUBLE_QUOTATION, C_EQUAL, C_HYPHEN, C_LF, C_SINGLE_QUATATION, C_SINGLE_QUOTATION, C_SPACE, C_TAB, S_BACKSLASH, S_BLOCK_CLOSE, S_BLOCK_OPEN, S_COMMA, S_CR, S_CRLF, S_DOUBLE_QUATATION, S_DOUBLE_QUOTATION, S_EQUAL, S_HYPHEN, S_LF, S_SINGLE_QUATATION, S_SINGLE_QUOTATION, S_SPACE, S_TAB
コンストラクタと説明 |
---|
Bcp(java.lang.Object creator,
java.util.Properties prop) |
Bcp(java.lang.Object creator,
java.util.Properties prop,
java.sql.Connection con) |
Bcp(java.util.Properties prop) |
Bcp(java.util.Properties prop,
java.sql.Connection con) |
修飾子とタイプ | メソッドと説明 |
---|---|
static void |
_main(java.lang.String[] argv) |
void |
bcpIn() |
void |
bcpIn(java.util.Vector<DSV> data)
process "bcp in".
|
void |
bcpOut() |
void |
bcpUpdate() |
void |
bcpUpdate(java.util.Vector<DSV> v) |
java.lang.String |
cleanUpChars(java.lang.String d) |
void |
closeBcpInFile() |
void |
closeBcpOutFile() |
java.lang.String |
createBcpOutSelectSQL() |
void |
doBcp() |
void |
doBcpIn() |
void |
doBcpOut() |
java.lang.String |
getApplicationName() |
java.sql.Connection |
getAssignedConnection() |
java.io.BufferedReader |
getBcpInReader() |
java.sql.ResultSet |
getBcpOutResultSet() |
java.io.PrintWriter |
getBcpOutWriter() |
Bcp.ColumnInfo |
getColumnInfo(java.lang.String column_name) |
boolean |
getCommitRequired() |
java.sql.Connection |
getConnection() |
java.lang.Object |
getCreator() |
java.lang.String |
getFileEncodingType() |
java.lang.String |
getFileName() |
java.lang.Throwable |
getLastException() |
java.lang.Object |
getObject(java.lang.String key)
get the object you set with
(String,Object) #setObject(String, Object) . |
java.lang.String |
getTargetFileName() |
java.lang.String |
getTargetTableName() |
void |
initBcpIn() |
void |
initBcpOut() |
java.util.Vector<DSV> |
loadDSVFile() |
static void |
main(java.lang.String[] argv) |
void |
openBcpInFile() |
void |
openBcpOutFile() |
void |
releaseConnection(java.sql.Connection con) |
static java.lang.String |
removeChars(java.lang.String OriginalString,
java.lang.String TargetChars) |
void |
removeConnection() |
java.lang.Object |
removeObject(java.lang.String key)
remove the object you set with
(String,Object) setObject (String,Object) . |
void |
setBcpInReader(java.io.BufferedReader br) |
void |
setBcpOutResultSet(java.sql.ResultSet rs) |
void |
setBcpOutWriter(java.io.PrintWriter pw) |
void |
setCommitRequired(boolean commit_required) |
void |
setConnection(java.sql.Connection con) |
void |
setFileEncodingType(java.lang.String file_encoding_type) |
void |
setFileName(java.lang.String file_name) |
void |
setObject(java.lang.String key,
java.lang.Object value)
set anything you want into the working hash map.
|
void |
setSkippedRecordsFileName(java.lang.String skipped_records_filename) |
protected void |
skipLeadingLines(java.io.BufferedReader br) |
protected void |
sortColumnInfo() |
void |
wrapup() |
void |
wrapupBcpIn() |
void |
wrapupBcpOut() |
clone, debug, debug, equals_n, equals_n2, getBooleanProperty, getBooleanProperty, getGroupedProperties, getIntProperty, getIntProperty, getLog, getLongProperty, getLongProperty, getProperties, getPropertiesForMe, getProperty, getProperty, getShortProperty, getShortProperty, setLog, setNgmObject, setProperties, sysoutprintln
public java.util.Vector<Bcp.ColumnInfo> columns
public java.util.Hashtable<java.lang.String,Bcp.ColumnInfo> columns_ht
public java.util.Vector<Bcp.ColumnInfo> lob_columns
public boolean has_lob_columns
protected java.lang.String column_names_csv_string
public Bcp.Params param
public Log cout
public Bcp.Counters counter
public Bcp(java.lang.Object creator, java.util.Properties prop) throws java.lang.ClassNotFoundException, java.sql.SQLException
java.lang.ClassNotFoundException
java.sql.SQLException
public Bcp(java.lang.Object creator, java.util.Properties prop, java.sql.Connection con) throws java.lang.ClassNotFoundException, java.sql.SQLException
java.lang.ClassNotFoundException
java.sql.SQLException
public Bcp(java.util.Properties prop) throws java.lang.ClassNotFoundException, java.sql.SQLException
java.lang.ClassNotFoundException
java.sql.SQLException
public Bcp(java.util.Properties prop, java.sql.Connection con) throws java.lang.ClassNotFoundException, java.sql.SQLException
java.lang.ClassNotFoundException
java.sql.SQLException
public void setConnection(java.sql.Connection con)
public void removeConnection()
public java.lang.Object getCreator()
public void setObject(java.lang.String key, java.lang.Object value)
key
- value
- public java.lang.Object getObject(java.lang.String key)
(String,Object) #setObject(String, Object)
.key
- public java.lang.Object removeObject(java.lang.String key)
(String,Object) setObject (String,Object)
.key
- public void wrapup()
public java.lang.String getApplicationName()
public java.lang.String getTargetTableName()
public java.lang.String getTargetFileName()
public boolean getCommitRequired()
public void setCommitRequired(boolean commit_required)
public java.lang.String getFileName()
public void setFileName(java.lang.String file_name)
public void setSkippedRecordsFileName(java.lang.String skipped_records_filename)
public java.lang.String getFileEncodingType()
public void setFileEncodingType(java.lang.String file_encoding_type)
public java.sql.Connection getConnection() throws java.sql.SQLException, java.lang.ClassNotFoundException
java.sql.SQLException
java.lang.ClassNotFoundException
public void releaseConnection(java.sql.Connection con) throws java.sql.SQLException
java.sql.SQLException
public java.sql.Connection getAssignedConnection()
public void setBcpOutResultSet(java.sql.ResultSet rs)
public java.sql.ResultSet getBcpOutResultSet()
public void setBcpOutWriter(java.io.PrintWriter pw)
public java.io.PrintWriter getBcpOutWriter()
public void openBcpOutFile() throws java.io.IOException
java.io.IOException
public void closeBcpOutFile()
public void initBcpOut() throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public java.lang.String createBcpOutSelectSQL()
public void wrapupBcpOut() throws java.sql.SQLException
java.sql.SQLException
public void bcpOut() throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public void doBcpOut() throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
public Bcp.ColumnInfo getColumnInfo(java.lang.String column_name)
protected void sortColumnInfo()
public java.lang.String cleanUpChars(java.lang.String d)
public static java.lang.String removeChars(java.lang.String OriginalString, java.lang.String TargetChars)
public void setBcpInReader(java.io.BufferedReader br)
public java.io.BufferedReader getBcpInReader()
public java.lang.Throwable getLastException()
protected void skipLeadingLines(java.io.BufferedReader br) throws java.io.IOException
java.io.IOException
public void initBcpIn() throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public void openBcpInFile() throws java.io.IOException
java.io.IOException
public void closeBcpInFile() throws java.io.IOException
java.io.IOException
public void doBcp() throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public void bcpIn() throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public void wrapupBcpIn() throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
public void doBcpIn() throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
public void bcpIn(java.util.Vector<DSV> data) throws java.lang.ClassNotFoundException, java.sql.SQLException
DSV
.data
- java.lang.ClassNotFoundException
java.sql.SQLException
public void bcpUpdate() throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public void bcpUpdate(java.util.Vector<DSV> v) throws java.lang.ClassNotFoundException, java.io.IOException, java.sql.SQLException
java.lang.ClassNotFoundException
java.io.IOException
java.sql.SQLException
public java.util.Vector<DSV> loadDSVFile() throws java.io.IOException
java.io.IOException
public static void main(java.lang.String[] argv)
public static void _main(java.lang.String[] argv)