import ohos.data.rdb.RdbStore;
import ohos.data.rdb.RdbOpenCallback;
import ohos.data.rdb.StoreConfig;
import ohos.data.resultset.ResultSet;
import ohos.data.values.ValuesBucket;

public class RdbStoreExample {
    public static void main(String[] args) {
        // 定义数据库名称和版本
        String dbName = "example.db";
        int dbVersion = 1;

        // 定义 RDB 数据库的配置
        StoreConfig config = StoreConfig.newDefaultConfig(dbName);

        // 创建或打开数据库
        RdbStore rdbStore = new RdbStore(config, dbVersion, new RdbOpenCallback() {
            @Override
            public void onCreate(RdbStore rdbStore) {
                // 在数据库第一次创建时执行的操作
                // 可以创建表和进行初始化
                rdbStore.executeSql("CREATE TABLE IF NOT EXISTS person (id INTEGER PRIMARY KEY, name TEXT);");
            }

            @Override
            public void onUpgrade(RdbStore rdbStore, int oldVersion, int newVersion) {
                // 在数据库版本升级时执行的操作
                // 可以根据需要进行表结构的变更
            }
        });

        // 插入数据
        ValuesBucket values = new ValuesBucket();
        values.putString("name", "John");
        rdbStore.insert("person", values);

        // 查询数据
        ResultSet resultSet = rdbStore.querySql("SELECT * FROM person;");
        while (resultSet.goToNextRow()) {
            int id = resultSet.getInt(resultSet.getColumnIndexForName("id"));
            String name = resultSet.getString(resultSet.getColumnIndexForName("name"));
            System.out.println("ID: " + id + ", Name: " + name);
        }

        // 关闭数据库连接
        rdbStore.close();
    }
}