閱讀552 返回首頁    go 微信

單行數據操作__Java-SDK_SDK 參考_表格存儲-阿裏雲

表格存儲的 SDK 提供了 PutRow、GetRow、UpdateRow 和 DeleteRow 等單行操作的接口。

插入一行數據（PutRow）

插入數據到指定的行。

接口

  1.     /**
  2.      * 向表（Table）中插入或覆蓋一行數據。
  3.      * 
  4.      * @param putRowRequest     執行PutRow操作所需參數的封裝。
  5.      * @return PutRow                 操作的響應內容。
  6.      * @throws OTSException       OTS訪問返回錯誤消息
  7.      * @throws ClientException    請求的返回結果無效， 或由於網絡原因請求失敗， 或訪問超時。
  8.      */
  9.     public PutRowResult putRow(PutRowRequest putRowRequest)
  10.             throws OTSException, ClientException;

示例 1

插入一行數據

  1.     // 定義行的主鍵，必須與創建表時的TableMeta中定義的一致
  2.     RowPrimaryKey primaryKey = new RowPrimaryKey();
  3.     primaryKey.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(1));
  4.     primaryKey.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(101));
  6.     RowPutChange rowChange = new RowPutChange("SampleTable");
  7.     rowChange.setPrimaryKey(primaryKey);
  9.     // 定義要寫入改行的屬性列
  10.     rowChange.addAttributeColumn("col0", ColumnValue.fromLong(10));
  11.     rowChange.addAttributeColumn("col1", ColumnValue.fromLong(111111));
  12.     rowChange.addAttributeColumn("col2", ColumnValue.fromString("北上杭深"));
  14.     // RowExistenceExpectation.EXPECT_NOT_EXIST表示隻有此行不存在時才會執行插入
  15.     rowChange.setCondition(new Condition(RowExistenceExpectation.EXPECT_NOT_EXIST)); 
  17.     try
  18.     {
  19.         // 構造插入數據的請求對象，
  20.         PutRowRequest request = new PutRowRequest();
  21.         request.setRowChange(rowChange);
  23.         // 調用PutRow接口插入數據
  24.         client.PutRow(request);
  26.         // 如果沒有拋出異常，則說明執行成功
  27.         System.out.println("Put row succeeded.");
  28.     } catch (ClientException ex) {
  29.         System.out.println("Put row failed.");
  30.     } catch (OTSException ex) {
  31.         System.out.println("Put row failed.");
  32.     }

提示：

  • RowExistenceExpectation.IGNORE 表示不管此行是否已經存在，都會插入新數據，如果之前有會被覆蓋。

  • RowExistenceExpectation.EXPECT_EXIST 表示隻有此行存在時，才會插入新數據，此時，原有數據也會被覆蓋。

  • RowExistenceExpectation.EXPECT_NOT_EXIST 表示隻有此行不存在時，才會插入數據，否則不執行。

  • 詳細代碼：PutRow@GitHub。

示例 2

