TimesTen 应用层数据库缓存学习:18. 利用TimesTen实现Sharding或数据分区

本文主要是介绍TimesTen 应用层数据库缓存学习:18. 利用TimesTen实现Sharding或数据分区,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

考虑到恢复和磁盘加载到内存的速度,单个TimesTen数据库可以缓存的数据一般不超过100G,如果需要缓存的数据较大,一般可以利用多个TimesTen来实现数据分区或分片(Sharding)。
虽然TimesTen有Cache Grid即Global Cache Group的概念,但由于其还不太成熟,一般采用手工分区的方式,即通过应用服务器定向到指定的TimesTen的方式。

以下给出了只读和读写数据分区的例子。

另外强调一点,TimesTen没有Oracle Partition的概念。

TimesTen can cache Oracle Database partitioned tables at the table level, but individual partitions cannot be cached. The following describes how operations on partitioned tables affect cache groups:
DDL operations on a table that has partitions do not affect the cache group unless there is data loss. For example, if a partition with data is truncated, an AUTOREFRESH operation does not delete the data from the corresponding cached table.
WHERE clauses in any cache group operations cannot reference individual partitions or subpartitions. Any attempt to define a single partition of a table returns an error.

只读分区

利用只读分区可以指定where条件的便利,可以在不同的TimesTen中建立带where条件的cache group,来缓存Oracle数据库不同部分的数据。
以下的例子虽然Oracle中的表具有分区,但只是示例而已,即使没有分区结果也是一样的。

在Oracle中建表,分为东西南北四个区

create table datapart
( region varchar2(1),
id int,
city varchar2(20),
primary key(id)
)
partition by list(region)
( 
partition part_1 values ( 'N' ),
partition part_2 values ( 'S' ),
partition part_3 values ( 'W' ),
partition part_4 values ( 'E' )
);insert into datapart values ('N', 1, 'Beijing');
insert into datapart values ('S', 2, 'Guangzhou');
insert into datapart values ('E', 3, 'Shanghai');
insert into datapart values ('W', 4, 'Chengdu');SQL> select * from datapart partition(part_2);R         ID CITY
- ---------- --------------------
S          2 Guangzhougrant select, delete, update, insert on datapart to cacheadm;

分别在两个TimesTen数据库cachedb1和cachedb2中建立Cache Group,缓存北区和南区的数据

cachedb1>
CREATE READONLY CACHE GROUP "DATAPART1" AUTOREFRESH MODE INCREMENTAL INTERVAL 5 SECONDSSTATE ONFROM"TTHR"."DATAPART" ("REGION" VARCHAR2(1 BYTE) ,"ID"     NUMBER(38)        NOT NULL,"CITY"   VARCHAR2(20 BYTE),PRIMARY KEY("ID"))WHERE (REGION='N')cachedb1> select * from datapart;
< N, Beijing >cachedb2>
CREATE READONLY CACHE GROUP "DATAPART2" AUTOREFRESH MODE INCREMENTAL INTERVAL 5 SECONDSSTATE ONFROM"TTHR"."DATAPART" ("REGION" VARCHAR2(1 BYTE) ,"ID"     NUMBER(38)        NOT NULL,"CITY"   VARCHAR2(20 BYTE),PRIMARY KEY("ID"))WHERE (REGION='S')cachedb2> select * from datapart;
< S, Guangzhou >

在Oracle中插入数据

insert into datapart values ('N', 5, 'Qingdao');
insert into datapart values ('S', 6, 'Haikou');

然后在两个TimesTen中可自动得到新数据

cachedb1> select * from datapart;
< N, 1, Beijing >
< N, 5, Qingdao >cachedb2> select * from datapart;
< S, 2, Guangzhou >
< S, 6, Haikou >

可写分区

可写分区以AWT为例,和只读分区不一样,AWT在建立时不能指定where条件,但是可以在LOAD操作时指定where条件来进行数据分区

在cachedb1中建立Cache Group, LOAD时指定缓存北区的数据:

CREATE ASYNCHRONOUS WRITETHROUGH CACHE GROUP "AWT1" FROM"TTHR"."DATAPART" ("REGION" VARCHAR2(1 BYTE) ,"ID"     NUMBER(38)        NOT NULL,"CITY"   VARCHAR2(20 BYTE),PRIMARY KEY("ID"))cachedb1> call ttrepstart;cachedb1> load cache group awt1 where region = 'N' commit every 256 rows;
cachedb1> select * from datapart;
< N, 1, Beijing >
< N, 5, Qingdao >cachedb1> truncate table datapart;8238: Cannot truncate cache group table DATAPART; please use DROP/REFRESH/UNLOAD CACHE GROUP insteadinsert into datapart values ('N', 7, 'Tianjing');

在cachedb2中建立Cache Group, LOAD时指定缓存南区的数据:

CREATE ASYNCHRONOUS WRITETHROUGH CACHE GROUP "AWT2" FROM"TTHR"."DATAPART" ("REGION" VARCHAR2(1 BYTE) ,"ID"     NUMBER(38)        NOT NULL,"CITY"   VARCHAR2(20 BYTE),PRIMARY KEY("ID"))cachedb2> call ttrepstart;cachedb2> load cache group awt2 where region = 'S' commit every 256 rows;
cachedb2> select * from datapart;
< S, 2, Guangzhou >
< S, 6, Haikou >
cachedb2> insert into datapart values ('S', 8, 'Changsha');

