本文通過程式碼範例向您介紹如何使用BufferedWriter介面實現資料上傳。
// 初始化MaxCompute和tunnel的代碼。
RecordWriter writer = null;
TableTunnel.UploadSession uploadSession = tunnel.createUploadSession(projectName, tableName);
try {
int i = 0;
// 產生TunnelBufferedWriter的執行個體。
writer = uploadSession.openBufferedWriter();
Record product = uploadSession.newRecord();
for (String item : items) {
product.setString("name", item);
product.setBigint("id", i);
// 調用write介面寫入資料。
writer.write(product);
i += 1;
}
} finally {
if (writer != null) {
// 關閉TunnelBufferedWriter
writer.close();
}
}
// uploadSession提交,結束上傳。
uploadSession.commit();
代碼解釋
items
:表示待上傳的資料,您可使用STRING類型的數組定義,例如:String[] arr={"s1","s2"}
。
name
:為表中待寫入資料的name
列,資料類型為STRING。您可根據表的實際列名和類型進行設定。
id
:為表中待寫入資料的id
列,資料類型為BIGINT。您可根據表的實際列名和類型進行設定。