Examples of com.datastax.driver.core.PreparedStatement.bind()

Class com.datastax.driver.core.PreparedStatement

Examples of com.datastax.driver.core.PreparedStatement.bind()

com.datastax.driver.core.PreparedStatement.bind()
Creates a new BoundStatement object and bind its variables to the provided values.
While the number of {@code values} cannot be greater than the number of boundvariables, the number of {@code values} may be fewer than the number of boundvariables. In that case, the remaining variables will have to be bound to values by another mean because the resulting {@code BoundStatement}being executable.
This method is a convenience for {@code new BoundStatement(this).bind(...)}. @param values the values to bind to the variables of the newly createdBoundStatement. @return the newly created {@code BoundStatement} with its variablesbound to {@code values}. @throws IllegalArgumentException if more {@code values} are providedthan there is of bound variables in this statement. @throws InvalidTypeException if any of the provided value is not ofcorrect type to be bound to the corresponding bind variable. @throws NullPointerException if one of {@code values} is a collection(List, Set or Map) containing a null value. Nulls are not supported in collections by CQL. @see BoundStatement#bind

    }


    BoundStatement buildModifyInitial(Session session, PersistOption[] persistOptions, PreparedStatements.StatementType statementType,
                                      Binder binder) {
        PreparedStatement pStmt = preparedStatements.statementFor(session, statementType, binder, persistOptions);
        BoundStatement bStmt = pStmt.bind();


        binder.bindColumns(0, bStmt);


        PersistOption.forBoundStatement(persistOptions, bStmt);
        return bStmt;

View Full Code Here

        } catch (Throwable t) {
            throw new RuntimeException("Invalid primary key element "+Arrays.toString(primaryKey), t);
        }


        PreparedStatement pstmt = preparedStatements.statementFor(session, PreparedStatements.StatementType.SELECT, binder, persistOptions);
        BoundStatement bStmt = pstmt.bind();
        statementOptions.applyRead(bStmt, readConsistencyLevel, persistOptions);
        PersistOption.forBoundStatement(persistOptions, bStmt);


        idx = binder.bindColumns(0, bStmt);

View Full Code Here


        Session session = persistenceSession.driverSession();


        PreparedStatement pstmt = preparedStatements
            .statementFor(session, PreparedStatements.StatementType.SELECT, binder, persistOptions);
        BoundStatement bStmt = pstmt.bind();
        statementOptions.applyRead(bStmt, readConsistencyLevel, persistOptions);
        PersistOption.forBoundStatement(persistOptions, bStmt);


        int idx = binder.bindColumns(0, bStmt);

View Full Code Here


        CqlColumn[] readColumns = readColumns(persistOptions);


        PreparedStatement pstmt = preparedStatements.statementFor(queryBinder.session, PreparedStatements.StatementType.SELECT,
            readColumns, queryBinder.conditionFor((Class<? extends T>) type), persistOptions);
        BoundStatement bStmt = pstmt.bind();
        statementOptions.applyRead(bStmt, readConsistencyLevel, persistOptions);
        PersistOption.forBoundStatement(persistOptions, bStmt);
        queryBinder.addStatement((Class<? extends T>) type, bStmt, readColumns);
    }

View Full Code Here

        if (isAbstract) {
            throw new ModelUseException("type " + type.getName() + " is abstract");
        }


        PreparedStatement pStmt = preparedStatements.statementFor(session, statementType, binder, persistOptions);
        BoundStatement bStmt = pStmt.bind();


        binder.bindColumns(0, bStmt);


        PersistOption.forBoundStatement(persistOptions, bStmt);
        return bStmt;

View Full Code Here

        } catch (Throwable t) {
            throw new RuntimeException("Invalid primary key element "+Arrays.toString(primaryKey), t);
        }


        PreparedStatement pstmt = preparedStatements.statementFor(session, PreparedStatements.StatementType.SELECT, binder, persistOptions);
        BoundStatement bStmt = pstmt.bind();
        statementOptions.applyRead(bStmt, readConsistencyLevel, persistOptions);
        PersistOption.forBoundStatement(persistOptions, bStmt);


        idx = binder.bindColumns(0, bStmt);

View Full Code Here


        Session session = persistenceSession.driverSession();


        PreparedStatement pstmt = preparedStatements
            .statementFor(session, PreparedStatements.StatementType.SELECT, binder, persistOptions);
        BoundStatement bStmt = pstmt.bind();
        statementOptions.applyRead(bStmt, readConsistencyLevel, persistOptions);
        PersistOption.forBoundStatement(persistOptions, bStmt);


        int idx = binder.bindColumns(0, bStmt);

View Full Code Here


        CqlColumn[] readColumns = readColumns(persistOptions);


        PreparedStatement pstmt = preparedStatements.statementFor(queryBinder.session, PreparedStatements.StatementType.SELECT,
            readColumns, queryBinder.conditionFor((Class<? extends T>) type), persistOptions);
        BoundStatement bStmt = pstmt.bind();
        statementOptions.applyRead(bStmt, readConsistencyLevel, persistOptions);
        PersistOption.forBoundStatement(persistOptions, bStmt);
        queryBinder.addStatement((Class<? extends T>) type, bStmt, readColumns);
    }

View Full Code Here

    PreparedStatement preparedStatement = cpsc.createPreparedStatement(getSession());
    addPreparedStatementOptions(preparedStatement, options);


    Session s = getSession();
    while (rowIterator.hasNext()) {
      s.executeAsync(preparedStatement.bind(rowIterator.next()));
    }
  }


  @Override
  public void ingest(String cql, RowIterator rowIterator) {

View Full Code Here

      public Object doInSession(Session s) throws DataAccessException {


        String cql = "insert into book (isbn, title, author, pages) values (?, ?, ?, ?)";


        PreparedStatement ps = s.prepare(cql);
        BoundStatement bs = ps.bind(isbn, title, author, pages);


        s.execute(bs);


        return null;

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.