每天学习一点点,成功增加一大步

NodeJs 阿里云的表格存储

NodsJS zhanghui 305℃

二、批量读取

读表时的配置信息

var time = Long.fromNumber(Date.now());
var params = {
    tableName: "message",
    direction: TableStore.Direction.BACKWARD,
    // 包含起始主键
    inclusiveStartPrimaryKey: [{
        "partition_key": md5(body.From_Account+"|"+body.To_Account).slice(0, 4)
    }, {
        "receive_id": body.To_Account
    }, {
        "from_id": body.From_Account
    }, {
        "msg_time": time
    }],
    // 专用结束主键
    exclusiveEndPrimaryKey: [{
        "partition_key": md5(body.From_Account+"|"+body.To_Account).slice(0, 4)
    }, {
        "receive_id": body.To_Account
    }, {
        "from_id": body.From_Account
    }, {
        // 测试同是 msg_time 但 inclusiveStartPrimaryKey 中的必须比 exclusiveEndPrimaryKey 要大
        "msg_time": TableStore.INF_MIN
    }],
    limit: 2
};
console.log(params);

读表操作

client.getRange(params, function (err, data) {
    if (err) {
        console.log('error:', err);
        reject(err);
    }
    var resultRows = data.rows;
    var obj = {
        History: []
    };
    console.log(data)
    obj.Next = data.next_start_primary_key ? data.next_start_primary_key[3].value.toString() : null;
    // console.log("data", data.next_start_primary_key[3].value.toString());
    for (let i = resultRows.length-1; i >-1; i--) {
        const item = resultRows[i];
        obj.History.push(JSON.parse(item.attributes[0].columnValue));
        console.log(item);
    }
    console.log(obj)
});

第一次接触【表格存储】,对于它的使用来说还是有些陌生。

转载请注明:隨習筆記 » NodeJs 阿里云的表格存储