in tablestore-java-mcp-server-rag/tablestore-mcp-server/src/main/java/com/alicloud/openservices/tablestore/sample/service/TablestoreService.java [362:381]
private void addFAQ(String id, FAQContent entry) {
PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
primaryKeyBuilder.addPrimaryKeyColumn(this.pkName, PrimaryKeyValue.fromString(id));
PrimaryKey primaryKey = primaryKeyBuilder.build();
RowPutChange rowPutChange = new RowPutChange(this.faqStore, primaryKey);
float[] embed = embeddingService.embed(entry.getQuestion());
String embeddingString = embeddingToString(embed);
rowPutChange.addColumn(new Column(this.embeddingField, ColumnValue.fromString(embeddingString)));
String text = entry.getQuestion();
if (text != null) {
rowPutChange.addColumn(new Column(this.textField, ColumnValue.fromString(text)));
}
rowPutChange.addColumn(new Column(this.faqAnswerFieldName, ColumnValue.fromString(entry.getAnswer())));
try {
log.info("store entry id:{}, question:{}, answer:{}, embedding:{}", id, entry.getQuestion(), entry.getAnswer(), maxLogOrNull(embeddingString));
client.putRow(new PutRowRequest(rowPutChange));
} catch (Exception e) {
throw new RuntimeException(String.format("store entry failed, id:%s, question:%s, embedding:%s", id, entry.getQuestion(), maxLogOrNull(embeddingString)), e);
}
}