表格存儲提供了單行插入、單行更新和批量寫入的寫入方式用于寫入數據到數據表。當要寫入數據到數據表時，您需要指定完整主鍵以及要增刪改的屬性列。在高并發應用中寫入數據時，您可以配置行存在性條件或者列條件實現按照指定條件更新數據。
如果需要了解表格存儲各場景的應用案例，請參見快速玩轉Tablestore入門與實戰。
前提條件
- 已初始化Client，詳情請參見初始化OTSClient。
- 已創建數據表并寫入數據。
插入單行數據
調用PutRow接口新寫入一行數據。如果該行已存在，則先刪除原行數據（原行的所有列以及所有版本的數據），再寫入新行數據。
接口
// @param PutRowRequest 執行PutRow操作所需參數的封裝。
// @return PutRowResponse
PutRow(request *PutRowRequest) (*PutRowResponse, error) 參數
參數 | 說明 |
TableName | 數據表名稱。 |
PrimaryKey | 行的主鍵。主鍵包括主鍵列名、主鍵類型和主鍵值。 重要
|
Columns | 行的屬性列。每一項的順序是屬性名、屬性值ColumnValue、屬性類型ColumnType（可選）、時間戳（可選）。
|
Condition | 使用條件更新，可以設置原行的存在性條件或者原行中某列的列值條件。更多信息，請參見條件更新。 |
示例
以下示例用于插入一行數據。
putRowRequest := new(tablestore.PutRowRequest)
putRowChange := new(tablestore.PutRowChange)
putRowChange.TableName = tableName
putPk := new(tablestore.PrimaryKey)
putPk.AddPrimaryKeyColumn("pk1", "pk1value1")
putPk.AddPrimaryKeyColumn("pk2", int64(2))
putPk.AddPrimaryKeyColumn("pk3", []byte("pk3"))
putRowChange.PrimaryKey = putPk
putRowChange.AddColumn("col1", "col1data1")
putRowChange.AddColumn("col2", int64(3))
putRowChange.AddColumn("col3", []byte("test"))
putRowChange.SetCondition(tablestore.RowExistenceExpectation_IGNORE)
putRowRequest.PutRowChange = putRowChange
_, err := client.PutRow(putRowRequest)
if err != nil {
fmt.Println("putrow failed with error:", err)
} else {
fmt.Println("putrow finished")
} 詳細代碼請參見PutRow@GitHub。
更新單行數據
調用UpdateRow接口更新一行數據，可以增加和刪除一行中的屬性列，刪除屬性列指定版本的數據，或者更新已存在的屬性列的值。如果更新的行不存在，則新增一行數據。
當UpdateRow請求中只包含刪除指定的列且該行不存在時，則該請求不會新增一行數據。
接口
// 更新表中的一行數據。
// @param UpdateRowRequest 執行UpdateRow操作所需參數的封裝。
// @return UpdateRowResponse UpdateRow操作的響應內容。
UpdateRow(request *UpdateRowRequest) (*UpdateRowResponse, error) 參數
參數 | 說明 |
TableName | 數據表名稱。 |
PrimaryKey | 行的主鍵。主鍵包括主鍵列名、主鍵類型和主鍵值。 重要 設置的主鍵個數和類型必須和數據表的主鍵個數和類型一致。 |
Columns | 行的屬性列。
|
Condition | 使用條件更新，可以設置原行的存在性條件或者原行中某列的列值條件。更多信息，請參見條件更新。 |
示例
以下示例用于更新一行數據。
updateRowRequest := new(tablestore.UpdateRowRequest)
updateRowChange := new(tablestore.UpdateRowChange)
updateRowChange.TableName = tableName
updatePk := new(tablestore.PrimaryKey)
updatePk.AddPrimaryKeyColumn("pk1", "pk1value1")
updatePk.AddPrimaryKeyColumn("pk2", int64(2))
updatePk.AddPrimaryKeyColumn("pk3", []byte("pk3"))
updateRowChange.PrimaryKey = updatePk
updateRowChange.DeleteColumn("col1")
updateRowChange.PutColumn("col2", int64(77))
updateRowChange.PutColumn("col4", "newcol3")
updateRowChange.SetCondition(tablestore.RowExistenceExpectation_EXPECT_EXIST)
updateRowRequest.UpdateRowChange = updateRowChange
_, err := client.UpdateRow(updateRowRequest)
if err != nil {
fmt.Println("update failed with error:", err)
} else {
fmt.Println("update row finished")
} 詳細代碼請參見UpdateRow@GitHub。
批量寫入數據
調用BatchWriteRow接口在一次請求中進行批量寫入操作或者一次對多張表進行寫入。
BatchWriteRow操作由多個PutRow、UpdateRow、DeleteRow子操作組成，構造子操作的過程與使用PutRow接口、UpdateRow接口和DeleteRow接口時相同。
BatchWriteRow的各個子操作獨立執行，表格存儲會分別返回各個子操作的執行結果。
注意事項
由于批量寫入可能存在部分行失敗的情況，失敗行的Index及錯誤信息在返回的BatchWriteRowResponse中，但并不拋出異常。因此調用BatchWriteRow接口時，需要檢查返回值，判斷每行的狀態是否成功；如果不檢查返回值，則可能會忽略掉部分操作的失敗。
當服務端檢查到某些操作出現參數錯誤時，BatchWriteRow接口可能會拋出參數錯誤的異常，此時該請求中所有的操作都未執行。
BatchWriteRow操作單次支持寫入的最大行數為200行，且所有行的數據量總和不能超過4 MB。
接口
// 對多個數據表中的多行數據進行增加、刪除或者更新操作。
// @param BatchWriteRowRequest 執行BatchWriteRow操作所需參數的封裝。
// @return BatchWriteRowResponse BatchWriteRow操作的響應內容。
BatchWriteRow(request *BatchWriteRowRequest) (*BatchWriteRowResponse,error) 示例
以下示例用于批量寫入100行數據。
batchWriteReq := &tablestore.BatchWriteRowRequest{}
for i := 0; i < 100; i++ {
putRowChange := new(tablestore.PutRowChange)
putRowChange.TableName = tableName
putPk := new(tablestore.PrimaryKey)
putPk.AddPrimaryKeyColumn("pk1", "pk1value1")
putPk.AddPrimaryKeyColumn("pk2", int64(i))
putPk.AddPrimaryKeyColumn("pk3", []byte("pk3"))
putRowChange.PrimaryKey = putPk
putRowChange.AddColumn("col1", "fixvalue")
putRowChange.SetCondition(tablestore.RowExistenceExpectation_IGNORE)
batchWriteReq.AddRowChange(putRowChange)
}
response, err := client.BatchWriteRow(batchWriteReq)
if err != nil {
fmt.Println("batch request failed with:", response)
} else {
fmt.Println("batch write row finished")
} 詳細代碼請參見BatchWriteRow@GitHub。