在Oracle中可以看到由各个TimesTen新插入的数据

SQL> select * from datapart order by id; R         ID CITY
- ---------- --------------------
N          1 Beijing
S          2 Guangzhou
E          3 Shanghai
W          4 Chengdu
N          5 Qingdao
S          6 Haikou
N          7 Tianjing
S          8 Changsha8 rows selected.

在Oracle中插入数据,然后各个缓存组通过LOAD/REFRESH操作得到新数据。
注意,对于Explicitly load的缓存组,LOAD和REFRESH的作用是一样的。

SQL>
insert into datapart values ('N', 9, 'Baoding');
insert into datapart values ('S', 10, 'Wuhan');
commit;cachedb1> select * from datapart;
< N, 1, Beijing >
< N, 5, Qingdao >
< N, 7, Tianjing >cachedb1> refresh cache group awt1 where region = 'N' commit every 256 rows;
cachedb1> select * from datapart;
< N, 1, Beijing >
< N, 5, Qingdao >
< N, 7, Tianjing >
< N, 9, Baoding >cachedb2> select * from datapart;
< S, 2, Guangzhou >
< S, 6, Haikou >
< S, 8, Changsha >cachedb2> load cache group awt2 where region = 'S' commit every 256 rows;cachedb2> select * from datapart;
< S, 2, Guangzhou >
< S, 6, Haikou >
< S, 8, Changsha >
< S, 10, Wuhan >

参考

https://community.oracle.com/thread/3594994?start=0&tstart=0

这篇关于TimesTen 应用层数据库缓存学习:18. 利用TimesTen实现Sharding或数据分区的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/677690

相关文章

Spring Security自定义身份认证的实现方法

《SpringSecurity自定义身份认证的实现方法》:本文主要介绍SpringSecurity自定义身份认证的实现方法,下面对SpringSecurity的这三种自定义身份认证进行详细讲解,... 目录1.内存身份认证(1)创建配置类(2)验证内存身份认证2.JDBC身份认证(1)数据准备 (2)配置依

利用python实现对excel文件进行加密

《利用python实现对excel文件进行加密》由于文件内容的私密性,需要对Excel文件进行加密,保护文件以免给第三方看到,本文将以Python语言为例,和大家讲讲如何对Excel文件进行加密,感兴... 目录前言方法一:使用pywin32库(仅限Windows)方法二:使用msoffcrypto-too

C#使用StackExchange.Redis实现分布式锁的两种方式介绍

《C#使用StackExchange.Redis实现分布式锁的两种方式介绍》分布式锁在集群的架构中发挥着重要的作用,:本文主要介绍C#使用StackExchange.Redis实现分布式锁的... 目录自定义分布式锁获取锁释放锁自动续期StackExchange.Redis分布式锁获取锁释放锁自动续期分布式

springboot使用Scheduling实现动态增删启停定时任务教程

《springboot使用Scheduling实现动态增删启停定时任务教程》:本文主要介绍springboot使用Scheduling实现动态增删启停定时任务教程,具有很好的参考价值,希望对大家有... 目录1、配置定时任务需要的线程池2、创建ScheduledFuture的包装类3、注册定时任务,增加、删

SpringBoot整合mybatisPlus实现批量插入并获取ID详解

《SpringBoot整合mybatisPlus实现批量插入并获取ID详解》这篇文章主要为大家详细介绍了SpringBoot如何整合mybatisPlus实现批量插入并获取ID,文中的示例代码讲解详细... 目录【1】saveBATch(一万条数据总耗时:2478ms)【2】集合方式foreach(一万条数

使用Python实现矢量路径的压缩、解压与可视化

《使用Python实现矢量路径的压缩、解压与可视化》在图形设计和Web开发中,矢量路径数据的高效存储与传输至关重要,本文将通过一个Python示例,展示如何将复杂的矢量路径命令序列压缩为JSON格式,... 目录引言核心功能概述1. 路径命令解析2. 路径数据压缩3. 路径数据解压4. 可视化代码实现详解1

PyQt6/PySide6中QTableView类的实现

《PyQt6/PySide6中QTableView类的实现》本文主要介绍了PyQt6/PySide6中QTableView类的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学... 目录1. 基本概念2. 创建 QTableView 实例3. QTableView 的常用属性和方法

PyQt6/PySide6中QTreeView类的实现

《PyQt6/PySide6中QTreeView类的实现》QTreeView是PyQt6或PySide6库中用于显示分层数据的控件,本文主要介绍了PyQt6/PySide6中QTreeView类的实现... 目录1. 基本概念2. 创建 QTreeView 实例3. QTreeView 的常用属性和方法属性

Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

《Android使用ImageView.ScaleType实现图片的缩放与裁剪功能》ImageView是最常用的控件之一,它用于展示各种类型的图片,为了能够根据需求调整图片的显示效果,Android提... 目录什么是 ImageView.ScaleType?FIT_XYFIT_STARTFIT_CENTE

pandas中位数填充空值的实现示例

《pandas中位数填充空值的实现示例》中位数填充是一种简单而有效的方法,用于填充数据集中缺失的值,本文就来介绍一下pandas中位数填充空值的实现,具有一定的参考价值,感兴趣的可以了解一下... 目录什么是中位数填充?为什么选择中位数填充?示例数据结果分析完整代码总结在数据分析和机器学习过程中,处理缺失数