| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Name | Name | Last commit date | ||
|---|---|---|---|---|
表格存储(tablestore)
具体可以查看sdk中的demo目录
instance 的service需要继承TableStoreService
@Service
public class ActionTableStoreServiceImpl extends TableStoreService {
@Value("${aliyun.accessId}")
private String aliyunAccessId;
@Value("${aliyun.accessKey}")
private String aliyunAccessKey;
@Value("${aliyun.tablestore.action.endPoint}")
private String actionEndPoint;
@Value("${aliyun.tablestore.action.instanceName}")
private String actionInstanceName;
@PostConstruct
public void init() {
super.accessId = this.aliyunAccessId;
super.accessKey = this.aliyunAccessKey;
super.endPoint = this.actionEndPoint;
super.instanceName = this.actionInstanceName;
initClient();
}
/***
*
*
*
***/
}
定义调用方法:
@Service
public class UserActionServiceImpl implements UserActionService {
private static final Logger logger = LoggerFactory.getLogger(UserActionServiceImpl.class);
@Autowired
private ActionTableStoreServiceImpl actionTableStoreService;
@Autowired
private IdentityService identityService;
@Value("${aliyun.tablestore.action.tableName}")
private String actionTableName;
@Override
public void doRecord(UserAction userAction) {
//设置主键
long actionId = identityService.genRandomId();
userAction.setActionId(actionId);
logger.info("[doRecord] userAction = "+ JSONObject.toJSONString(userAction));
StoreTableRow row = actionTableStoreService.initTable(actionTableName,userAction);
if(row == null){
logger.error("[doRecord] row init error");
return;
}
actionTableStoreService.putRow(row);
}
}
使用的时候只用实例化UserAction,然后调用doRecord方法即可
| Back | FazBrowse Home | New Git URL |