根據條件插入一行數據：當行存在，且 col0 小於 5，且 col2 不等於“beijing”的時候才執行插入操作。

  1.     // 定義行的主鍵，必須與創建表時的TableMeta中定義的一致
  2.     RowPrimaryKey primaryKey = new RowPrimaryKey();
  3.     primaryKey.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(1));
  4.     primaryKey.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(101));
  6.     RowPutChange rowChange = new RowPutChange("SampleTable");
  7.     rowChange.setPrimaryKey(primaryKey);
  9.     // 定義要寫入改行的屬性列
  10.     rowChange.addAttributeColumn("col0", ColumnValue.fromLong(10));
  11.     rowChange.addAttributeColumn("col1", ColumnValue.fromLong(111111));
  12.     rowChange.addAttributeColumn("col2", ColumnValue.fromString("北上杭深"));
  14.     try
  15.     {
  16.         //條件1：col0的值小於5
  17.         ColumnCondition filter1 = new RelationalCondition(
  18.             "col0",
  19.             RelationalCondition.CompareOperator.LESS_THAN,
  20.             ColumnValue.fromLong(5));
  22.         //條件2：col2不等於beijing的行
  23.         ColumnCondition filter2 = new RelationalCondition(
  24.             "col2",
  25.             RelationalCondition.CompareOperator.NOT_EQUAL,
  26.             ColumnValue.fromString("beijing"));
  28.         // 組合條件1和條件2，關係是AND
  29.         ColumnCondition cond = new CompositeCondition(CompositeCondition.LogicOperator.AND)
  30.         .addCondition(filter1).addCondition(filter2);
  32.         // RowExistenceExpectation.EXPECT_NOT_EXIST表示隻有此行不存在時才會執行後麵邏輯，否則直接返回
  33.         Condition condition = new Condition(RowExistenceExpectation.EXPECT_NOT_EXIST);
  35.         // 設置列條件，隻有col0小於5且col2不等於beijing的時候才會插入
  36.         condition.setColumnCondition(cond);
  38.         // 設置條件
  39.         rowChange.setCondition(cond);
  41.         // 構造插入數據的請求對象
  42.         PutRowRequest request = new PutRowRequest();
  43.         request.setRowChange(rowChange);
  45.         // 調用PutRow接口插入數據
  46.         client.PutRow(request);
  48.         // 如果沒有拋出異常，則說明執行成功
  49.         System.out.println("Put row succeeded.");
  50.     } catch (ClientException ex) {
  51.         // 如果拋出客戶端異常，則說明參數等有誤
  52.         System.out.println("Put row failed.");
  53.     } catch (OTSException ex) {
  54.         // 如果拋出服務器端異常，則說明請求失敗
  55.         System.out.println("Put row failed.");
  56.     }

讀取一行數據（GetRow）

根據給定的主鍵讀取單行數據。

接口

  1.     /**
  2.      * 返回表（Table）中的一行數據。
  3.      * 
  4.      * @param getRowRequest             執行GetRow操作所需參數的封裝。
  5.      * @return                                    GetRow操作的響應內容。
  6.      * @throws OTSException              OTS訪問返回錯誤消息
  7.      * @throws ClientException           請求的返回結果無效， 或由於網絡原因請求失敗， 或訪問超時。
  8.      */
  9.     public GetRowResult getRow(GetRowRequest getRowRequest)
  10.             throws OTSException, ClientException;

示例 1

讀取一行數據。

  1.     // 定義行的主鍵，必須與創建表時的TableMeta中定義的一致
  2.     RowPrimaryKey primaryKeys = new RowPrimaryKey();
  3.     primaryKeys.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(1));
  4.     primaryKeys.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(101));
  6.     SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("SampleTable");
  7.     criteria.setPrimaryKey(primaryKeys);
  9.     try
  10.     {
  11.         // 構造查詢請求對象，這裏未指定讀哪列，默認讀整行
  12.         GetRowRequest request = new GetRowRequest();
  13.         request.setRowQueryCriteria(criteria);
  15.         // 調用GetRow接口查詢數據
  16.         GetRowResult result = client.getRow(request);
  18.         // 輸出此行的數據
  19.         Row row = result.getRow();
  20.         int consumedReadCU = result.getConsumedCapacity().getCapacityUnit().getReadCapacityUnit();
  21.         System.out.println("Consumed capacity unti：" + consumedReadCU);
  22.         System.out.println("col0：" + row.getColumns().get("col0"));
  23.         System.out.println("col1：" + row.getColumns().get("col1"));
  24.         System.out.println("col2：" + row.getColumns().get("col2"));
  26.         // 如果沒有拋出異常，則說明成功
  27.         System.out.println("Get row succeeded.");
  28.     } catch (ClientException ex) {
  29.         // 如果拋出客戶端異常，則說明參數等有誤
  30.         System.out.println("Get row failed.");
  31.     } catch (OTSException ex) {
  32.         // 如果拋出服務器端異常，則說明請求失敗
  33.         System.out.println("Get row failed.");
  34.     }

