This is an automated email from the ASF dual-hosted git repository.
markt pushed a commit to branch 7.0.x
in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit edf36aa3cb199f5cd06e99fe76441d2977e774c6
Author: Phil Steitz <phil.ste...@gmail.com>
AuthorDate: Sat Oct 19 14:44:43 2019 -0700
Add TesterStatement from Commons DBCP 1.5 branch, commit
fa9c1eb250c76dd9af5ee23bf2ecd5351cad4e04.
---
.../apache/tomcat/dbcp/dbcp/TesterStatement.java | 310 +++++++++++++++++++++
1 file changed, 310 insertions(+)
diff --git a/test/org/apache/tomcat/dbcp/dbcp/TesterStatement.java
b/test/org/apache/tomcat/dbcp/dbcp/TesterStatement.java
new file mode 100644
index 0000000..4a81e10
--- /dev/null
+++ b/test/org/apache/tomcat/dbcp/dbcp/TesterStatement.java
@@ -0,0 +1,310 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.commons.dbcp;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.SQLWarning;
+import java.sql.Statement;
+
+/**
+ * A dummy {@link Statement}, for testing purposes.
+ *
+ * @author Rodney Waldhoff
+ * @author Dirk Verbeeck
+ * @version $Revision$ $Date$
+ */
+public class TesterStatement implements Statement {
+ public TesterStatement(Connection conn) {
+ _connection = conn;
+ }
+
+ public TesterStatement(Connection conn, int resultSetType, int
resultSetConcurrency) {
+ _connection = conn;
+ _resultSetType = resultSetType;
+ _resultSetConcurrency = resultSetConcurrency;
+ }
+
+ protected Connection _connection = null;
+ protected boolean _open = true;
+ protected int _rowsUpdated = 1;
+ protected boolean _executeResponse = true;
+ protected int _maxFieldSize = 1024;
+ protected int _maxRows = 1024;
+ protected boolean _escapeProcessing = false;
+ protected int _queryTimeout = 1000;
+ protected String _cursorName = null;
+ protected int _fetchDirection = 1;
+ protected int _fetchSize = 1;
+ protected int _resultSetConcurrency = 1;
+ protected int _resultSetType = 1;
+ protected ResultSet _resultSet = null;
+
+ public ResultSet executeQuery(String sql) throws SQLException {
+ checkOpen();
+ if("null".equals(sql)) {
+ return null;
+ }
+ if("invalid".equals(sql)) {
+ throw new SQLException("invalid query");
+ }
+ if ("broken".equals(sql)) {
+ throw new SQLException("broken connection");
+ }
+ if("select username".equals(sql)) {
+ String username = ((TesterConnection) _connection).getUsername();
+ Object[][] data = {{username}};
+ return new TesterResultSet(this, data);
+ } else {
+ // Simulate timeout if queryTimout is set to less than 5 seconds
+ if (_queryTimeout > 0 && _queryTimeout < 5) {
+ throw new SQLException("query timeout");
+ }
+ return new TesterResultSet(this);
+ }
+ }
+
+ public int executeUpdate(String sql) throws SQLException {
+ checkOpen();
+ return _rowsUpdated;
+ }
+
+ public void close() throws SQLException {
+ // calling close twice has no effect
+ if (!_open) {
+ return;
+ }
+
+ _open = false;
+ if (_resultSet != null) {
+ _resultSet.close();
+ _resultSet = null;
+ }
+ }
+
+ public int getMaxFieldSize() throws SQLException {
+ checkOpen();
+ return _maxFieldSize;
+ }
+
+ public void setMaxFieldSize(int max) throws SQLException {
+ checkOpen();
+ _maxFieldSize = max;
+ }
+
+ public int getMaxRows() throws SQLException {
+ checkOpen();
+ return _maxRows;
+ }
+
+ public void setMaxRows(int max) throws SQLException {
+ checkOpen();
+ _maxRows = max;
+ }
+
+ public void setEscapeProcessing(boolean enable) throws SQLException {
+ checkOpen();
+ _escapeProcessing = enable;
+ }
+
+ public int getQueryTimeout() throws SQLException {
+ checkOpen();
+ return _queryTimeout;
+ }
+
+ public void setQueryTimeout(int seconds) throws SQLException {
+ checkOpen();
+ _queryTimeout = seconds;
+ }
+
+ public void cancel() throws SQLException {
+ checkOpen();
+ }
+
+ public SQLWarning getWarnings() throws SQLException {
+ checkOpen();
+ return null;
+ }
+
+ public void clearWarnings() throws SQLException {
+ checkOpen();
+ }
+
+ public void setCursorName(String name) throws SQLException {
+ checkOpen();
+ _cursorName = name;
+ }
+
+ public boolean execute(String sql) throws SQLException {
+ checkOpen();
+ if("invalid".equals(sql)) {
+ throw new SQLException("invalid query");
+ }
+ return _executeResponse;
+ }
+
+ public ResultSet getResultSet() throws SQLException {
+ checkOpen();
+ if (_resultSet == null) {
+ _resultSet = new TesterResultSet(this);
+ }
+ return _resultSet;
+ }
+
+ public int getUpdateCount() throws SQLException {
+ checkOpen();
+ return _rowsUpdated;
+ }
+
+ public boolean getMoreResults() throws SQLException {
+ checkOpen();
+ return false;
+ }
+
+ public void setFetchDirection(int direction) throws SQLException {
+ checkOpen();
+ _fetchDirection = direction;
+ }
+
+ public int getFetchDirection() throws SQLException {
+ checkOpen();
+ return _fetchDirection;
+ }
+
+ public void setFetchSize(int rows) throws SQLException {
+ checkOpen();
+ _fetchSize = rows;
+ }
+
+ public int getFetchSize() throws SQLException {
+ checkOpen();
+ return _fetchSize;
+ }
+
+ public int getResultSetConcurrency() throws SQLException {
+ checkOpen();
+ return _resultSetConcurrency;
+ }
+
+ public int getResultSetType() throws SQLException {
+ checkOpen();
+ return _resultSetType;
+ }
+
+ public void addBatch(String sql) throws SQLException {
+ checkOpen();
+ }
+
+ public void clearBatch() throws SQLException {
+ checkOpen();
+ }
+
+ public int[] executeBatch() throws SQLException {
+ checkOpen();
+ return new int[0];
+ }
+
+ public Connection getConnection() throws SQLException {
+ checkOpen();
+ return _connection;
+ }
+
+ protected void checkOpen() throws SQLException {
+ if(!_open) {
+ throw new SQLException("Connection is closed.");
+ }
+ }
+
+ public boolean getMoreResults(int current) throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public ResultSet getGeneratedKeys() throws SQLException {
+ return new TesterResultSet(this);
+ }
+
+ public int executeUpdate(String sql, int autoGeneratedKeys)
+ throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public int executeUpdate(String sql, int columnIndexes[])
+ throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public int executeUpdate(String sql, String columnNames[])
+ throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public boolean execute(String sql, int autoGeneratedKeys)
+ throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public boolean execute(String sql, int columnIndexes[])
+ throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public boolean execute(String sql, String columnNames[])
+ throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public int getResultSetHoldability() throws SQLException {
+ checkOpen();
+ throw new SQLException("Not implemented.");
+ }
+
+/* JDBC_4_ANT_KEY_BEGIN */
+
+ public boolean isWrapperFor(Class<?> iface) throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public <T> T unwrap(Class<T> iface) throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public boolean isClosed() throws SQLException {
+ return !_open;
+ }
+
+ public void setPoolable(boolean poolable) throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+
+ public boolean isPoolable() throws SQLException {
+ throw new SQLException("Not implemented.");
+ }
+/* JDBC_4_ANT_KEY_END */
+
+ /* JDBC_4_1_ANT_KEY_BEGIN */
+ @Override
+ public void closeOnCompletion() throws SQLException {
+ }
+
+ @Override
+ public boolean isCloseOnCompletion() throws SQLException {
+ return false;
+ }
+ /* JDBC_4_1_ANT_KEY_END */
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
