使用 API 添加表数据
在表中添加行。将数据存储在表行中时，应用程序可以轻松地从表中检索、添加或删除信息。
PutRequest 类 / put 方法执行无条件和条件放置：
- 覆盖任何现有行。覆盖是默认功能。
- 仅当行不存在时成功。在本例中使用
IfAbsent方法。 - 仅当该行存在时成功。在本例中使用
IfPresent方法。 - 仅当行存在且版本与特定版本匹配时才成功。在此情况下使用
IfVersion方法，使用setMatchVersion方法指定要匹配的版本。
PutRequest 类提供了 setValueFromJson 方法，该方法接受 JSON 字符串并使用它填充行以插入到表中。JSON 字符串应指定与表字段名称对应的字段名称。
private static void writeRows(NoSQLHandle handle, MapValue value)
throws Exception {
PutRequest putRequest =
new PutRequest().setValue(value).setTableName(tableName);
PutResult putResult = handle.put(putRequest);
if (putResult.getVersion() != null) {
System.out.println("Added a row to the stream_acct table");
} else {
System.out.println("Put failed");
}
}borneo.PutRequest 类表示用于插入单行的 borneo.NoSQLHandle.put() 方法的输入。
此外，还可以将 JSON 数据添加到您的表。对于固定方案表，JSON 将转换为目标方案。JSON 数据可以直接插入到 JSON 类型的列中。使用 JSON 数据类型可以创建不使用固定模式的表数据，从而更灵活地使用数据。
def insert_record(handle,table_name,acct_data):
request = PutRequest().set_table_name(table_name)
.set_value_from_json(acct_data)
handle.put(request)
print('Added a row to the stream_acct table')
nosqldb.PutRequest 表示 nosqldb.Put() 函数的输入，用于插入单行。
为行（在 PutRequest 中）提供的数据值为 *types.MapValue。MapValue 中每个条目的 key 部分必须与目标表的列名匹配，value 部分必须为列的有效值。JSON 数据也可以直接插入到 JSON 类型的列中。使用 JSON 数据类型可以创建不使用固定模式的表数据，从而更灵活地使用数据。
func insertData(client *nosqldb.Client, err error,
tableName string,value1 *types.MapValue )(){
putReq := &nosqldb.PutRequest{
TableName: tableName,
Value: value1,
}
putRes, err := client.Put(putReq)
if err != nil {
fmt.Printf("failed to put single row: %v\n", err)
return
}
fmt.Printf("Added a row to the stream_acct table\n")
} 使用 put 方法向表中插入一行。有关方法详细信息，请参见 NoSQLClient 类。
/* Adding 3 records in acct_stream table */
let putResult = await handle.put(TABLE_NAME, JSON.parse(acct1));
let putResult1 = await handle.put(TABLE_NAME, JSON.parse(acct2));
let putResult2 = await handle.put(TABLE_NAME, JSON.parse(acct3));
console.log("Added rows to the stream_acct table");interface StreamInt {
acct_Id: Integer;
profile_name: String;
account_expiry: TIMESTAMP;
acct_data: JSON;
}
/* Adding 3 records in acct_stream table */
let putResult = await handle.put<StreamInt>(TABLE_NAME, JSON.parse(acct1));
let putResult1 = await handle.put<StreamInt>(TABLE_NAME, JSON.parse(acct2));
let putResult2 = await handle.put<StreamInt>(TABLE_NAME, JSON.parse(acct3));
console.log("Added rows to the stream_acct table");方法 PutAsync 和相关方法 PutIfAbsentAsync、PutIfPresentAsync 和 PutIfVersionAsync 用于在表中插入一行或更新一行。
上面的每个 Put 方法都返回 Task<PutResult<RecordValue>>。PutResult 实例包含有关已完成 Put 操作的信息，例如成功状态（如果不满足相应条件，条件放置操作可能会失败）和生成的 RowVersion。请注意，结果的“成功”属性仅表示与条件放置操作相关的成功完成，并且对于无条件放置始终为真。如果 Put 操作因任何其他原因而失败，将引发异常错误。使用数据类型 JSON 的字段可以更灵活地使用数据，因为 JSON 字段中的数据没有预定义的方案。要将值放入 JSON 字段，请提供 MapValue 实例作为其字段值作为行值的一部分。您还可以通过 FieldValue.FromJsonString 从 JSON 字符串创建其值。
private static async Task insertData(NoSQLClient client, String acctdet){
var putResult = await client.PutAsync(TableName,
FieldValue.FromJsonString(acctdet).AsMapValue);
if (putResult.ConsumedCapacity != null)
{
Console.WriteLine(" Added a row to the stream_acct table");
}
}相关主题
您可以使用 MultiWrite API 在单个数据库操作中添加多行数据。
可以使用 WriteMultipleRequest 类执行与表关联的 PutRequest 操作序列，该表与使用主键的单个原子写入操作共享其主键的分片键部分。还可以使用 WriteMultipleRequest 类同时向父表和子表添加数据。这是一种以原子方式修改多个相关行的有效方法。如果操作成功，则 WriteMultipleResult.getSuccess() 方法返回 true。
有关各种类和方法的更多详细信息，请参阅 Oracle NoSQL Java SDK API Reference 。
private static void writeMul(NoSQLHandle handle,String parent_tblname,
String parent_data, String child_tblname, String child_data){
WriteMultipleRequest umRequest = new WriteMultipleRequest();
PutRequest putRequest =
new PutRequest().setValueFromJson(parent_data,null).setTableName(parent_tblname);
umRequest.add(putRequest, false);
putRequest =
new PutRequest().setValueFromJson(child_data,null).setTableName(child_tblname);
umRequest.add(putRequest, false);
WriteMultipleResult umResult = handle.writeMultiple(umRequest);
}可以使用 borneo.WriteMultipleRequest 类执行与表关联的 PutRequest 操作序列，该表与使用主键的单个原子写入操作共享其主键的分片键部分。还可以使用 borneo.WriteMultipleRequest 类同时向父表和子表添加数据。这是一种以原子方式修改多个相关行的有效方法。
有关各种类和方法的更多详细信息，请参见 Oracle NoSQL Python SDK API Reference 。
def mul_write(handle,parent_tblname,parent_data,
child_tblname, child_data):
request = PutRequest()
request.set_value_from_json(parent_data)
request.set_table_name('ticket')
wm_req.add(request, True)
request1 = PutRequest()
request1.set_table_name(child_tblname)
request1.set_value_from_json(child_data)
wm_req.add(request1, True)
result = handle.write_multiple(wm_req)可以使用 WriteMultipleRequest 类执行与表关联的 PutRequest 操作序列，该表与使用主键的单个原子写入操作共享其主键的分片键部分。还可以使用 WriteMultipleRequest 类同时向父表和子表添加数据。这是一种以原子方式修改多个相关行的有效方法。
有关各种类和方法的更多详细信息，请参阅 Oracle NoSQL Go SDK API Reference 。
//multiple write from the table
func mul_write(client *nosqldb.Client, err error, parenttbl_name string,
parent_data string, childtbl_name string, child_data string)(){
value, err := types.NewMapValueFromJSON(parent_data)
putReq := &nosqldb.PutRequest{
TableName: parenttbl_name,
Value: value,
}
wmReq := &nosqldb.WriteMultipleRequest{
TableName: "",
Timeout: 10 * time.Second,
}
wmReq.AddPutRequest(putReq, true)
value1, err := types.NewMapValueFromJSON(child_data)
putReq1 := &nosqldb.PutRequest{
TableName: childtbl_name,
Value: value1,
}
wmReq.AddPutRequest(putReq1, true)
wmRes, err := client.WriteMultiple(wmReq)
if err != nil {
fmt.Printf("WriteMultiple() failed: %v\n", err)
return
}
if wmRes.IsSuccess() {
fmt.Printf("WriteMultiple() succeeded\n")
} else {
fmt.Printf("WriteMultiple() failed\n")
}
}可以使用 writeMany 方法执行与表关联的放置操作序列，该表与其主键的分片键部分共享为单个原子写入操作。还可以使用 writeMany 方法同时向父表和子表添加数据。这是一种以原子方式修改多个相关行的有效方法。
有关方法详细信息，请参见 NoSQLClient 类。
const ops = [
{
tableName: 'ticket',
put: {
"ticketNo": "1762344493810",
"confNo" : "LE6J4Z"
},
abortOnFail: true
},
{
tableName: 'ticket.bagInfo',
put: {
"ticketNo":"1762344493810",
"id":"79039899165297",
"tagNum":"17657806255240",
"routing":"MIA/LAX/MEL",
"lastActionCode":"OFFLOAD",
"lastActionDesc":"OFFLOAD",
"lastSeenStation":"MEL",
"lastSeenTimeGmt":"2019-02-01T16:13:00Z",
"bagArrivalDate":"2019-02-01T16:13:00Z"
},
abortOnFail: true
}
];
const res = await handle.writeMany(ops, null);const ops = [
{
tableName: 'ticket',
put: {
"ticketNo": "1762344493810",
"confNo" : "LE6J4Z"
},
abortOnFail: true
},
{
tableName: 'ticket.bagInfo',
put: {
"ticketNo":"1762344493810",
"id":"79039899165297",
"tagNum":"17657806255240",
"routing":"MIA/LAX/MEL",
"lastActionCode":"OFFLOAD",
"lastActionDesc":"OFFLOAD",
"lastSeenStation":"MEL",
"lastSeenTimeGmt":"2019-02-01T16:13:00Z",
"bagArrivalDate":"2019-02-01T16:13:00Z"
},
abortOnFail: true
}
];
const res = await handle.writeMany(ops, null);可以使用 PutManyAsync 方法执行与表关联的放置操作序列，该表与其主键的分片键部分共享为单个原子写入操作。还可以使用 PutManyAsync 方法同时向父表和子表添加数据。这是一种以原子方式修改多个相关行的有效方法。
有关所有类和方法的更多详细信息，请参阅 Oracle NoSQL Dotnet SDK API Reference 。
private static async Task mul_write(NoSQLClient client,string parentbl_name,
string data1, string childtbl_name, string data2){
var result = await client.WriteManyAsync(
new WriteOperationCollection()
.AddPut(parentbl_name, FieldValue.FromJsonString(data1).AsMapValue)
.AddPut(childtbl_name, FieldValue.FromJsonString(data2).AsMapValue)
);
}