本文將通過參數說明和範例程式碼為您介紹如何使用 Node.js SDK 建立資料表。在建立資料表時,您需要指定資料表的結構資訊和配置資訊。高效能型執行個體中的資料表還可以根據需要設定預留讀寫輸送量。
注意事項
建立資料表後需要幾秒鐘進行載入,在此期間對該資料表的讀寫資料操作均會失敗。請等待資料表載入完畢後再進行資料操作。
如果您有主鍵資料自增的需求,例如電商網站的商品 ID、論壇文章的 ID 等情境,可以在建立資料時配置主鍵列自增。具體操作,請參見主鍵列自增。
前提條件
已通過控制台建立執行個體。具體操作,請參見建立執行個體。
已初始化 OTSClient。具體操作,請參見初始化 OTSClient。
介面
/**
* 說明:根據指定表結構資訊建立資料表。
* 當建立一個資料表後,通常需要等待幾秒鐘時間使partition load完成,才能進行各種操作。
*/
createTable(params, callback)
參數說明
params
包含以下參數:
參數 | 說明 |
tableMeta(必選) | 資料表的結構資訊,包括如下內容:
|
tableOptions(必選) | 資料表的配置資訊,包括如下內容:
|
indexMetas(可選) | 索引列表。每個索引包含以下內容:
|
reservedThroughput(必選) | 預留讀寫輸送量,單位為 CU。預設值為 0。 重要 僅高效能型執行個體支援設定資料表的預留讀寫輸送量為非零值。 |
streamSpecification(可選) | 資料表的 Stream 配置資訊,包括如下內容:
|
樣本
建立資料表
以下樣本用於建立資料表。
var params = {
tableMeta: {
//設定資料表名稱。
tableName: '<TABLE_NAME>',
//設定資料表主鍵列。主鍵為pk1(String類型)和pk2(Integer類型),其中pk1主鍵列為分區鍵,pk2主鍵列為自增列。
primaryKey: [
{
name: 'pk1',
type: 'STRING'
},
{
name: 'pk2',
type: 'INTEGER',
option: 'AUTO_INCREMENT'
}
]
},
tableOptions: {
//資料的到期時間,-1表示永不到期。
timeToLive: -1,
//最大版本數,屬性列值最多保留1個版本,即儲存最新的版本。
maxVersions: 1,
//有效版本偏差,即寫入資料的時間戳記與系統目前時間的偏差允許最大值為86400秒(1天)。
maxTimeDeviation: 86400
},
//設定預留讀寫輸送量,容量型執行個體下的資料表只能設定為0,高效能型執行個體下的資料表可以設定為非零值。
reservedThroughput: {
capacityUnit: {
read: 0,
write: 0
}
}
};
client.createTable(params, function (err, data) {
if (err) {
console.log('error:', err);
return;
}
console.log('success:', data);
});
建立資料表時配置二級索引
建立資料表時配置全域二級索引
以下樣本用於同時建立資料表和全域二級索引。
var params = {
tableMeta: {
//設定資料表名稱。
tableName: '<TABLE_NAME>',
//設定資料表主鍵列。主鍵為pk1(String類型)和pk2(Integer類型)。
primaryKey: [
{
name: 'pk1',
type: 'STRING'
},
{
name: 'pk2',
type: 'INTEGER'
}
],
//設定資料表預定義列。預定義列為defcol1(String類型)和defcol2(Integer類型)。
definedColumn: [
{
name: 'defcol1',
type: TableStore.DefinedColumnType.DCT_STRING
},
{
name: 'defcol2',
type: TableStore.DefinedColumnType.DCT_INTEGER
}
],
},
tableOptions: {
//資料的到期時間,-1表示永不到期。
timeToLive: -1,
//最大版本數,屬性列值最多保留1個版本,即儲存最新的版本。
maxVersions: 1
},
//設定預留讀寫輸送量,容量型執行個體下的資料表只能設定為0,高效能型執行個體下的資料表可以設定為非零值。
reservedThroughput: {
capacityUnit: {
read: 0,
write: 0
}
},
indexMetas: [
//索引類型預設為全域二級索引
{
//設定索引名稱。
name: '<INDEX_NAME>',
//為索引添加主鍵。主鍵列為defcol1、pk1和pk2。
primaryKey: ['defcol1', 'pk1', 'pk2'],
//為索引添加預定義列。預定義列為defcol2。
definedColumn: ['defcol2']
}
]
};
client.createTable(params, function (err, data) {
if (err) {
console.log('error:', err);
return;
}
console.log('success:', data);
});
建立資料表時配置本地二級索引
以下樣本用於同時建立資料表和本地二級索引。
var params = {
tableMeta: {
//設定資料表名稱。
tableName: '<TABLE_NAME>',
//設定資料表主鍵列。主鍵為pk1(String類型)和pk2(Integer類型)。
primaryKey: [
{
name: 'pk1',
type: 'STRING'
},
{
name: 'pk2',
type: 'INTEGER'
}
],
//設定資料表預定義列。預定義列為defcol1(String類型)和defcol2(Integer類型)。
definedColumn: [
{
name: 'defcol1',
type: TableStore.DefinedColumnType.DCT_STRING
},
{
name: 'defcol2',
type: TableStore.DefinedColumnType.DCT_INTEGER
}
],
},
tableOptions: {
//資料的到期時間,-1表示永不到期。
timeToLive: -1,
//最大版本數,屬性列值最多保留1個版本,即儲存最新的版本。
maxVersions: 1,
},
//設定預留讀寫輸送量,容量型執行個體下的資料表只能設定為0,高效能型執行個體下的資料表可以設定為非零值。
reservedThroughput: {
capacityUnit: {
read: 0,
write: 0
}
},
indexMetas: [
//本地二級索引
{
//設定索引名稱。
name: '<INDEX_NAME>',
//為索引添加主鍵。主鍵列為pk1、defcol1和pk2。
primaryKey: ['pk1', 'defcol1', 'pk2'],
//為索引添加預定義列。預定義列為defcol2。
definedColumn: ['defcol2'],
//設定索引類型為本地二級索引(IT_LOCAL_INDEX)。
indexType: TableStore.IndexType.IT_LOCAL_INDEX,
//設定索引更新模式為同步更新(IUM_SYNC_INDEX)。當索引類型為本地二級索引時,索引更新模式必須為同步更新。
indexUpdateMode: TableStore.IndexUpdateMode.IUM_SYNC_INDEX
}
]
};
client.createTable(params, function (err, data) {
if (err) {
console.log('error:', err);
return;
}
console.log('success:', data);
});