diff --git a/src/main/java/org/springframework/cassandra/core/CassandraOperations.java b/src/main/java/org/springframework/cassandra/core/CassandraOperations.java index fbd3653d6..82d052fce 100644 --- a/src/main/java/org/springframework/cassandra/core/CassandraOperations.java +++ b/src/main/java/org/springframework/cassandra/core/CassandraOperations.java @@ -107,11 +107,11 @@ public interface CassandraOperations { T execute(PreparedStatementCreator psc, PreparedStatementCallback action) throws DataAccessException; - T query(final String cql, PreparedStatementBinder pss, ResultSetExtractor rse) throws DataAccessException; + T query(final String cql, PreparedStatementBinder psb, ResultSetExtractor rse) throws DataAccessException; - void query(final String cql, PreparedStatementBinder pss, RowCallbackHandler rch) throws DataAccessException; + void query(final String cql, PreparedStatementBinder psb, RowCallbackHandler rch) throws DataAccessException; - List query(final String cql, PreparedStatementBinder pss, RowMapper rowMapper) throws DataAccessException; + List query(final String cql, PreparedStatementBinder psb, RowMapper rowMapper) throws DataAccessException; T query(PreparedStatementCreator psc, ResultSetExtractor rse) throws DataAccessException; @@ -119,13 +119,13 @@ public interface CassandraOperations { List query(PreparedStatementCreator psc, RowMapper rowMapper) throws DataAccessException; - T query(PreparedStatementCreator psc, final PreparedStatementBinder pss, final ResultSetExtractor rse) + T query(PreparedStatementCreator psc, final PreparedStatementBinder psb, final ResultSetExtractor rse) throws DataAccessException; - void query(PreparedStatementCreator psc, final PreparedStatementBinder pss, final RowCallbackHandler rch) + void query(PreparedStatementCreator psc, final PreparedStatementBinder psb, final RowCallbackHandler rch) throws DataAccessException; - List query(PreparedStatementCreator psc, final PreparedStatementBinder pss, final RowMapper rowMapper) + List query(PreparedStatementCreator psc, final PreparedStatementBinder psb, final RowMapper rowMapper) throws DataAccessException; /** diff --git a/src/main/java/org/springframework/cassandra/core/CassandraTemplate.java b/src/main/java/org/springframework/cassandra/core/CassandraTemplate.java index 5ed7e8aba..352ef301a 100644 --- a/src/main/java/org/springframework/cassandra/core/CassandraTemplate.java +++ b/src/main/java/org/springframework/cassandra/core/CassandraTemplate.java @@ -458,7 +458,7 @@ public class CassandraTemplate extends CassandraAccessor implements CassandraOpe /* (non-Javadoc) * @see org.springframework.cassandra.core.CassandraOperations#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementSetter, org.springframework.cassandra.core.ResultSetExtractor) */ - public T query(PreparedStatementCreator psc, final PreparedStatementBinder pss, final ResultSetExtractor rse) + public T query(PreparedStatementCreator psc, final PreparedStatementBinder psb, final ResultSetExtractor rse) throws DataAccessException { Assert.notNull(rse, "ResultSetExtractor must not be null"); @@ -468,8 +468,8 @@ public class CassandraTemplate extends CassandraAccessor implements CassandraOpe public T doInPreparedStatement(PreparedStatement ps) throws DriverException { ResultSet rs = null; BoundStatement bs = null; - if (pss != null) { - bs = pss.bindValues(ps); + if (psb != null) { + bs = psb.bindValues(ps); } else { bs = ps.bind(); } @@ -483,31 +483,31 @@ public class CassandraTemplate extends CassandraAccessor implements CassandraOpe * @see org.springframework.cassandra.core.CassandraOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementSetter, org.springframework.cassandra.core.ResultSetExtractor) */ @Override - public T query(String cql, PreparedStatementBinder pss, ResultSetExtractor rse) throws DataAccessException { - return query(new SimplePreparedStatementCreator(cql), pss, rse); + public T query(String cql, PreparedStatementBinder psb, ResultSetExtractor rse) throws DataAccessException { + return query(new SimplePreparedStatementCreator(cql), psb, rse); } /* (non-Javadoc) * @see org.springframework.cassandra.core.CassandraOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementSetter, org.springframework.cassandra.core.RowCallbackHandler) */ @Override - public void query(String cql, PreparedStatementBinder pss, RowCallbackHandler rch) throws DataAccessException { - query(new SimplePreparedStatementCreator(cql), pss, rch); + public void query(String cql, PreparedStatementBinder psb, RowCallbackHandler rch) throws DataAccessException { + query(new SimplePreparedStatementCreator(cql), psb, rch); } /* (non-Javadoc) * @see org.springframework.cassandra.core.CassandraOperations#query(java.lang.String, org.springframework.cassandra.core.PreparedStatementSetter, org.springframework.cassandra.core.RowMapper) */ @Override - public List query(String cql, PreparedStatementBinder pss, RowMapper rowMapper) throws DataAccessException { - return query(new SimplePreparedStatementCreator(cql), pss, rowMapper); + public List query(String cql, PreparedStatementBinder psb, RowMapper rowMapper) throws DataAccessException { + return query(new SimplePreparedStatementCreator(cql), psb, rowMapper); } /* (non-Javadoc) * @see org.springframework.cassandra.core.CassandraOperations#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowCallbackHandler) */ @Override - public void query(PreparedStatementCreator psc, final PreparedStatementBinder pss, final RowCallbackHandler rch) + public void query(PreparedStatementCreator psc, final PreparedStatementBinder psb, final RowCallbackHandler rch) throws DataAccessException { Assert.notNull(rch, "RowCallbackHandler must not be null"); logger.debug("Executing prepared CQL query"); @@ -516,8 +516,8 @@ public class CassandraTemplate extends CassandraAccessor implements CassandraOpe public Object doInPreparedStatement(PreparedStatement ps) throws DriverException { ResultSet rs = null; BoundStatement bs = null; - if (pss != null) { - bs = pss.bindValues(ps); + if (psb != null) { + bs = psb.bindValues(ps); } else { bs = ps.bind(); } @@ -532,7 +532,7 @@ public class CassandraTemplate extends CassandraAccessor implements CassandraOpe * @see org.springframework.cassandra.core.CassandraOperations#query(org.springframework.cassandra.core.PreparedStatementCreator, org.springframework.cassandra.core.PreparedStatementBinder, org.springframework.cassandra.core.RowMapper) */ @Override - public List query(PreparedStatementCreator psc, final PreparedStatementBinder pss, final RowMapper rowMapper) + public List query(PreparedStatementCreator psc, final PreparedStatementBinder psb, final RowMapper rowMapper) throws DataAccessException { Assert.notNull(rowMapper, "RowMapper must not be null"); logger.debug("Executing prepared CQL query"); @@ -541,8 +541,8 @@ public class CassandraTemplate extends CassandraAccessor implements CassandraOpe public List doInPreparedStatement(PreparedStatement ps) throws DriverException { ResultSet rs = null; BoundStatement bs = null; - if (pss != null) { - bs = pss.bindValues(ps); + if (psb != null) { + bs = psb.bindValues(ps); } else { bs = ps.bind(); }