文件dbinput.java则是真正的数据拷贝部分：
　　
　　import java.sql.*;
　　
　　public class dbinput
　　
　　{
　　
　　　　connection src=null;
　　
　　　　connection dest=null;
　　
　　　　connection connformax=null;
　　
　　　　connpara srcpara;
　　
　　　　connpara destpara;
　　
　　　　public dbinput(){}
　　
　　　　
　　
　　　　public void dbinit()
　　
　　　　{
　　
　　　　　　dbxmlparser xmlparser=new dbxmlparser("dbs.xml");
　　
　　　　　　srcpara=xmlparser.getsource();
　　
　　　　　　destpara=xmlparser.getdest();
　　
　　　　　　try {
　　
　　　　　　　 class.forname("sun.jdbc.odbc.jdbcodbcdriver" );
　　
　　　　　　　 class.forname("com.microsoft.jdbc.sqlserver.sqlserverdriver");
　　
　　　　　　　 src = drivermanager.getconnection( srcpara.geturl(), srcpara.getusername(),srcpara.getpassword());
　　
　　　　　　　 dest =drivermanager.getconnection( destpara.geturl(), destpara.getusername(),destpara.getpassword());
　　
　　　　　　　 connformax= drivermanager.getconnection( destpara.geturl(), destpara.getusername(),destpara.getpassword());
　　
　　　　　　}
　　
　　　　　　//捕获加载驱动程序异常
　　
　　　　　　catch ( classnotfoundexception cnfex ) {
　　
　　　　　　　 system.err.println( "装载 jdbc/odbc 驱动程序失败。" );
　　
　　　　　　　 cnfex.printstacktrace();
　　
　　　　　　　 system.exit( 1 );　// terminate program
　　
　　　　　　} catch ( sqlexception ex )
　　
　　　　　　{
　　
　　　　　　　　system.err.println( "连接失败" );
　　
　　　　　　　　ex.printstacktrace();
　　
　　　　　　　　system.exit( 1 );　// terminate program
　　
　　　　　　}　　　　　
　　
　　　　}
　　
　　　　public void copyproduct()
　　
　　　　{
　　
　　　　　　statement st=null;
　　
　　　　　　resultset rset=null;
　　
　　　　　　string sqlstr;
　　
　　　　　　try {
　　
　　　　　　　 //执行sql语句
　　
　　　　　　　 string query = "select * from production";
　　
　　　　　　　 st = src.createstatement();
　　
　　　　　　　 rset = st.executequery(query);　　　　　
　　
　　　　　　　 int pid,ljid,cid,ciid;
　　
　　　　　　　 while(rset.next())
　　
　　　　　　　 {
　　
　　　　　　　 string pnumber=rset.getstring(1);
　　
　　　　　　　 string ljnumber=rset.getstring(2);
　　
　　　　　　　　string cnumber=rset.getstring(3);
　　
　　　　　　　 //插入到产品表
　　
　　　　　　　 pid=getidfromnumber("project","number",pnumber);
　　
　　　　　　　 if(pid==0) //插入一条新记录
　　
　　　　　　　 {
　　
　　　　　　　　　　pid=getmax("project");//system.out.println(pid);
　　
　　　　　　　　　　sqlstr="insert into project(id,number) values("+pid+",'"+pnumber+"')";
　　
　　　　　　　　　　execute(destpara,sqlstr);
　　
　　　　　　　 }　　　　　
　　
　　　　　　　 //插入到零件表
　　
　　　　　　　 ljid=getidfromnumber("product","number",ljnumber);
　　
　　　　　　　　if(ljid==0) //插入一条新记录
　　
　　　　　　　　{
　　
　　　　　　　　　　ljid=getmax("product");
　　
　　　　　　　　　　sqlstr="insert into product(id,pid,number) values("+ljid+","+pid+",'"+ljnumber+"')";
　　
　　　　　　　　　　execute(destpara,sqlstr);
　　
　　　　　　　　}　　　　　
　　
　　　　　　　 //插入工具表
　　
　　　　　　　　cid=getidfromnumber("componenttype","number",cnumber);
　　
　　　　　　　　if(cid==0) //插入一条新记录
　　
　　　　　　　　{
　　
　　　　　　　　　　cid=getmax("componenttype");
　　
　　　　　　　　　　sqlstr="insert into componenttype(id,aid,number) values("+cid+","+ljid+",'"+cnumber+"')";
　　
　　　　　　　　　　execute(destpara,sqlstr);
　　
　　　　　　　　}　　　　　　　　　　
　　
　　　　　　　 }
　　
　　　　　　}
　　
　　　　　　catch ( sqlexception sqlex ) {
　　
　　　　　　　 sqlex.printstacktrace();
　　
　　　　　　}　　　
　　
　　　　}