Connection conn=getJDBCType4Connection("sqlserver",JDBC_TransactionType.MB_TRANSACTION_AUTO); //Connection conn=getJDBCType4Connection("TTT",JDBC_TransactionType.MB_TRANSACTION_AUTO); Statement statement; statement = conn.createStatement(); Statement statement2 = conn.createStatement(); ResultSet resultSet = statement.executeQuery("select w from tb_test"); int r=0; System.out.println("输出结果集:====================================开始"); while (resultSet.next()) { r++; statement2.executeUpdate("insert into tb_to_test(w) values('"+resultSet.getString("w")+"')"); } System.out.println("输出结果集:====================================结束"); } catch (Exception e) { e.printStackTrace(); String s = e.getMessage(); File f = new File("c:1.txt"); try { FileOutputStream fos = new FileOutputStream(f); fos.write(s.getBytes()); fos.flush(); fos.close(); } catch (IOException e1) { // TODO 自动生成 catch 块 e1.printStackTrace(); } }
[BIPmsgs:6231]BIP6231E: 节点中发生错误:Broker 'MB7BROKER'; Execution Group 'default'; Message Flow 'test_sqlserver'; Node 'Java 计算'; Node Type 'Test_sqlserver_Java 异常详细信息: message: com.microsoft.sqlserver.jdbc.SQLServerConnectionPoolDataSource stack trace: [java.net.URLClassLoader.findClass(URLClassLoader.java:434) com.ibm.broker.classloading.JavaResourceClassLoader.findClass(JavaResourceClassLoader.java:146) com.ibm.broker.classloading.SharedClassLoader.findClass(SharedClassLoader.java:162) java.lang.ClassLoader.loadClass(ClassLoader.java:660) java.lang.ClassLoader.loadClass(ClassLoader.java:626) com.ibm.broker.jdbctype4.jdbcdbasemgr.JDBCType4Connection.createXAConnection(JDBCType4Connection.java:180) com.ibm.broker.jdbctype4.jdbcdbasemgr.JDBCType4Connection.getT4NodeConnection(JDBCType4Connection.java:1137) com.ibm.broker.jdbctype4.localtrxn.JDBCType4SinglePhaseTrxnHandler.getConnection(JDBCType4SinglePhaseTrxnHandler.java:246) com.ibm.broker.jdbctype4.connfact.JDBCType4ConnectionFactory.getConnection(JDBCType4ConnectionFactory.java:155) sun.reflect.GeneratedMethodAccessor5.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:37) java.lang.reflect.Method.invoke(Method.java:611) com.ibm.broker.plugin.MbNode.getJDBCType4Connection(MbNode.java:1551) sqlserver.com.Test_sqlserver_Java.evaluate(Test_sqlserver_Java.java:26) com.ibm.broker.javacompute.MbRuntimeJavaComputeNode.evaluate(MbRuntimeJavaComputeNode.java:232) com.ibm.broker.plugin.MbNode.evaluate(MbNode.java:1469)] 节点生成错误消息。 如果您无法确定问题的起因,请与 IBM 支持中心联系。 : Problem encountered obtaining JDBC connection
附件:
sqljdbc_4.0.2206.100_chs.tar.gz (2.19 MB)
sqljdbc_4.0.2206.100_chs.exe.zip (4.03 MB)