src/org/ohmage/query/impl/ObserverQueries.java
@Override
							public PreparedStatement createPreparedStatement(
									final Connection connection)
									throws SQLException {
								
								PreparedStatement ps =
									connection.prepareStatement(
										streamSql,
										new String[] { "id" });
								
								ps.setString(1, streamId);
								ps.setLong(2, stream.getVersion());
								ps.setString(3, stream.getName());
								ps.setString(4, stream.getDescription());
								ps.setObject(5, stream.getWithId());
								ps.setObject(6, stream.getWithTimestamp());
								ps.setObject(7, stream.getWithLocation());
								ps.setString(8, schema);
								
								return ps;
							}
/**
							 * Create the stream insertion statement.
							 */
Create the stream insertion statement.
Create the stream insertion statement .
@Override
							public PreparedStatement createPreparedStatement(
									final Connection connection)
									throws SQLException {
								PreparedStatement ps =
									connection.prepareStatement(
										streamSql,
										new String[] { "id" });
								ps.setString(1, streamId);
								ps.setLong(2, stream.getVersion());
								ps.setString(3, stream.getName());
								ps.setString(4, stream.getDescription());
								ps.setObject(5, stream.getWithId());
								ps.setObject(6, stream.getWithTimestamp());
								ps.setObject(7, stream.getWithLocation());
								ps.setString(8, schema);
								return ps;
							}
@ Override public PreparedStatement createPreparedStatement ( final Connection connection ) throws SQLException { PreparedStatement ps = connection . prepareStatement ( streamSql , new String [ ] { "id" } ) ; ps . setString ( 1 , streamId ) ; ps . setLong ( 2 , stream . getVersion ( ) ) ; ps . setString ( 3 , stream . getName ( ) ) ; ps . setString ( 4 , stream . getDescription ( ) ) ; ps . setObject ( 5 , stream . getWithId ( ) ) ; ps . setObject ( 6 , stream . getWithTimestamp ( ) ) ; ps . setObject ( 7 , stream . getWithLocation ( ) ) ; ps . setString ( 8 , schema ) ; return ps ; }
Create the stream insertion statement.
Create the stream insertion statement .