AerospikeでOR、AND、NOTなどの複数の論理演算を使用する

Nov 22 2020

私は以下のようなデータを持っています:

+--------+-----------+---------+---------+
| COMPANY| COLOR     | OWNER   | MODEL   |
+--------+-----------+---------+---------+
|Benz    | Red       | p1      | ABC     |
+--------+-----------+---------+---------+
|BMW     | Blue      | P2      | XYZ     |
+--------+-----------+---------+---------+
|Ferrari | YelloW    | P3      | PQR     |
+--------+-----------+---------+---------+
|Audi    | Blue      + P4      | MNO     |
------------------------------------------

ここで、会社がベンツ、カラーがブルー、または所有者がP2のレコードが必要です。Aerospikeのドキュメントを確認しましたが、1回のクエリでそのような操作を実行する方法が見つかりませんでした。C#クライアントを使用してaerospikeでこのSQLクエリをシミュレートしたいと思います。

select * from tablename where (company = Benz or Color = Blue or Owner = P1)

回答

1 pgupta Nov 23 2020 at 22:36

AerospikeのExpressionsを使用して、まさにそれを行うことができます。以下のJavaの例。AerospikeJavaクライアントライブラリの例(公開リポジトリ)でさらに利用できます。これはQueryExp.javaからのものです。(C#クライアントについては、Csharpクライアントコード/ Framework / AerospikeDemoのQueryExp.csを参照してください)

private void runQuery1(
    AerospikeClient client,
    Parameters params,
    String binName
) throws Exception {

    int begin = 10;
    int end = 40;

    console.info("Query Predicate: (bin2 > 126 && bin2 <= 140) || (bin2 = 360)");

    Statement stmt = new Statement();
    stmt.setNamespace(params.namespace);
    stmt.setSetName(params.set);

    // Filter applied on query itself.  Filter can only reference an indexed bin.
    stmt.setFilter(Filter.range(binName, begin, end));

    // Predicates are applied on query results on server side.
    // Predicates can reference any bin.
    QueryPolicy policy = new QueryPolicy(client.queryPolicyDefault);
    policy.filterExp = Exp.build(
        Exp.or(
            Exp.and(
                Exp.gt(Exp.intBin("bin2"), Exp.val(126)),
                Exp.le(Exp.intBin("bin2"), Exp.val(140))),
            Exp.eq(Exp.intBin("bin2"), Exp.val(360))));

    RecordSet rs = client.query(policy, stmt);

    try {
        while (rs.next()) {
            Record record = rs.getRecord();
            console.info("Record: " + record.toString());
        }
    }
    finally {
        rs.close();
    }
}