提示：

  • 查詢一行數據時，默認返回這一行所有列的數據，如果想隻返回特定行，可以通過 criteria.addColumnsToGet 接口限製，如果將 col0 和 col1 加入到 columnsToGet 中，則隻返回 col0 和 col1 的值。

  • 查詢時也支持按條件過濾，比如當 col0 的值大於 24 時才返回結果。

  • 當同時使用 columnsToGet 和 condition 時，順序是 columnsToGet 先生效，然後再去返回的列中進行過濾。

  • 某列不存在時的行為，可以通過 PassIfMissing 控製。

  • 詳細代碼：GetRow@GitHub。

示例 2

使用過濾功能讀取一行數據。

下麵演示查詢數據，在 col0 和 col2 上麵過濾，隻有滿足條件是 col0 等於24，或者 col2 不等於“chengdu”的列才會返回。

  1.     // 定義行的主鍵，必須與創建表時的TableMeta中定義的一致
  2.     RowPrimaryKey primaryKeys = new RowPrimaryKey();
  3.     primaryKeys.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(1));
  4.     primaryKeys.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(101));
  6.     SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("SampleTable");
  7.     criteria.setPrimaryKey(primaryKeys);
  9.     try
  10.     {
  11.         //條件1：col0的值等於24
  12.         ColumnCondition filter1 = new RelationalCondition(
  13.             "col0",
  14.             RelationalCondition.CompareOperator.EQUAL,
  15.             ColumnValue.fromLong(24));
  17.         //條件2：col2不等於chengdu的行
  18.         ColumnCondition filter2 = new RelationalCondition(
  19.             "col1",
  20.             RelationalCondition.CompareOperator.NOT_EQUAL,
  21.             ColumnValue.fromString("chengdu"));
  23.         // 組合條件1和條件2，關係是OR
  24.         criteria.setFilter(new CompositeCondition(CompositeCondition.LogicOperator.OR)
  25.         .addCondition(filter1).addCondition(filter2));
  27.         // 構造查詢請求對象，這裏未指定讀哪列，默認讀整行
  28.         GetRowRequest request = new GetRowRequest();
  29.         request.setRowQueryCriteria(criteria);
  31.         // 調用GetRow接口查詢數據
  32.         GetRowResult result = client.getRow(request);
  34.         // 輸出此行的數據
  35.         Row row = result.getRow();
  36.         int consumedReadCU = result.getConsumedCapacity().getCapacityUnit().getReadCapacityUnit();
  37.         System.out.println("Consumed capacity unti：" + consumedReadCU);
  38.         System.out.println("col0：" + row.getColumns().get("col0"));
  39.         System.out.println("col2：" + row.getColumns().get("col2"));
  41.         // 如果沒有拋出異常，則說明成功
  42.         System.out.println("Get row succeeded.");
  43.     } catch (ClientException ex) {
  44.         // 如果拋出客戶端異常，則說明參數等有誤
  45.         System.out.println("Get row failed.");
  46.     } catch (OTSException ex) {
  47.         // 如果拋出服務器端異常，則說明請求失敗
  48.         System.out.println("Get row failed.");
  49.     }

更新一行數據（UpdateRow）

更新指定行的數據，如果該行不存在，則新增一行；若該行存在，則根據請求的內容在這一行中新增、修改或者刪除指定列的值。

接口

  1.     /**
  2.      * 更新表的讀或寫CapacityUnit。
  3.      * 
  4.      * @param updateTableRequest        執行UpdateTable操作所需參數的封裝。
  5.      * @return                                       UpdateTable操作的響應內容。
  6.      * @throws OTSException                 OTS訪問返回錯誤消息
  7.      * @throws ClientException             請求的返回結果無效， 或由於網絡原因請求失敗， 或訪問超時。
  8.      */
  9.     public UpdateTableResult updateTable(UpdateTableRequest updateTableRequest)
  10.             throws OTSException, ClientException;

