com.ngMAT.tools

クラス Bcp

java.lang.Object

com.ngMAT.Common.ngmObject

com.ngMAT.tools.Bcp

すべての実装されたインタフェース:

ngmObjectFunction, java.io.Serializable, java.lang.Cloneable

直系の既知のサブクラス:

MySQLBcp, PGBcp

public class Bcp
extends ngmObject

This class provides import/export utility function for database tables for Oracle. Oracle用データベーステーブルデータ入出力ツール。
使用法：
java com.ngMAT.tools.Bcp {out|in|update} tablename filename propfilename
または
java com.ngMAT.tools.Bcp propfilename

Properties for Bcp :

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.

以下のプロパティは後者の使用法で起動したときのみ必要。Following properties are required when this start with the 2nd format.
applicationname.Tablename=tablename
applicationname.Filename=filename
applicationname.Bcp.Mode=in/out/update
それぞれ、指定がない場合は下記項目で代用される。If Bcp cannot find these properties, it uses following properties instead.
Bcp.Tablename=tablename
Bcp.Filename=filename
EZServlet 2001.3.1以降では、in/updateの際、数値項目に対してtrue/falseと認識される文字列が指定されている場合、それぞれ1/0として処理する。（対oracle）
When the value is true or false for a numeric field on bcp in/update, it will be converted into 1 or 0. This feature is available with EZServlet 2001.3.1 or later.

関連項目:

PGBcp, 直列化された形式

ネストされたクラスのサマリー

ネストされたクラス

修飾子とタイプ	クラスと説明
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

インタフェースから継承されたフィールド com.ngMAT.Common.ngmObjectFunction

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()

クラスから継承されたメソッド com.ngMAT.Common.ngmObject

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

クラスから継承されたメソッド java.lang.Object

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

フィールドの詳細

columns

public java.util.Vector<Bcp.ColumnInfo> columns

columns_ht

public java.util.Hashtable<java.lang.String,Bcp.ColumnInfo> columns_ht

lob_columns

public java.util.Vector<Bcp.ColumnInfo> lob_columns

has_lob_columns

public boolean has_lob_columns

column_names_csv_string

protected java.lang.String column_names_csv_string

param

public Bcp.Params param

cout

public Log cout

counter

public Bcp.Counters counter

コンストラクタの詳細

Bcp

public Bcp(java.lang.Object creator,
           java.util.Properties prop)
    throws java.lang.ClassNotFoundException,
           java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.sql.SQLException

Bcp

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

Bcp

public Bcp(java.util.Properties prop)
    throws java.lang.ClassNotFoundException,
           java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.sql.SQLException

Bcp

public Bcp(java.util.Properties prop,
           java.sql.Connection con)
    throws java.lang.ClassNotFoundException,
           java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.sql.SQLException

メソッドの詳細

setConnection

public void setConnection(java.sql.Connection con)

removeConnection

public void removeConnection()

getCreator

public java.lang.Object getCreator()

setObject

public void setObject(java.lang.String key,
                      java.lang.Object value)

set anything you want into the working hash map.

パラメータ:

key -

value -

getObject

public java.lang.Object getObject(java.lang.String key)

get the object you set with (String,Object) #setObject(String, Object).

パラメータ:

key -

戻り値:

Object

removeObject

public java.lang.Object removeObject(java.lang.String key)

remove the object you set with (String,Object) setObject (String,Object).

パラメータ:

key -

戻り値:

Object

wrapup

public void wrapup()

getApplicationName

public java.lang.String getApplicationName()

getTargetTableName

public java.lang.String getTargetTableName()

getTargetFileName

public java.lang.String getTargetFileName()

getCommitRequired

public boolean getCommitRequired()

setCommitRequired

public void setCommitRequired(boolean commit_required)

getFileName

public java.lang.String getFileName()

setFileName

public void setFileName(java.lang.String file_name)

setSkippedRecordsFileName

public void setSkippedRecordsFileName(java.lang.String skipped_records_filename)

getFileEncodingType

public java.lang.String getFileEncodingType()

setFileEncodingType

public void setFileEncodingType(java.lang.String file_encoding_type)

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException,
                                         java.lang.ClassNotFoundException

