如何从持久化存储中读取数据
发布网友
发布时间：2022-04-20 07:36
共4个回答
热心网友
时间：2022-04-09 07:33
1.属性列表
2.对象归档
3.数据库存储（SQLite3）
4.苹果公司提供的持久性工具Core Data。
其实储存的形式无非就这么几种，而我们还必须要关心的是，这些文件会被放置在那个文件下，然后如何读取。
也就是说：IOS上数据存储，我们要了解的两点，数据存储格式（也就是存储机制），数据存储位置。
1》文件如何存储（如上面4点）
2》文件存储在哪里。
对于数据的操作，其实我们关心的是操作的速率。
就好比在Adnroid中偏好存储，数据库存储，io存储一样。
热心网友
时间：2022-04-09 08:51
热心网友
时间：2022-04-09 10:26
首先，这是我数据库中PERSON的数据：
2.模型
这是一个Person.java类对应数据库中PERSON表的例子。
public class Person {
private long id;
private long orgId;
private String name;
private int salary;
// Constructor
…
// Getter and Setter methods
…
}
3.Maven Dependency
我已在我的项目 pom.xml 中指定了以下依赖项 ：
<dependency>
<groupid>org.apache.ignite</groupid>
<artifactid>ignite-core</artifactid>
<version>1.5.0.final</version>
</dependency>
<dependency>
<groupid>org.apache.ignite</groupid>
<artifactid>ignite-spring</artifactid>
<version>1.5.0.final</version>
</dependency>
<dependency>
<groupid>mysql</groupid>
<artifactid>mysql-connector-java</artifactid>
<version>5.1.6</version>
</dependency>
4.Read-Through配置
从数据库中加载数据，你需要启用 read-through 模式和设置CacheConfiguration的cacheStoreFactory属性。你可以在pring XML配置文件或程序中设置这些值。
<bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="dataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql://localhost:3306/mydbname"></property>
<property name="username" value="username"></property>
<property name="password" value="passwd"></property>
</bean>
<bean class="org.apache.ignite.configuration.IgniteConfiguration" id="ignite.cfg">
<property name="cacheConfiguration">
<list>
<bean class="org.apache.ignite.configuration.CacheConfiguration">
<property name="name" value="personCache"></property>
<!-- Enable readThrough-->
<property name="readThrough" value="true"></property>
<property name="writeThrough" value="true"></property>
<!-- Set cacheStoreFactory-->
<property name="cacheStoreFactory">
<bean class="javax.cache.configuration.FactoryBuilder" factory-method="factoryOf">
<constructor-arg value="myexamples.store.PersonStore"></constructor-arg>
</bean>
</property>
<property name="queryEntities">
<list>
<bean class="org.apache.ignite.cache.QueryEntity">
<property name="keyType" value="java.lang.Long"></property>
<property name="valueType" value="ignite.myexamples.model.Person"></property>
<property name="fields">
<map>
<entry key="id" value="java.lang.Long"></entry>
<entry key="name" value="java.lang.String"></entry>
<entry key="orgId" value="java.lang.Long"></entry>
<entry key="salary" value="java.lang.Integer"></entry>
</map>
</property>
</bean>
</list>
</property>
</bean>
</list>
</property>
<property name="peerClassLoadingEnabled" value="true"></property>
<!-- Other Ignite configurations-->
...
</bean>
5.实现CacheStore
现在我们有我们的模型，Maven依赖关系和缓存已配置到位，那么，现在是时候来实现存储。若从数据库加载数据，应实现CacheStore接口的 loadCache（）和 load（）的方法。
public class PersonStore implements CacheStore<Long, Person> {
@SpringResource(resourceName = "dataSource")
private DataSource dataSource;
// This method is called whenever IgniteCache.loadCache() method is called.
@Override
public void loadCache(IgniteBiInClosure<Long, Person> clo, @Nullable Object... objects) throws CacheLoaderException {
System.out.println(">> Loading cache from store...");
try (Connection conn = dataSource.getConnection()) {
try (PreparedStatement st = conn.prepareStatement("select * from PERSON")) {
try (ResultSet rs = st.executeQuery()) {
while (rs.next()) {
Person person = new Person(rs.getLong(1), rs.getLong(2), rs.getString(3), rs.getInt(4));
clo.apply(person.getId(), person);
}
}
}
}
catch (SQLException e) {
throw new CacheLoaderException("Failed to load values from cache store.", e);
}
}
// This method is called whenever IgniteCache.get() method is called.
@Override
public Person load(Long key) throws CacheLoaderException {
System.out.println(">> Loading person from store...");
try (Connection conn = dataSource.getConnection()) {
try (PreparedStatement st = conn.prepareStatement("select * from PERSON where id = ?")) {
st.setString(1, key.toString());
ResultSet rs = st.executeQuery();
return rs.next() ? new Person(rs.getLong(1), rs.getLong(2), rs.getString(3), rs.getInt(4)) : null;
}
}
catch (SQLException e) {
throw new CacheLoaderException("Failed to load values from cache store.", e);
}
}
// Other CacheStore method implementations.
…
}
为了方便起见，Ignite还为用户提供了一些具有默认实现CacheStore方法的CacheStoreAdapter类—— loadAll（）、writeAll（）和deleteAll（）。
6.加载缓存
这是一个PersonStoreExample.java类调用IgniteCache.loadCache()方法，在内部将调用CacheStore.loadCache（）方法的示例（在上一步中我们实现了）。
public class PersonStoreExample {
public static void main(String[] args) throws IgniteException {
Ignition.setClientMode(true);
try (Ignite ignite = Ignition.start("config/cluster-config.xml")) {
try (IgniteCache<Long, Person> cache = ignite.getOrCreateCache("personCache")) {
// Load cache with data from the database.
cache.loadCache(null);
// Execute query on cache.
QueryCursor<List<?>> cursor = cache.query(new SqlFieldsQuery(
"select id, name from Person"));
System.out.println(cursor.getAll());
}
}
}
}
7.开始Ignite集群
从命令shell中，使用下面的命令，自己安装Ignite文件夹并启动服务器节点：
$ bin/ignite.sh <path-to-Spring-XML-configuration-file>
确保personstore.java是在类路径中Ignite。这样做，你可以设置USER_LIBS环境变量，或将项目jar放入Ignite安装的libs文件夹中。
8.输出
从你的IDE，运行PersonStoreExample.java。
热心网友
时间：2022-04-09 12:17
在许多情况下，从服务端更新 my.cnf 并不是一个方便的选择，并且使变量仅被更新才能在后续重新启动时动态还原，而没有任何历史记录。
持久化系统变量是 MySQL 8 中引入的功能之一。新功能可帮助 DBA 动态更新变量并注册它们，而无需从服务器端访问配置文件。
如何持久化全局系统变量？
与 SET GLOBAL 一样，SET PERSIST 是可用于在运行时更新系统变量并使它们在重新启动后保持不变的命令。当我们使用 PERSIST 关键字时，变量更改将更新到数据目录中的 mysqld-auto.cnf 选项文件。mysqld-auto.cnf 是仅在第一次执行 PERSIST 或 PERSIST_ONLY 语句时创建的 JSON 格式文件。
声明：本网页内容为用户发布，旨在传播知识，不代表本网认同其观点，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。
E-MAIL:11247931@qq.com
E-MAIL:11247931@qq.com