示例

更新一行數據。

  1.     // 定義行的主鍵，必須與創建表時的TableMeta中定義的一致
  2.     RowUpdateChange rowChange = new RowUpdateChange("SampleTable");
  3.     RowPrimaryKey primaryKeys = new RowPrimaryKey();
  4.     primaryKeys.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(1));
  5.     primaryKeys.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(101));
  6.     rowChange.setPrimaryKey(primaryKeys);
  8.     // 定義要寫入改行的屬性列
  9.     rowChange.addAttributeColumn("col0", ColumnValue.fromLong(99));
  10.     rowChange.addAttributeColumn("col2", ColumnValue.fromString("京滬杭深"));
  12.     // 刪除col1
  13.     rowChange.deleteAttributeColumn("col1");
  15.     rowChange.setCondition(new Condition(RowExistenceExpectation.EXPECT_EXIST));
  17.     try
  18.     {
  19.         // 構造更新行的請求對象
  20.         UpdateRowRequest request = new UpdateRowRequest();
  21.         request.setRowChange(rowChange);
  23.         // 調用UpdateRow接口執行
  24.         client.updateRow(request);
  26.         // 如果沒有拋出異常，則說明執行成功
  27.         System.out.println("Update row succeeded.");
  28.     } catch (ClientException ex) {
  29.         // 如果拋出客戶端異常，則說明參數等有誤
  30.         System.out.println("Update row failed.");
  31.     } catch (OTSException ex) {
  32.         // 如果拋出服務器端異常，則說明請求失敗
  33.         System.out.println("Update row failed.");
  34.     }

提示：

刪除一行數據（DeleteRow）

接口

  1.     /**
  2.      * 刪除表（Table）中的一行數據。
  3.      * 
  4.      * @param deleteRowRequest   執行DeleteRow操作所需參數的封裝。
  5.      * @return                               DeleteRow操作的響應內容。
  6.      * @throws OTSException         OTS訪問返回錯誤消息
  7.      * @throws ClientException     請求的返回結果無效， 或由於網絡原因請求失敗， 或訪問超時。
  8.      */
  9.     public DeleteRowResult deleteRow(DeleteRowRequest deleteRowRequest)
  10.             throws OTSException, ClientException;

示例

刪除一行數據。

  1.     // 要刪除的行的PK列分別為0和100
  2.     RowDeleteChange rowChange = new RowDeleteChange("SampleTable");
  3.     RowPrimaryKey primaryKeys = new RowPrimaryKey();
  4.     primaryKeys.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(0));
  5.     primaryKeys.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(100));
  6.     rowChange.setPrimaryKey(primaryKeys);
  8.     try
  9.     {
  10.         // 構造請求
  11.         DeleteRowRequest request = new DeleteRowRequest();
  12.         request.setRowChange(rowChange);
  14.         // 調用DeleteRow接口執行刪除
  15.         client.deleteRow(request);
  17.         // 如果沒有拋出異常，則表示成功
  18.         System.out.println("Delete table succeeded.");
  19.     } catch (ClientException ex) {
  20.         // 如果拋出客戶端異常，則說明參數等有誤
  21.         System.out.println("Delete row failed.");
  22.     } catch (OTSException ex) {
  23.         // 如果拋出服務器端異常，則說明請求失敗
  24.         System.out.println("Delete row failed.");
  25.     }

提示：

最後更新：2016-11-23 16:04:09

  上一篇：go UpdateRowInBatchWriteRowRequest__DataType_API 參考_表格存儲-阿裏雲
  下一篇：go 多行數據操作__Java-SDK_SDK 參考_表格存儲-阿裏雲