例外:

java.sql.SQLException

java.lang.ClassNotFoundException

releaseConnection

public void releaseConnection(java.sql.Connection con)
                       throws java.sql.SQLException

例外:

java.sql.SQLException

getAssignedConnection

public java.sql.Connection getAssignedConnection()

setBcpOutResultSet

public void setBcpOutResultSet(java.sql.ResultSet rs)

getBcpOutResultSet

public java.sql.ResultSet getBcpOutResultSet()

setBcpOutWriter

public void setBcpOutWriter(java.io.PrintWriter pw)

getBcpOutWriter

public java.io.PrintWriter getBcpOutWriter()

openBcpOutFile

public void openBcpOutFile()
                    throws java.io.IOException

例外:

java.io.IOException

closeBcpOutFile

public void closeBcpOutFile()

initBcpOut

public void initBcpOut()
                throws java.lang.ClassNotFoundException,
                       java.io.IOException,
                       java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.io.IOException

java.sql.SQLException

createBcpOutSelectSQL

public java.lang.String createBcpOutSelectSQL()

wrapupBcpOut

public void wrapupBcpOut()
                  throws java.sql.SQLException

例外:

java.sql.SQLException

bcpOut

public void bcpOut()
            throws java.lang.ClassNotFoundException,
                   java.io.IOException,
                   java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.io.IOException

java.sql.SQLException

doBcpOut

public void doBcpOut()
              throws java.io.IOException,
                     java.sql.SQLException

例外:

java.io.IOException

java.sql.SQLException

getColumnInfo

public Bcp.ColumnInfo getColumnInfo(java.lang.String column_name)

sortColumnInfo

protected void sortColumnInfo()

cleanUpChars

public java.lang.String cleanUpChars(java.lang.String d)

removeChars

public static java.lang.String removeChars(java.lang.String OriginalString,
                                           java.lang.String TargetChars)

setBcpInReader

public void setBcpInReader(java.io.BufferedReader br)

getBcpInReader

public java.io.BufferedReader getBcpInReader()

getLastException

public java.lang.Throwable getLastException()

skipLeadingLines

protected void skipLeadingLines(java.io.BufferedReader br)
                         throws java.io.IOException

例外:

java.io.IOException

initBcpIn

public void initBcpIn()
               throws java.lang.ClassNotFoundException,
                      java.io.IOException,
                      java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.io.IOException

java.sql.SQLException

openBcpInFile

public void openBcpInFile()
                   throws java.io.IOException

例外:

java.io.IOException

closeBcpInFile

public void closeBcpInFile()
                    throws java.io.IOException

例外:

java.io.IOException

doBcp

public void doBcp()
           throws java.lang.ClassNotFoundException,
                  java.io.IOException,
                  java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.io.IOException

java.sql.SQLException

bcpIn

public void bcpIn()
           throws java.lang.ClassNotFoundException,
                  java.io.IOException,
                  java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.io.IOException

java.sql.SQLException

wrapupBcpIn

public void wrapupBcpIn()
                 throws java.io.IOException,
                        java.sql.SQLException

例外:

java.io.IOException

java.sql.SQLException

doBcpIn

public void doBcpIn()
             throws java.io.IOException,
                    java.sql.SQLException

例外:

java.io.IOException

java.sql.SQLException

bcpIn

public void bcpIn(java.util.Vector<DSV> data)
           throws java.lang.ClassNotFoundException,
                  java.sql.SQLException

process "bcp in". The elements of 'data' must be instances of DSV.

パラメータ:

data -

例外:

java.lang.ClassNotFoundException

java.sql.SQLException

bcpUpdate

public void bcpUpdate()
               throws java.lang.ClassNotFoundException,
                      java.io.IOException,
                      java.sql.SQLException

例外:

java.lang.ClassNotFoundException

java.io.IOException

java.sql.SQLException

bcpUpdate

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

loadDSVFile

public java.util.Vector<DSV> loadDSVFile()
                                  throws java.io.IOException

例外:

java.io.IOException

main

public static void main(java.lang.String[] argv)

_main

public static void _main(java.lang.String[] argv)