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)
C:Program FilesIBMMQSI7.0bin>mqsichangeproperties MB7BROKER -c JDBCProvider s -o sqlserver -n user -v sa BIP8984W: 未找到可配置服务的对象名“JDBCProviders : sqlserver : user”。 用户试图删除或修改不存在或对于 UserDefined 类型无效的可配置服务对象名称。 使用 mqsireportproperties 命令检查现有可配置服务的名称。然后修改外部资源的对象名 并再次发出命令。 BIP2087E: 代理 MB7BROKER 无法处理内部配置消息。 未能成功处理整个内部配置消息。 使用该消息后面的消息来确定故障原因。如果查看这些消息后还是无法解决问题,请与 IBM 支持中心联系。启用服务跟踪可能有助于确定故障起因。 BIP8036E: 接收到否定响应。 此命令将内部配置消息发送到代理,接收到的响应表明内部配置消息失败。 检查 WebSphere MQ 传送是否可用。 检查系统日志以获取进一步信息。
--配置命令 --创建配置服务(Oracle JDBC) mqsicreateconfigurableservice MB7BROKER -c JDBCProviders -o sqlserver -n connectionUrlFormat,connectionUrlFormatAttr1,description,jarsURL,portNumber,serverName,type4DatasourceClassName,type4DriverClassName -v "jdbc:sqlserver://127.0.0.1:1433; DatabaseName=jbq_sbk,jbq_sbk,Simplified Database Routing Sample Database,D:sqljdbcsqljdbc_4.0chs,1433,127.0.0.1,com.microsoft.sqlserver.jdbc.SQLServerXADataSource,com.microsoft.sqlserver.jdbc.SQLServerDriver" --将安全标识挂接到配置服务 mqsichangeproperties MB7BROKER -c JDBCProviders -o sqlserver -n securityIdentity -v sqlmySecurityIdentity --设置安全标识(数据库连接用户及密码) mqsisetdbparms MB7BROKER -n jdbc::sqlmySecurityIdentity -u mySa -p mySa --重启代理 mqsireload MB7BROKER -e default --javaCompute节点代码 Connection conn=getJDBCType4Connection("sqlserver",JDBC_TransactionType.MB_TRANSACTION_AUTO); --报错信息 [BIPmsgs:6233]BIP6233E: 节点中发生错误:Broker 'MB7BROKER'; Execution Group 'default'; Message Flow 'myMf'; Node 'myMsfService.Extract'; Node Type 'MyMfJava 建立到给定数据库 URL 的连接时发生问题:jdbc:sqlserver://127.0.0.1:1433; DatabaseName=master 异常详细信息: error message: 用户 '' 登录失败。 ClientConnectionId:774f3530-e872-492f-a27f-1d8cf353c634, SQLState value: S0001, vendor's error code: 18456, stack trace: [com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError(SQLServerException.java:216) com.microsoft.sqlserver.jdbc.TDSTokenHandler.onEOF(tdsparser.java:254) com.microsoft.sqlserver.jdbc.TDSParser.parse(tdsparser.java:84) com.microsoft.sqlserver.jdbc.SQLServerConnection.sendLogon(SQLServerConnection.java:2908) com.microsoft.sqlserver.jdbc.SQLServerConnection.logon(SQLServerConnection.java:2234) com.microsoft.sqlserver.jdbc.SQLServerConnection.access$000(SQLServerConnection.java:41) com.microsoft.sqlserver.jdbc.SQLServerConnection$LogonCommand.doExecute(SQLServerConnection.java:2220) com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:5696) com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:1715) com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(SQLServerConnection.java:1326) com.microsoft.sqlserver.jdbc.SQLServerConnection.login(SQLServerConnection.java:991) com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(SQLServerConnection.java:827) com.microsoft.sqlserver.jdbc.SQLServerDataSource.getConnectionInternal(SQLServerDataSource.java:621) com.microsoft.sqlserver.jdbc.SQLServerPooledConnection.createNewConnection(SQLServerPooledConnection.java:60) com.microsoft.sqlserver.jdbc.SQLServerPooledConnection.收起(SQLServerPooledConnection.java:42) com.microsoft.sqlserver.jdbc.SQLServerXAConnection. (SQLServerXAConnection.java:30) com.microsoft.sqlserver.jdbc.SQLServerXADataSource.getXAConnection(SQLServerXADataSource.java:51) com.microsoft.sqlserver.jdbc.SQLServerXADataSource.getXAConnection(SQLServerXADataSource.java:84) com.ibm.broker.jdbctype4.jdbcdbasemgr.JDBCType4Connection.createXAConnection(JDBCType4Connection.java:238) 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.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:60) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:37) java.lang.reflect.Method.invoke(Method.java:611) com.ibm.broker.plugin.MbNode.getJDBCType4Connection(MbNode.java:1551) myMfpJava.com.MyMfJava.evaluate(MyMfJava.java:37) com.ibm.broker.javacompute.MbRuntimeJavaComputeNode.evaluate(MbRuntimeJavaComputeNode.java:232) com.ibm.broker.plugin.MbNode.evaluate(MbNode.java:1469) com.ibm.broker.plugin.MbRoute._propagate(Native Method) com.ibm.broker.plugin.MbRoute.propagate(MbRoute.java:87) com.ibm.broker.soap.SoapExtractNode.routeToOperationLabelNode(SoapExtractNode.java:386) com.ibm.broker.soap.SoapExtractNode.evaluate(SoapExtractNode.java:176) com.ibm.broker.plugin.MbNode.evaluate(MbNode.java:1469)] 节点无法建立到给定数据库 URL 的连接。 请与 WebSphere Message Broker 管理员联系。 : Problem encountered obtaining JDBC connection