package com.example.entity;

import cn.com.digitalhainan.common.table.store.annotation.Table;
import cn.com.digitalhainan.common.table.store.annotation.Primary;
import cn.com.digitalhainan.common.table.store.annotation.Attribute;
import cn.com.digitalhainan.common.table.store.annotation.Ignore;

/**
 * 表格存储实体示例
 *
 * @Table: 指定对应的表格存储表名
 * @Primary: 标记字段为表主键（value 为 OTS 中的主键列名）
 * @Attribute: 标记字段为属性列（value 为 OTS 中的属性列名）
 * @Ignore: 标记字段不映射到 OTS
 */
@Table("user_profile")
public class UserProfile {

    @Primary("user_id")
    private String userId;

    @Primary("create_time")
    private Long createTime;

    @Attribute("user_name")
    private String userName;

    @Attribute("email")
    private String email;

    @Attribute("age")
    private Integer age;

    @Ignore
    private String tempField;  // 不会映射到表格存储
}

package com.example.service;

import cn.com.digitalhainan.common.table.store.mapper.TableStoreMapper;
import com.alicloud.openservices.tablestore.model.Direction;
import com.example.entity.UserProfile;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * TableStoreMapper 使用示例
 * 支持：insert / delete / select / selectList / selectPage
 */
@Service
public class UserProfileService {

    private final TableStoreMapper<UserProfile> mapper;

    public UserProfileService(TableStoreMapper<UserProfile> mapper) {
        this.mapper = mapper;
    }

    public void save(UserProfile profile) {
        mapper.insert(profile);
    }

    public void remove(UserProfile profile) {
        mapper.delete(profile);
    }

    public UserProfile findById(UserProfile query) {
        return mapper.select(query);
    }

    public List<UserProfile> findRange(UserProfile start, UserProfile end) {
        return mapper.selectList(start, end, Direction.FORWARD);
    }

    public List<UserProfile> findPage(UserProfile start, UserProfile end, int pageNo, int pageSize) {
        return mapper.selectPage(start, end, pageNo, pageSize, Direction.FORWARD);
    }
}