Java 类org.bson.BSONObject 实例源码

项目：Docussandra 文件：DocumentPersistanceUtils.java

/**
 * Marshals a Cassandra row into a Document object.
 *
 * @param row Row to marshal.
 * @return A document based on the provided row.
 */
public static Document marshalRow(Row row)
{
    if (row == null)
    {
        return null;
    }
    Document d = new Document();
    d.setUuid(row.getUUID(DocumentRepositoryImpl.Columns.ID));
    ByteBuffer b = row.getBytes(DocumentRepositoryImpl.Columns.OBJECT);
    if (b != null && b.hasArray())
    {
        byte[] result = new byte[b.remaining()];
        b.get(result);
        BSONObject o = BSON.decode(result);
        d.setObject(o);
    }
    d.setCreatedAt(row.getDate(DocumentRepositoryImpl.Columns.CREATED_AT));
    d.setUpdatedAt(row.getDate(DocumentRepositoryImpl.Columns.UPDATED_AT));
    return d;
}

项目：mycat-src-1.6.1-RELEASE 文件：SequoiaResultSet.java

@Override
public Object getObject(String columnLabel) throws SQLException {

    if (isSum) {
       if (isGroupBy){
          Object ob=dblist.get(_row-1);
          if (ob instanceof BSONObject) {
              return ((BSONObject)ob).get(columnLabel);
          }
          else {
              return "0";  
          }
       }
       else{
           return  this._sum;
       }
    }
    else {
        return this._cur.get(columnLabel);
    }
}

项目：mycat-src-1.6.1-RELEASE 文件：SequoiaSQLParser.java

private int InsertData(SQLInsertStatement state) {
    if (state.getValues().getValues().size() ==0 ){
        throw new RuntimeException("number of  columns error");
    }       
    if (state.getValues().getValues().size() != state.getColumns().size()){
        throw new RuntimeException("number of values and columns have to match");
    }
    SQLTableSource table=state.getTableSource();
    BSONObject o = new BasicBSONObject();
    int i=0;
    for(SQLExpr col : state.getColumns()) {
        o.put(getFieldName2(col), getExpValue(state.getValues().getValues().get(i)));
        i++;
    }       
    DBCollection coll =this._db.getCollection(table.toString());
    //coll.insert(new DBObject[] { o });
    coll.insert(o);
    return 1;
}

项目：mycat-src-1.6.1-RELEASE 文件：SequoiaSQLParser.java

private int UpData(SQLUpdateStatement state) {
    SQLTableSource table=state.getTableSource();
    DBCollection coll =this._db.getCollection(table.toString());

    SQLExpr expr=state.getWhere();
    BSONObject query = parserWhere(expr);

    BasicBSONObject set = new BasicBSONObject();
    for(SQLUpdateSetItem col : state.getItems()){
        set.put(getFieldName2(col.getColumn()), getExpValue(col.getValue()));   
    }
    BSONObject mod = new BasicBSONObject("$set", set);
    //coll.updateMulti(query, mod);
    coll.update(query, mod, null);
    //System.out.println("changs count:"+coll.getStats().size());
    return 1;       
}

项目：athena 文件：Marking.java

public boolean checkElements(BSONObject index, BSONObject feature) {

        if (srcIpMask == 0 && dstIpMask == 0) {
            //marking according to featureConstraint
            return featureDatabaseMgmtManager.isSatisfyOnlineEvent(
                    (Document) index,
                    (Document) feature,
                    featureConstraint);
        }

        if (srcIpMask != 0 && index.get(AthenaIndexField.MATCH_IPV4_SRC) != null ) {
            int ipsrc = (Integer) index.get(AthenaIndexField.MATCH_IPV4_SRC);
            if ((ipsrc & this.srcIpMask) == srcComparator) {
                return true;
            }
        }

        if (dstIpMask != 0 && index.get(AthenaIndexField.MATCH_IPV4_DST) != null) {
            int ipdst = (Integer) index.get(AthenaIndexField.MATCH_IPV4_DST);
            if ((ipdst & this.dstIpMask) == dstComparator) {
                return true;
            }
        }
        return false;
    }

项目：athena 文件：Marking.java

public int checkClassificationMarkingElements(BSONObject index, BSONObject feature) {
    ClassificationMarkingElement classificationMarkingElement;
    boolean check = false;
    for (int i = 1 ; i < listofClassificationMarkingElement.size() ; i++){
        classificationMarkingElement = listofClassificationMarkingElement.get(i);
        check = checkElements(index,feature,
                classificationMarkingElement.featureConstraint,
                classificationMarkingElement.getSrcIpMask(),
                classificationMarkingElement.getSrcComparator(),
                classificationMarkingElement.getDstIpMask(),
                classificationMarkingElement.getDstComparator());

        if(check){
            return classificationMarkingElement.getLabel();
        }
    }
    return 0;
}

项目：athena 文件：LogisticRegressionDistJob.java

public LogisticRegressionModel generateDecisionTreeWithPreprocessing(JavaPairRDD<Object, BSONObject> mongoRDD,
                                                               AthenaMLFeatureConfiguration athenaMLFeatureConfiguration,
                                                               LogisticRegressionDetectionAlgorithm logisticRegressionDetectionAlgorithm,
                                                               Marking marking,
                                                               LogisticRegressionModelSummary logisticRegressionModelSummary) {

    return generateKMeansModel(
            rddPreProcessing(mongoRDD, athenaMLFeatureConfiguration, logisticRegressionModelSummary,
                    marking),
            logisticRegressionDetectionAlgorithm, logisticRegressionModelSummary
    );
}

项目：SequoiaDB-ORM 文件：SequoiaDataAccess.java

/**
 * 
 * @param dbcollection
 * @return
 */
public List<BSONObject> queryAll() {
    List<BSONObject> list = new ArrayList<BSONObject>();
    DBCursor cursor = null;
    Sequoiadb sdb = DbConnectionPool.getConnection();
    try {
        cursor = getDbCollection(sdb).query();
        while (cursor.hasNext()) {
            BSONObject record = cursor.getNext();
            list.add(record);
        }
    } catch (BaseException e) {

        e.printStackTrace();
    } finally {
        DbConnectionPool.free(sdb);
    }
    return list;
}

项目：SequoiaDB-ORM 文件：SequoiaDataAccess.java

/**
 * 
 * 查询多少条数据
 * 
 * @param matcher
 * @param selector
 * @param order
 * @param skipRows
 * @param returnRows
 * @return
 */
public List<BSONObject> query(BSONObject matcher, BSONObject selector, BSONObject order, long skipRows,
        long returnRows) {
    Sequoiadb sdb = DbConnectionPool.getConnection();
    List<BSONObject> list = new ArrayList<BSONObject>();
    DBCursor cursor = null;
    try {
        cursor = getDbCollection(sdb).query(matcher, selector, order, null, skipRows, returnRows);
        while (cursor.hasNext()) {
            BSONObject record = cursor.getNext();
            list.add(record);
        }
    } catch (BaseException e) {

        e.printStackTrace();
    } finally {
        DbConnectionPool.free(sdb);
    }
    return list;
}