设置非分区键的主键列为自增列后,在写入数据时,无需为自增列设置具体值,表格存储会自动生成自增列的值。该值在分区键级别唯一且严格递增。
说明 从Java SDK 4.2.0版本开始支持主键列自增功能。
前提条件
已初始化Client。具体操作,请参见初始化。
使用方法
- 创建表时,将非分区键的主键列设置为自增列。
只有整型的主键列才能设置为自增列,系统自动生成的自增列值为64位的有符号长整型。
- 写入数据时,无需为自增列设置具体值,只需将自增列的值设置为占位符。
如果需要获取写入数据后系统自动生成的自增列的值,将ReturnType设置为RT_PK,可以在数据写入成功后返回自增列的值。
查询数据时,需要完整的主键值。通过设置PutRow、UpdateRow或者BatchWriteRow中的ReturnType为RT_PK可以获取完整的主键值。
说明 如果要更新已存在的行,请先通过GetRange接口获取要更新的行主键信息,然后再进行数据更新。
示例
主键自增列功能主要涉及创建表(CreateTable)和写数据(PutRow、UpdateRow和BatchWriteRow)两类接口。
- 创建表
创建表时,只需将自增的主键属性设置为AUTO_INCREMENT。
private static void createTable(SyncClient client) { TableMeta tableMeta = new TableMeta("table_name"); //第一列为分区键。 tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("PK_1", PrimaryKeyType.STRING)); //第二列为自增列,类型为INTEGER,属性为AUTO_INCREMENT。 tableMeta.addPrimaryKeyColumn(new PrimaryKeySchema("PK_2", PrimaryKeyType.INTEGER, PrimaryKeyOption.AUTO_INCREMENT)); int timeToLive = -1; //数据永不过期。 int maxVersions = 1; //只保存一个数据版本。 TableOptions tableOptions = new TableOptions(timeToLive, maxVersions); CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions); client.createTable(request); }
- 写数据
写入数据时,无需为自增列设置具体值,只需将自增列的值设置为占位符AUTO_INCREMENT。
private static void putRow(SyncClient client, String receive_id) { //构造主键。 PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder(); //第一列的值为md5(receive_id)前4位。 primaryKeyBuilder.addPrimaryKeyColumn("PK_1", PrimaryKeyValue.fromString("Hangzhou")); //第二列是主键自增列,此处无需填入具体值,只需要一个占位符AUTO_INCREMENT,表格存储会自动生成此值。 primaryKeyBuilder.addPrimaryKeyColumn("PK_2", PrimaryKeyValue.AUTO_INCREMENT); PrimaryKey primaryKey = primaryKeyBuilder.build(); RowPutChange rowPutChange = new RowPutChange("table_name", primaryKey); //此处设置返回类型为RT_PK,即在返回结果中包含PK列的值。如果不设置ReturnType,默认不返回。 rowPutChange.setReturnType(ReturnType.RT_PK); //加入属性列。 rowPutChange.addColumn(new Column("content", ColumnValue.fromString("content"))); //写入数据到表格存储。 PutRowResponse response = client.putRow(new PutRowRequest(rowPutChange)); //打印返回的PK列。 Row returnRow = response.getRow(); if (returnRow != null) { System.out.println("PrimaryKey:" + returnRow.getPrimaryKey().toString()); } //打印消耗的CU。 CapacityUnit cu = response.getConsumedCapacity().getCapacityUnit(); System.out.println("Read CapacityUnit:" + cu.getReadCapacityUnit()); System.out.println("Write CapacityUnit:" + cu.getWriteCapacityUnit()); }