DynamoDB的基本操作（一）

一、創建表 

 1 var AWS = require("aws-sdk");
 2 AWS.config.update({
 3     region: "us-west-2",                          //使用哪個區域的aws服務
 4     endpoint: "http://localhost:8000" //dynamodb位置
 5 });
 6 var dynamodb = new AWS.DynamoDB();
 7 
 8 var params = {
 9     TableName: "Movies",//表名
10     KeySchema: [       //主鍵
11         {AttributeName: "year", KeyType: "HASH"},  //Partition key 分區鍵
12         {AttributeName: "title", KeyType: "RANGE"}  //Sort key    排序鍵
13     ],
14     AttributeDefinitions: [//主鍵數據類型    
15         {AttributeName: "year", AttributeType: "N"},//N Number
16         {AttributeName: "title", AttributeType: "S"}   //S String
17     ],
18     ProvisionedThroughput: { //DynamoDB吞吐量配置
19         ReadCapacityUnits: 10,
20         WriteCapacityUnits: 10
21     }
22 };
23 dynamodb.createTable(params, function (err, data) {
24     if (err) {
25         console.error("Unable to create table. Error JSON:", JSON.stringify(err, null, 2));
26     } else {
27         console.log("Created table. Table description JSON:", JSON.stringify(data, null, 2));
28     }
29 });

二、增加項 

var docClient = new AWS.DynamoDB.DocumentClient();
var table = "Movies";
var year = 2015;
var title = "The Big New Movie";
var params = {
    TableName: table,//要操作的表名
    Item: {
        "year": year,//主鍵-分區間
        "title": title,//主鍵-排序鍵
        "info": {     //其他屬性
            "plot": "Nothing happens at all.", "rating": 0
        }
    }
};
console.log("Adding a new item...");
docClient.put(params, function (err, data) {
    if (err) {
        console.error("Unable to add item. Error JSON:", JSON.stringify(err, null, 2));
    } else {
        console.log("Added item:", JSON.stringify(data, null, 2));
    }
});

 三、獲取項 

var docClient = new AWS.DynamoDB.DocumentClient()
var table = "Movies";//表名必須填
var year = 2015;  //待查詢的分區鍵
var title = "The Big New Movie";//待查詢的排序鍵   如果表建立時設置為復合主鍵的話，分區鍵排序鍵必須都存在
var params = {TableName: table, Key: {"year": year, "title": title}};
docClient.get(params, function (err, data) {
    if (err) {
        console.error("Unable to read item. Error JSON:", JSON.stringify(err, null, 2));
    } else {
        console.log("GetItem succeeded:", JSON.stringify(data, null, 2));
    }
});

 四、更新項 

var table = "Movies";
var year = 2015;
var title = "The Big New Movie"; // Update the item, unconditionally,
var params = {
    TableName: table, Key: {
        "year": year,//分區鍵
        "title": title//排序鍵   主鍵在update接口必須
    }, UpdateExpression: "set info.rating = :r, info.plot=:p, info.actors=:a",//想要改變值的表達式
    ExpressionAttributeValues: {      //為想要改變的值賦值
        ":r": 5.5, ":p": "Everything happens all at once.", ":a": ["Larry", "Moe", "Curly"]
    }, ReturnValues: "UPDATED_NEW"//返回更新值，即下中data
};
console.log("Updating the item...");
docClient.update(params, function (err, data) {
    console.log(data);
    if (err) {
        console.error("Unable to update item. Error JSON:", JSON.stringify(err, null, 2));
    } else {
        console.log("UpdateItem succeeded:", JSON.stringify(data, null, 2));
    }
});

五、刪除項 

var table = "Movies";
var year = 2015;
var title = "The Big New Movie";
var params = {
    TableName: table,//待刪除操作的表
    Key: {
        "year": year,//分區鍵
        "title": title//排序鍵
    },
    ExpressionAttributeNames:{"#u":"User"},
    ConditionExpression: "#u = :val",//刪除條件表達式
    ExpressionAttributeValues: {
        ":val": 5.0   //條件值
    }
};
console.log("Attempting a conditional delete...");
docClient.delete(params, function (err, data) {
    if (err) {
        console.error("Unable to delete item. Error JSON:", JSON.stringify(err, null, 2));
    } else {
        console.log("DeleteItem succeeded:", JSON.stringify(data, null, 2));
    }
});

 六、批量查詢 

var params = {
 RequestItems: {
  "GsdSubDevices": {
   Keys: [
    {
     "Mac": "haha"
    },
    {
     "Mac": "111"
    },
    {
     "Mac": "222"
    }
   ]
  }
 }
};
console.log("requestArr===>" + JSON.stringify(requestArr));
docClient.batchGet(params, function (err, data) {
 if (err) {
  console.error("Unable to read item. Error JSON:", JSON.stringify(err, null, 2));
 } else {
 
 }
});

 

 推薦操作數據庫時使用以上操作，操作DynamoDB數據庫有兩種方式，另一種見DynamoBD常見操作（二），這種方式比較繁瑣，不推薦使用