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