Java+XML将数据导入SQL Server中 - 编程入门网
作者 佚名技术
来源 NET编程
浏览
发布时间 2012-06-23
| ction 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(),rcPara.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(); } } protected boolean alreadyin(String tname,String colname, String value) { int result; ResultSet rst=null; try { //执行SQL语句 String query = "select "+colname+" from |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
你可能对下面的文章感兴趣
关于Java+XML将数据导入SQL Server中 - 编程入门网的所有评论
