Dave Jarvis' Repositories

git clone https://repo.autonoma.ca/repo/rxm.git
rxm / Commits / 9dab953

Tabs to spaces.

Authordjarvis <email>
Date2018-12-11 14:54:36 GMT-0800
Commit9dab953fc347fe978dcdcc143a9172cc38cf33cb
Parent7074b9f
source/java/com/whitemagicsoftware/rxm/NamedParameterStatement.java
*/
public class NamedParameterStatement {
- /** The statement this object is wrapping. */
- private final PreparedStatement statement;
+ /** The statement this object is wrapping. */
+ private final PreparedStatement statement;
- /** Maps parameter names to arrays of ints (the parameter indices). */
- private Map<String, int[]> indexMap;
+ /** Maps parameter names to arrays of ints (the parameter indices). */
+ private Map<String, int[]> indexMap;
- /**
- * Creates a NamedParameterStatement.
+ /**
+ * Creates a NamedParameterStatement.
* Wraps c.{@link Connection#prepareStatement(java.lang.String) prepareStatement}.
- *
- * @param connection
- * the database connection
- * @param query
- * the parameterized query
- * @throws SQLException
- * if the statement could not be created
- */
- public NamedParameterStatement(Connection connection, String query)
+ *
+ * @param connection
+ * the database connection
+ * @param query
+ * the parameterized query
+ * @throws SQLException
+ * if the statement could not be created
+ */
+ public NamedParameterStatement(Connection connection, String query)
throws SQLException {
- String parsedQuery = parse(query);
- statement = connection.prepareStatement(parsedQuery);
- }
+ String parsedQuery = parse(query);
+ statement = connection.prepareStatement(parsedQuery);
+ }
- /**
- * Parses a query with named parameters. The parameter-index mappings
+ /**
+ * Parses a query with named parameters. The parameter-index mappings
* are put into the map, and the parsed query is returned.
- *
- * @param query
- * query to parse
- * @param paramMap
- * map to hold parameter-index mappings
- * @return the parsed query
- */
- private final String parse(String query) {
- // Regular expressions didn't work well for ignoring
- // parameter-like strings inside quotes.
- int length = query.length();
- StringBuffer parsedQuery = new StringBuffer(length);
- boolean inSingleQuote = false;
- boolean inDoubleQuote = false;
- int index = 1;
- HashMap<String, List<Integer>> indexes = new HashMap<String, List<Integer>>(10);
+ *
+ * @param query
+ * query to parse
+ * @param paramMap
+ * map to hold parameter-index mappings
+ * @return the parsed query
+ */
+ private final String parse(String query) {
+ // Regular expressions didn't work well for ignoring
+ // parameter-like strings inside quotes.
+ int length = query.length();
+ StringBuffer parsedQuery = new StringBuffer(length);
+ boolean inSingleQuote = false;
+ boolean inDoubleQuote = false;
+ int index = 1;
+ HashMap<String, List<Integer>> indexes = new HashMap<String, List<Integer>>(10);
- for (int i = 0; i < length; i++) {
- char c = query.charAt(i);
- if (inSingleQuote) {
- if (c == '\'') {
- inSingleQuote = false;
- }
- } else if (inDoubleQuote) {
- if (c == '"') {
- inDoubleQuote = false;
- }
- } else {
- if (c == '\'') {
- inSingleQuote = true;
- } else if (c == '"') {
- inDoubleQuote = true;
- } else if (c == ':' && i + 1 < length && Character.isJavaIdentifierStart(query.charAt(i + 1))) {
- int j = i + 2;
- while (j < length && Character.isJavaIdentifierPart(query.charAt(j))) {
- j++;
- }
- String name = query.substring(i + 1, j);
- c = '?'; // replace the parameter with a question mark
- i += name.length(); // skip past the end if the parameter
+ for (int i = 0; i < length; i++) {
+ char c = query.charAt(i);
+ if (inSingleQuote) {
+ if (c == '\'') {
+ inSingleQuote = false;
+ }
+ } else if (inDoubleQuote) {
+ if (c == '"') {
+ inDoubleQuote = false;
+ }
+ } else {
+ if (c == '\'') {
+ inSingleQuote = true;
+ } else if (c == '"') {
+ inDoubleQuote = true;
+ } else if (c == ':' && i + 1 < length && Character.isJavaIdentifierStart(query.charAt(i + 1))) {
+ int j = i + 2;
+ while (j < length && Character.isJavaIdentifierPart(query.charAt(j))) {
+ j++;
+ }
+ String name = query.substring(i + 1, j);
+ c = '?'; // replace the parameter with a question mark
+ i += name.length(); // skip past the end if the parameter
- List<Integer> indexList = indexes.get(name);
- if (indexList == null) {
- indexList = new LinkedList<Integer>();
- indexes.put(name, indexList);
- }
- indexList.add(Integer.valueOf(index));
+ List<Integer> indexList = indexes.get(name);
+ if (indexList == null) {
+ indexList = new LinkedList<Integer>();
+ indexes.put(name, indexList);
+ }
+ indexList.add(Integer.valueOf(index));
- index++;
- }
- }
- parsedQuery.append(c);
- }
+ index++;
+ }
+ }
+ parsedQuery.append(c);
+ }
- indexMap = new HashMap<String, int[]>(indexes.size());
- // replace the lists of Integer objects with arrays of ints
- for (Map.Entry<String, List<Integer>> entry : indexes.entrySet()) {
- List<Integer> list = entry.getValue();
- int[] intIndexes = new int[list.size()];
- int i = 0;
- for (Integer x : list) {
- intIndexes[i++] = x.intValue();
- }
- indexMap.put(entry.getKey(), intIndexes);
- }
+ indexMap = new HashMap<String, int[]>(indexes.size());
+ // replace the lists of Integer objects with arrays of ints
+ for (Map.Entry<String, List<Integer>> entry : indexes.entrySet()) {
+ List<Integer> list = entry.getValue();
+ int[] intIndexes = new int[list.size()];
+ int i = 0;
+ for (Integer x : list) {
+ intIndexes[i++] = x.intValue();
+ }
+ indexMap.put(entry.getKey(), intIndexes);
+ }
- return parsedQuery.toString();
- }
+ return parsedQuery.toString();
+ }
- /**
- * Returns the indexes for a parameter.
- *
- * @param name
- * parameter name
- * @return parameter indexes
- * @throws IllegalArgumentException
- * if the parameter does not exist
- */
- private int[] getIndexes(String name) {
- int[] indexes = indexMap.get(name);
- if (indexes == null) {
- throw new IllegalArgumentException("Parameter not found: " + name);
- }
- return indexes;
- }
+ /**
+ * Returns the indexes for a parameter.
+ *
+ * @param name
+ * parameter name
+ * @return parameter indexes
+ * @throws IllegalArgumentException
+ * if the parameter does not exist
+ */
+ private int[] getIndexes(String name) {
+ int[] indexes = indexMap.get(name);
+ if (indexes == null) {
+ throw new IllegalArgumentException("Parameter not found: " + name);
+ }
+ return indexes;
+ }
- /**
- * Sets a parameter.
- *
- * @param name
- * parameter name
- * @param value
- * parameter value
- * @throws SQLException
- * if an error occurred
- * @throws IllegalArgumentException
- * if the parameter does not exist
- * @see PreparedStatement#setObject(int, java.lang.Object)
- */
- public void setObject(String name, Object value) throws SQLException {
- int[] indexes = getIndexes(name);
- for (int i = 0; i < indexes.length; i++) {
- statement.setObject(indexes[i], value);
- }
- }
+ /**
+ * Sets a parameter.
+ *
+ * @param name
+ * parameter name
+ * @param value
+ * parameter value
+ * @throws SQLException
+ * if an error occurred
+ * @throws IllegalArgumentException
+ * if the parameter does not exist
+ * @see PreparedStatement#setObject(int, java.lang.Object)
+ */
+ public void setObject(String name, Object value) throws SQLException {
+ int[] indexes = getIndexes(name);
+ for (int i = 0; i < indexes.length; i++) {
+ statement.setObject(indexes[i], value);
+ }
+ }
- /**
- * Sets a parameter.
- *
- * @param name
- * parameter name
- * @param value
- * parameter value
- * @throws SQLException
- * if an error occurred
- * @throws IllegalArgumentException
- * if the parameter does not exist
- * @see PreparedStatement#setString(int, java.lang.String)
- */
- public void setString(String name, String value) throws SQLException {
- int[] indexes = getIndexes(name);
- for (int i = 0; i < indexes.length; i++) {
- statement.setString(indexes[i], value);
- }
- }
+ /**
+ * Sets a parameter.
+ *
+ * @param name
+ * parameter name
+ * @param value
+ * parameter value
+ * @throws SQLException
+ * if an error occurred
+ * @throws IllegalArgumentException
+ * if the parameter does not exist
+ * @see PreparedStatement#setString(int, java.lang.String)
+ */
+ public void setString(String name, String value) throws SQLException {
+ int[] indexes = getIndexes(name);
+ for (int i = 0; i < indexes.length; i++) {
+ statement.setString(indexes[i], value);
+ }
+ }
- /**
- * Sets a parameter.
- *
- * @param name
- * parameter name
- * @param value
- * parameter value
- * @throws SQLException
- * if an error occurred
- * @throws IllegalArgumentException
- * if the parameter does not exist
- * @see PreparedStatement#setInt(int, int)
- */
- public void setInt(String name, int value) throws SQLException {
- int[] indexes = getIndexes(name);
- for (int i = 0; i < indexes.length; i++) {
- statement.setInt(indexes[i], value);
- }
- }
+ /**
+ * Sets a parameter.
+ *
+ * @param name
+ * parameter name
+ * @param value
+ * parameter value
+ * @throws SQLException
+ * if an error occurred
+ * @throws IllegalArgumentException
+ * if the parameter does not exist
+ * @see PreparedStatement#setInt(int, int)
+ */
+ public void setInt(String name, int value) throws SQLException {
+ int[] indexes = getIndexes(name);
+ for (int i = 0; i < indexes.length; i++) {
+ statement.setInt(indexes[i], value);
+ }
+ }
- /**
- * Sets a parameter.
- *
- * @param name
- * parameter name
- * @param value
- * parameter value
- * @throws SQLException
- * if an error occurred
- * @throws IllegalArgumentException
- * if the parameter does not exist
- * @see PreparedStatement#setInt(int, int)
- */
- public void setLong(String name, long value) throws SQLException {
- int[] indexes = getIndexes(name);
- for (int i = 0; i < indexes.length; i++) {
- statement.setLong(indexes[i], value);
- }
- }
+ /**
+ * Sets a parameter.
+ *
+ * @param name
+ * parameter name
+ * @param value
+ * parameter value
+ * @throws SQLException
+ * if an error occurred
+ * @throws IllegalArgumentException
+ * if the parameter does not exist
+ * @see PreparedStatement#setInt(int, int)
+ */
+ public void setLong(String name, long value) throws SQLException {
+ int[] indexes = getIndexes(name);
+ for (int i = 0; i < indexes.length; i++) {
+ statement.setLong(indexes[i], value);
+ }
+ }
- /**
- * Sets a parameter.
- *
- * @param name
- * parameter name
- * @param value
- * parameter value
- * @throws SQLException
- * if an error occurred
- * @throws IllegalArgumentException
- * if the parameter does not exist
- * @see PreparedStatement#setTimestamp(int, java.sql.Timestamp)
- */
- public void setTimestamp(String name, Timestamp value) throws SQLException {
- int[] indexes = getIndexes(name);
- for (int i = 0; i < indexes.length; i++) {
- statement.setTimestamp(indexes[i], value);
- }
- }
+ /**
+ * Sets a parameter.
+ *
+ * @param name
+ * parameter name
+ * @param value
+ * parameter value
+ * @throws SQLException
+ * if an error occurred
+ * @throws IllegalArgumentException
+ * if the parameter does not exist
+ * @see PreparedStatement#setTimestamp(int, java.sql.Timestamp)
+ */
+ public void setTimestamp(String name, Timestamp value) throws SQLException {
+ int[] indexes = getIndexes(name);
+ for (int i = 0; i < indexes.length; i++) {
+ statement.setTimestamp(indexes[i], value);
+ }
+ }
- /**
- * Returns the underlying statement.
- *
- * @return the statement
- */
- public PreparedStatement getStatement() {
- return statement;
- }
+ /**
+ * Returns the underlying statement.
+ *
+ * @return the statement
+ */
+ public PreparedStatement getStatement() {
+ return statement;
+ }
- /**
- * Executes the statement.
- *
- * @return true if the first result is a {@link ResultSet}
- * @throws SQLException
- * if an error occurred
- * @see PreparedStatement#execute()
- */
- public boolean execute() throws SQLException {
- return statement.execute();
- }
+ /**
+ * Executes the statement.
+ *
+ * @return true if the first result is a {@link ResultSet}
+ * @throws SQLException
+ * if an error occurred
+ * @see PreparedStatement#execute()
+ */
+ public boolean execute() throws SQLException {
+ return statement.execute();
+ }
- /**
- * Executes the statement, which must be a query.
- *
- * @return the query results
- * @throws SQLException
- * if an error occurred
- * @see PreparedStatement#executeQuery()
- */
- public ResultSet executeQuery() throws SQLException {
- return statement.executeQuery();
- }
+ /**
+ * Executes the statement, which must be a query.
+ *
+ * @return the query results
+ * @throws SQLException
+ * if an error occurred
+ * @see PreparedStatement#executeQuery()
+ */
+ public ResultSet executeQuery() throws SQLException {
+ return statement.executeQuery();
+ }
- /**
- * Executes the statement, which must be an SQL INSERT, UPDATE or DELETE
+ /**
+ * Executes the statement, which must be an SQL INSERT, UPDATE or DELETE
* statement; or an SQL statement that returns nothing, such as a
* DDL statement.
- *
- * @return number of rows affected
- * @throws SQLException
- * if an error occurred
- * @see PreparedStatement#executeUpdate()
- */
- public int executeUpdate() throws SQLException {
- return statement.executeUpdate();
- }
+ *
+ * @return number of rows affected
+ * @throws SQLException
+ * if an error occurred
+ * @see PreparedStatement#executeUpdate()
+ */
+ public int executeUpdate() throws SQLException {
+ return statement.executeUpdate();
+ }
- /**
- * Closes the statement.
- *
- * @throws SQLException
- * if an error occurred
- * @see Statement#close()
- */
- public void close() throws SQLException {
- statement.close();
- }
+ /**
+ * Closes the statement.
+ *
+ * @throws SQLException
+ * if an error occurred
+ * @see Statement#close()
+ */
+ public void close() throws SQLException {
+ statement.close();
+ }
- /**
- * Adds the current set of parameters as a batch entry.
- *
- * @throws SQLException
- * if something went wrong
- */
- public void addBatch() throws SQLException {
- statement.addBatch();
- }
+ /**
+ * Adds the current set of parameters as a batch entry.
+ *
+ * @throws SQLException
+ * if something went wrong
+ */
+ public void addBatch() throws SQLException {
+ statement.addBatch();
+ }
- /**
- * Executes all of the batched statements.
- *
- * See {@link Statement#executeBatch()} for details.
- *
- * @return update counts for each statement
- * @throws SQLException
- * if something went wrong
- */
- public int[] executeBatch() throws SQLException {
- return statement.executeBatch();
- }
+ /**
+ * Executes all of the batched statements.
+ *
+ * See {@link Statement#executeBatch()} for details.
+ *
+ * @return update counts for each statement
+ * @throws SQLException
+ * if something went wrong
+ */
+ public int[] executeBatch() throws SQLException {
+ return statement.executeBatch();
+ }
}
Delta266 lines added, 266 lines removed