深圳网站建设推荐,汕头网页设计,宝安网站制作哪家强,html网页设计模板和源代码本文整理匯總了Java中java.sql.Connection.prepareCall方法的典型用法代碼示例。如果您正苦於以下問題#xff1a;Java Connection.prepareCall方法的具體用法#xff1f;Java Connection.prepareCall怎麽用#xff1f;Java Connection.prepareCall使用的例子#xff1f;那…本文整理匯總了Java中java.sql.Connection.prepareCall方法的典型用法代碼示例。如果您正苦於以下問題Java Connection.prepareCall方法的具體用法Java Connection.prepareCall怎麽用Java Connection.prepareCall使用的例子那麽恭喜您, 這裏精選的方法代碼示例或許可以為您提供幫助。您也可以進一步了解該方法所在類java.sql.Connection的用法示例。在下文中一共展示了Connection.prepareCall方法的16個代碼示例這些例子默認根據受歡迎程度排序。您可以為喜歡或者感覺有用的代碼點讚您的評價將有助於我們的係統推薦出更棒的Java代碼示例。示例1: testBug12417點讚 4import java.sql.Connection; //導入方法依賴的package包/類/*** Tests fix for Bug#12417 - stored procedure catalog name is case-sensitive* on Windows (this is actually a server bug, but we have a workaround in* place for it now).** throws Exception* if the test fails.*/public void testBug12417() throws Exception {if (serverSupportsStoredProcedures() isServerRunningOnWindows()) {createProcedure(testBug12417, ()\nBEGIN\nSELECT 1;end\n);Connection ucCatalogConn null;try {ucCatalogConn getConnectionWithProps((Properties) null);ucCatalogConn.setCatalog(this.conn.getCatalog().toUpperCase());ucCatalogConn.prepareCall({call testBug12417()});} finally {if (ucCatalogConn ! null) {ucCatalogConn.close();}}}}開發者ID:bragex項目名稱:the-vigilantes代碼行數:27示例2: testBug78961點讚 3import java.sql.Connection; //導入方法依賴的package包/類/*** Tests fix for Bug#78961 - Cant call MySQL procedure with InOut parameters in Fabric environment.** Although this is a Fabric related bug we are able reproduce it using a couple of multi-host connections.*/public void testBug78961() throws Exception {createProcedure(testBug78961, (IN c1 FLOAT, IN c2 FLOAT, OUT h FLOAT, INOUT t FLOAT) BEGIN SET h SQRT(c1 * c1 c2 * c2); SET t t h; END;);Connection highLevelConn getLoadBalancedConnection(null);assertTrue(highLevelConn.getClass().getName().startsWith(com.sun.proxy) || highLevelConn.getClass().getName().startsWith($Proxy));Connection lowLevelConn getMasterSlaveReplicationConnection(null);// This simulates the behavior from Fabric connections that are causing the problem.((ReplicationConnection) lowLevelConn).setProxy((MySQLConnection) highLevelConn);CallableStatement cstmt lowLevelConn.prepareCall({CALL testBug78961 (?, ?, ?, ?)});cstmt.setFloat(1, 3.0f);cstmt.setFloat(2, 4.0f);cstmt.setFloat(4, 5.0f);cstmt.registerOutParameter(3, Types.FLOAT);cstmt.registerOutParameter(4, Types.FLOAT);cstmt.execute();assertEquals(5.0f, cstmt.getFloat(3));assertEquals(10.0f, cstmt.getFloat(4));}開發者ID:Jugendhackt項目名稱:OpenVertretung代碼行數:27示例3: deleteTestcase點讚 3import java.sql.Connection; //導入方法依賴的package包/類public void deleteTestcase(List objectsToDelete ) throws DatabaseAccessException {StringBuilder testcaseIds new StringBuilder();for (Object obj : objectsToDelete) {testcaseIds.append( ((Testcase) obj).testcaseId);testcaseIds.append(,);}testcaseIds.delete(testcaseIds.length() - 1, testcaseIds.length());final String errMsg Unable to delete testcase(s) with id testcaseIds;Connection connection getConnection();CallableStatement callableStatement null;try {callableStatement connection.prepareCall({ call sp_delete_testcase(?) });callableStatement.setString(1, testcaseIds.toString());callableStatement.execute();} catch (SQLException e) {throw new DatabaseAccessException(errMsg, e);} finally {DbUtils.close(connection, callableStatement);}}開發者ID:Axway項目名稱:ats-framework代碼行數:25示例4: getSuiteMessagesCount點讚 3import java.sql.Connection; //導入方法依賴的package包/類public int getSuiteMessagesCount( String whereClause ) throws DatabaseAccessException {String sqlLog new SqlRequestFormatter().add(where, whereClause).format();Connection connection getConnection();CallableStatement callableStatement null;ResultSet rs null;try {callableStatement connection.prepareCall({ call sp_get_suite_messages_count(?) });callableStatement.setString(1, whereClause);rs callableStatement.executeQuery();int messagesCount 0;if (rs.next()) {messagesCount rs.getInt(messagesCount);}logQuerySuccess(sqlLog, suite messages count, messagesCount);return messagesCount;} catch (Exception e) {throw new DatabaseAccessException(Error when sqlLog, e);} finally {DbUtils.closeResultSet(rs);DbUtils.close(connection, callableStatement);}}開發者ID:Axway項目名稱:ats-framework代碼行數:27示例5: sendRequest點讚 3import java.sql.Connection; //導入方法依賴的package包/類protected void sendRequest(Document request) throws IOException {try {StringWriter writer new StringWriter();(new XMLWriter(writer,OutputFormat.createPrettyPrint())).write(request);writer.flush(); writer.close();SessionImplementor session (SessionImplementor)new _RootDAO().getSession();Connection connection session.getJdbcConnectionAccess().obtainConnection();try {CallableStatement call connection.prepareCall(iRequestSql);call.setString(1, writer.getBuffer().toString());call.execute();call.close();} finally {session.getJdbcConnectionAccess().releaseConnection(connection);}} catch (Exception e) {sLog.error(Unable to send request: e.getMessage(),e);} finally {_RootDAO.closeCurrentThreadSessions();}}開發者ID:Jenner4S項目名稱:unitimes代碼行數:22示例6: getNumberOfCheckpointsPerQueue點讚 2import java.sql.Connection; //導入方法依賴的package包/類public MapgetNumberOfCheckpointsPerQueue( String testcaseIds ) throws DatabaseAccessException {Map allStatistics new HashMap();String sqlLog new SqlRequestFormatter().add(testcase ids, testcaseIds).format();Connection connection getConnection();CallableStatement callableStatement null;ResultSet rs null;try {callableStatement connection.prepareCall({ call sp_get_number_of_checkpoints_per_queue(?) });callableStatement.setString(1, testcaseIds);rs callableStatement.executeQuery();int numberRecords 0;while (rs.next()) {String name rs.getString(name);int queueNumbers rs.getInt(numberOfQueue);allStatistics.put(name, queueNumbers);}logQuerySuccess(sqlLog, system statistics, numberRecords);} catch (Exception e) {throw new DatabaseAccessException(Error when sqlLog, e);} finally {DbUtils.closeResultSet(rs);DbUtils.close(connection, callableStatement);}return allStatistics;}開發者ID:Axway項目名稱:ats-framework代碼行數:34示例7: testInterfaceImplementation點讚 2import java.sql.Connection; //導入方法依賴的package包/類private void testInterfaceImplementation(Connection connToCheck) throws Exception {Method[] dbmdMethods java.sql.DatabaseMetaData.class.getMethods();// cant do this statically, as we return different// implementations depending on JDBC versionDatabaseMetaData dbmd connToCheck.getMetaData();checkInterfaceImplemented(dbmdMethods, dbmd.getClass(), dbmd);Statement stmtToCheck connToCheck.createStatement();checkInterfaceImplemented(java.sql.Statement.class.getMethods(), stmtToCheck.getClass(), stmtToCheck);PreparedStatement pStmtToCheck connToCheck.prepareStatement(SELECT 1);ParameterMetaData paramMd pStmtToCheck.getParameterMetaData();checkInterfaceImplemented(java.sql.PreparedStatement.class.getMethods(), pStmtToCheck.getClass(), pStmtToCheck);checkInterfaceImplemented(java.sql.ParameterMetaData.class.getMethods(), paramMd.getClass(), paramMd);pStmtToCheck ((com.mysql.jdbc.Connection) connToCheck).serverPrepareStatement(SELECT 1);checkInterfaceImplemented(java.sql.PreparedStatement.class.getMethods(), pStmtToCheck.getClass(), pStmtToCheck);ResultSet toCheckRs connToCheck.createStatement().executeQuery(SELECT 1);checkInterfaceImplemented(java.sql.ResultSet.class.getMethods(), toCheckRs.getClass(), toCheckRs);toCheckRs connToCheck.createStatement().executeQuery(SELECT 1);checkInterfaceImplemented(java.sql.ResultSetMetaData.class.getMethods(), toCheckRs.getMetaData().getClass(), toCheckRs.getMetaData());if (versionMeetsMinimum(5, 0, 0)) {createProcedure(interfaceImpl, (IN p1 INT)\nBEGIN\nSELECT 1;\nEND);CallableStatement cstmt connToCheck.prepareCall({CALL interfaceImpl(?)});checkInterfaceImplemented(java.sql.CallableStatement.class.getMethods(), cstmt.getClass(), cstmt);}checkInterfaceImplemented(java.sql.Connection.class.getMethods(), connToCheck.getClass(), connToCheck);}開發者ID:rafallis項目名稱:BibliotecaPS代碼行數:37示例8: testBug28689點讚 2import java.sql.Connection; //導入方法依賴的package包/類/*** Tests fix for BUG#28689 - CallableStatement.executeBatch() doesnt work* when connection property noAccessToProcedureBodies has been set to* true.** The fix involves changing the behavior of noAccessToProcedureBodies, in* that the driver will now report all paramters as IN paramters but allow* callers to call registerOutParameter() on them.** throws Exception*/public void testBug28689() throws Exception {if (!versionMeetsMinimum(5, 0)) {return; // no stored procedures}createTable(testBug28689, ( id int(11) NOT NULL auto_increment,usuario varchar(255) default NULL,PRIMARY KEY (id)));this.stmt.executeUpdate(INSERT INTO testBug28689 (usuario) VALUES (AAAAAA));createProcedure(sp_testBug28689, (tid INT)\nBEGIN\nUPDATE testBug28689 SET usuario BBBBBB WHERE id tid;\nEND);Connection noProcedureBodiesConn getConnectionWithProps(noAccessToProcedureBodiestrue);CallableStatement cStmt null;try {cStmt noProcedureBodiesConn.prepareCall({CALL sp_testBug28689(?)});cStmt.setInt(1, 1);cStmt.addBatch();cStmt.executeBatch();assertEquals(BBBBBB, getSingleIndexedValueWithQuery(noProcedureBodiesConn, 1, SELECT usuario FROM testBug28689 WHERE id1));} finally {if (cStmt ! null) {cStmt.close();}if (noProcedureBodiesConn ! null) {noProcedureBodiesConn.close();}}}開發者ID:JuanJoseFJ項目名稱:ProyectoPacientes代碼行數:45示例9: callFunction點讚 2import java.sql.Connection; //導入方法依賴的package包/類private void callFunction(CallableStatement cStmt, Connection c) throws SQLException {cStmt c.prepareCall({? CALL testbug61203fn(?)});cStmt.registerOutParameter(1, Types.INTEGER);cStmt.setFloat(2, 2);cStmt.execute();assertEquals(2f, cStmt.getInt(1), .001);}開發者ID:JuanJoseFJ項目名稱:ProyectoPacientes代碼行數:8示例10: executeBatchedStoredProc點讚 2import java.sql.Connection; //導入方法依賴的package包/類private void executeBatchedStoredProc(Connection c) throws Exception {this.stmt.executeUpdate(TRUNCATE TABLE testBatchTable);CallableStatement storedProc c.prepareCall({call testBatch(?)});try {int numBatches 300;for (int i 0; i numBatches; i) {storedProc.setInt(1, i 1);storedProc.addBatch();}int[] counts storedProc.executeBatch();assertEquals(numBatches, counts.length);for (int i 0; i numBatches; i) {assertEquals(1, counts[i]);}this.rs this.stmt.executeQuery(SELECT field1 FROM testBatchTable ORDER BY field1 ASC);for (int i 0; i numBatches; i) {assertTrue(this.rs.next());assertEquals(i 1, this.rs.getInt(1));}} finally {if (storedProc ! null) {storedProc.close();}}}開發者ID:Jugendhackt項目名稱:OpenVertretung代碼行數:35示例11: getTestcasesCount點讚 2import java.sql.Connection; //導入方法依賴的package包/類public int getTestcasesCount( String whereClause ) throws DatabaseAccessException {String sqlLog new SqlRequestFormatter().add(where, whereClause).format();Connection connection getConnection();CallableStatement callableStatement null;ResultSet rs null;try {callableStatement connection.prepareCall({ call sp_get_testcases_count(?) });callableStatement.setString(1, whereClause);rs callableStatement.executeQuery();int testcasesCount 0;while (rs.next()) {testcasesCount rs.getInt(testcasesCount);logQuerySuccess(sqlLog, test cases, testcasesCount);break;}return testcasesCount;} catch (Exception e) {throw new DatabaseAccessException(Error when sqlLog, e);} finally {DbUtils.closeResultSet(rs);DbUtils.close(connection, callableStatement);}}開發者ID:Axway項目名稱:ats-framework代碼行數:28示例12: testBug61150點讚 2import java.sql.Connection; //導入方法依賴的package包/類/*** Tests fix for BUG#61150 - First call to SP* fails with No Database Selected* The workaround introduced in DatabaseMetaData.getCallStmtParameterTypes* to fix the bug in server where SHOW CREATE PROCEDURE was not respecting* lower-case table names is misbehaving when connection is not attached to* database and on non-casesensitive OS.** throws Exception* if the test fails.*/public void testBug61150() throws Exception {NonRegisteringDriver driver new NonRegisteringDriver();Properties oldProps driver.parseURL(BaseTestCase.dbUrl, null);String host driver.host(oldProps);int port driver.port(oldProps);StringBuilder newUrlToTestNoDB new StringBuilder(jdbc:mysql://);if (host ! null) {newUrlToTestNoDB.append(host);}newUrlToTestNoDB.append(:).append(port).append(/);Statement savedSt this.stmt;Properties props getHostFreePropertiesFromTestsuiteUrl();props.remove(NonRegisteringDriver.DBNAME_PROPERTY_KEY);Connection conn1 DriverManager.getConnection(newUrlToTestNoDB.toString(), props);this.stmt conn1.createStatement();createDatabase(TST1);createProcedure(TST1.PROC, (x int, out y int)\nbegin\ndeclare z int;\nset z x1, y z;\nend\n);CallableStatement cStmt null;cStmt conn1.prepareCall({call TST1.PROC(?, ?)});cStmt.setInt(1, 5);cStmt.registerOutParameter(2, Types.INTEGER);cStmt.execute();assertEquals(6, cStmt.getInt(2));cStmt.clearParameters();cStmt.close();conn1.setCatalog(TST1);cStmt null;cStmt conn1.prepareCall({call TST1.PROC(?, ?)});cStmt.setInt(1, 5);cStmt.registerOutParameter(2, Types.INTEGER);cStmt.execute();assertEquals(6, cStmt.getInt(2));cStmt.clearParameters();cStmt.close();conn1.setCatalog(mysql);cStmt null;cStmt conn1.prepareCall({call TST1.PROC(?, ?)});cStmt.setInt(1, 5);cStmt.registerOutParameter(2, Types.INTEGER);cStmt.execute();assertEquals(6, cStmt.getInt(2));cStmt.clearParameters();cStmt.close();this.stmt savedSt;}開發者ID:JuanJoseFJ項目名稱:ProyectoPacientes代碼行數:68示例13: populateSystemStatisticDefinition點讚 2import java.sql.Connection; //導入方法依賴的package包/類public int populateSystemStatisticDefinition(String name,String parentName,String internalName,String unit,String params ) throws DatabaseAccessException {if (parentName null) {parentName ;}if (internalName null) {internalName ;}CallableStatement callableStatement null;Connection con null;boolean useLocalConnection false;try {if (connection null || connection.isClosed()) {// connection not set externally so use new connection only for// this method invocationuseLocalConnection true;con getConnection();} else {useLocalConnection false;con connection;}final int statisticId 6;callableStatement con.prepareCall({ call sp_populate_system_statistic_definition(?, ?, ?, ?, ?, ?) });callableStatement.setString(1, parentName);callableStatement.setString(2, internalName);callableStatement.setString(3, name);callableStatement.setString(4, unit);callableStatement.setString(5, params);callableStatement.registerOutParameter(statisticId, Types.INTEGER);callableStatement.execute();return callableStatement.getInt(statisticId);} catch (Exception e) {String errMsg Unable to populate statistic name with unit unit and params params ;throw new DatabaseAccessException(errMsg, e);} finally {DbUtils.closeStatement(callableStatement);if (useLocalConnection) {DbUtils.closeConnection(con);}}}開發者ID:Axway項目名稱:ats-framework代碼行數:52示例14: setUpClosedObjects點讚 2import java.sql.Connection; //導入方法依賴的package包/類BeforeClasspublic static void setUpClosedObjects() throws Exception {// (Note: Cant use JdbcTests connect(...) for this test class.)final Connection connToClose new Driver().connect(jdbc:dremio:zklocal,JdbcAssert.getDefaultProperties());final Connection connToKeep new Driver().connect(jdbc:dremio:zklocal,JdbcAssert.getDefaultProperties());final Statement plainStmtToClose connToKeep.createStatement();final Statement plainStmtToKeep connToKeep.createStatement();final PreparedStatement preparedStmtToClose connToKeep.prepareStatement(VALUES PreparedStatement query);try {connToKeep.prepareCall(VALUES CallableStatement query);fail(Test seems to be out of date. Was prepareCall(...) implemented?);}catch (SQLException | UnsupportedOperationException e) {// Expected.}final ResultSet resultSetToCloseOnStmtToClose plainStmtToClose.executeQuery(VALUES plain Statement query);resultSetToCloseOnStmtToClose.next();final ResultSet resultSetToCloseOnStmtToKeep plainStmtToKeep.executeQuery(VALUES plain Statement query);resultSetToCloseOnStmtToKeep.next();final ResultSetMetaData rsmdForClosedStmt resultSetToCloseOnStmtToKeep.getMetaData();final ResultSetMetaData rsmdForOpenStmt resultSetToCloseOnStmtToClose.getMetaData();final DatabaseMetaData dbmd connToClose.getMetaData();connToClose.close();plainStmtToClose.close();preparedStmtToClose.close();resultSetToCloseOnStmtToClose.close();resultSetToCloseOnStmtToKeep.close();closedConn connToClose;openConn connToKeep;closedPlainStmtOfOpenConn plainStmtToClose;closedPreparedStmtOfOpenConn preparedStmtToClose;closedResultSetOfClosedStmt resultSetToCloseOnStmtToClose;closedResultSetOfOpenStmt resultSetToCloseOnStmtToKeep;resultSetMetaDataOfClosedResultSet rsmdForOpenStmt;resultSetMetaDataOfClosedStmt rsmdForClosedStmt;databaseMetaDataOfClosedConn dbmd;// Self-check that member variables are set (and objects are in right open// or closed state):assertTrue(Test setup error, closedConn.isClosed());assertFalse(Test setup error, openConn.isClosed());assertTrue(Test setup error, closedPlainStmtOfOpenConn.isClosed());assertTrue(Test setup error, closedPreparedStmtOfOpenConn.isClosed());assertTrue(Test setup error, closedResultSetOfClosedStmt.isClosed());assertTrue(Test setup error, closedResultSetOfOpenStmt.isClosed());// (No ResultSetMetaData.isClosed() or DatabaseMetaData.isClosed():)assertNotNull(Test setup error, resultSetMetaDataOfClosedResultSet);assertNotNull(Test setup error, resultSetMetaDataOfClosedStmt);assertNotNull(Test setup error, databaseMetaDataOfClosedConn);}示例15: createCallableStatement點讚 2import java.sql.Connection; //導入方法依賴的package包/類Overridepublic CallableStatement createCallableStatement(Connection con) throws SQLException {return con.prepareCall(this.callString);}開發者ID:lamsfoundation項目名稱:lams代碼行數:5示例16: testSPCache點讚 1import java.sql.Connection; //導入方法依賴的package包/類/*** Tests parsing of stored procedures** throws Exception* if an error occurs.*/public void testSPCache() throws Exception {if (versionMeetsMinimum(5, 0)) {CallableStatement storedProc null;createProcedure(testSpParse, (IN FOO VARCHAR(15))\nBEGIN\nSELECT 1;\nend\n);int numIterations 10;long startTime System.currentTimeMillis();for (int i 0; i numIterations; i) {storedProc this.conn.prepareCall({call testSpParse(?)});storedProc.close();}long elapsedTime System.currentTimeMillis() - startTime;System.out.println(Standard parsing/execution: elapsedTime ms);storedProc this.conn.prepareCall({call testSpParse(?)});storedProc.setString(1, abc);this.rs storedProc.executeQuery();assertTrue(this.rs.next());assertTrue(this.rs.getInt(1) 1);Properties props new Properties();props.setProperty(cacheCallableStmts, true);Connection cachedSpConn getConnectionWithProps(props);startTime System.currentTimeMillis();for (int i 0; i numIterations; i) {storedProc cachedSpConn.prepareCall({call testSpParse(?)});storedProc.close();}elapsedTime System.currentTimeMillis() - startTime;System.out.println(Cached parse stage: elapsedTime ms);storedProc cachedSpConn.prepareCall({call testSpParse(?)});storedProc.setString(1, abc);this.rs storedProc.executeQuery();assertTrue(this.rs.next());assertTrue(this.rs.getInt(1) 1);}}開發者ID:bragex項目名稱:the-vigilantes代碼行數:59注本文中的java.sql.Connection.prepareCall方法示例整理自Github/MSDocs等源碼及文檔管理平台相關代碼片段篩選自各路編程大神貢獻的開源項目源碼版權歸原作者所有傳播和使用請參考對應項目的License未經允許請勿轉載。
