关于分布式缓存:DawnSql解决SAAS的痛点

39次阅读

共计 7274 个字符，预计需要花费 19 分钟才能阅读完成。

家喻户晓，软件 = 程序 + 数据。

如果客户的数据须要上传到 SAAS 厂商的服务器，那么 SAAS 厂商只须要对相应的数据设置用户组，并对这个用户组设置相应的权限，就能够将该用户组的权限，发给客户，客户就能够依据本人的理论需要来批改、扩大相应的性能！
客户对本身数据安全的担心。客户只须要将本人的数据依据 SAAS 厂商提供的表格局部署到 DawnSql 中，同时设置好用户组权限，SAAS 厂商就能够应用这个用户组来拜访数据，用户间接应用 SAAS 厂商提供的服务即可。

所有的例子来自于，NorthWind 实例数据库。

<property name="consistentId" value="dawn_node"></property>

 <!-- 超级管理员的 root token, 用户能够间接来设置一个 root token -->
 <!-- 本例中 root token 为 dafu -->
<property name="root_token" value="dafu"/>

<!-- 设置实现 log 事务接口的类 -->
<!--
<property name="myLogCls" value="org.gridgain.smart.logClient.MyLogTransactionClient"/>
-->

<!-- 设置启动的时候，初始化 rpc 服务器 -->
<!-- org.dawn.rpc.MyRpcStartImpl 是实现了 IDawnSqlStart 接口的类 -->
<!-- 不设置则不启动这个服务，具体代码能够参看开源的例子 -->
<!--
<property name="startAppCls" value="org.dawn.rpc.MyRpcStartImpl"/>
-->

例子中设置了两个模板：
base 模板：复制模式，反对事务
manage 模板：分区模式，同一份数据，在集群中备份 3 次，反对事务

<!-- 创立表的模板 -->
<property name="templateConfiguration">
    <map key-type="java.lang.String" value-type="org.apache.ignite.configuration.TableTemplateConfiguration">
        <entry key="base">
            <bean class="org.apache.ignite.configuration.TableTemplateConfiguration">
                <property name="templateValue" value="template=REPLICATED,ATOMICITY=TRANSACTIONAL"></property>
                <property name="description" value="复制模式，来保留数据！"></property>
            </bean>
        </entry>
        <entry key="manage">
            <bean class="org.apache.ignite.configuration.TableTemplateConfiguration">
                <property name="templateValue" value="template=partitioned,backups=3,ATOMICITY=TRANSACTIONAL"></property>
                <property name="description" value="分片模式，来保留数据！"></property>
            </bean>
        </entry>
    </map>
</property>

-- 1、产品类型表
CREATE TABLE IF NOT EXISTS public.Categories (
     -- 产品类型 ID
    CategoryID INTEGER NOT NULL auto,
    -- 产品类型名
    CategoryName VARCHAR(15) NOT NULL,
    -- 类型阐明
    Description VARCHAR,
    -- 产品样本
    Picture VARCHAR,
    PRIMARY KEY (CategoryID)
) WITH "template=manage";

-- 2、顾客信息表
CREATE TABLE IF NOT EXISTS public.Customers (
    -- 客户 ID
    CustomerID VARCHAR(5) NOT NULL,
    -- 所在公司名称
    CompanyName VARCHAR(40) NOT NULL,
    -- 客户姓名
    ContactName VARCHAR(30),
    -- 客户头衔
    ContactTitle VARCHAR(30),
    -- 联系地址
    Address VARCHAR(60),
    -- 所在城市
    City VARCHAR(15),
    -- 所在地区
    Region VARCHAR(15),
    -- 邮编
    PostalCode VARCHAR(10),
    -- 国家
    Country VARCHAR(15),
    -- 电话
    Phone VARCHAR(24),
    -- 传真
    Fax VARCHAR(24),
    PRIMARY KEY (CustomerID)
) WITH "template=manage";

-- 3、产品类别表
CREATE TABLE IF NOT EXISTS public.Products (
    -- 产品 ID
    ProductID INTEGER NOT NULL,
    -- 产品名称
    ProductName VARCHAR(40) NOT NULL,
    -- 供应商 ID
    SupplierID INTEGER,
    -- 类型 ID
    CategoryID INTEGER,
    -- 数量
    QuantityPerUnit VARCHAR(20),
    -- 单价
    UnitPrice DECIMAL(10,4) DEFAULT 0,
    -- 库存数量
    UnitsInStock SMALLINT(2) DEFAULT 0,
    -- 订购量
    UnitsOnOrder SMALLINT(2) DEFAULT 0,
    -- 再次订购量
    ReorderLevel SMALLINT(2) DEFAULT 0,
    -- 停止
    Discontinued BIT NOT NULL DEFAULT 0,
    PRIMARY KEY (ProductID)
) WITH "template=manage";

-- 4、运货商
CREATE TABLE IF NOT EXISTS Shippers (
    -- 运货商 ID
    ShipperID INTEGER NOT NULL auto,
    -- 公司名称
    CompanyName VARCHAR(40) NOT NULL,
    -- 联系电话
    Phone VARCHAR(24),
    PRIMARY KEY (ShipperID)
) WITH "template=manage";

-- 5、供应商表 
CREATE TABLE IF NOT EXISTS Suppliers (
    -- 地区形容
    SupplierID INTEGER NOT NULL,
    -- 供应商姓名
    CompanyName VARCHAR(40) NOT NULL,
    -- 联系人
    ContactName VARCHAR(30),
    -- 联系人职务
    ContactTitle VARCHAR(30),
    -- 地址
    Address VARCHAR(60),
    -- 城市
    City VARCHAR(15),
    -- 销售大区域
    Region VARCHAR(15),
    -- 邮政编码
    PostalCode VARCHAR(10),
    -- 国家
    Country VARCHAR(15),
    -- 联系电话
    Phone VARCHAR(24),
    -- 传真
    Fax VARCHAR(24),
    -- 首页
    HomePage VARCHAR,
    PRIMARY KEY (SupplierID)
) WITH "template=manage";

-- 6、雇员表，寄存员工的一些根本信息
CREATE TABLE IF NOT EXISTS Employees (
    -- 员工编号
    EmployeeID INTEGER NOT NULL,
    -- 员工姓
    LastName VARCHAR(20) NOT NULL,
    -- 员工名
    FirstName VARCHAR(10) NOT NULL,
    -- 头衔
    Title VARCHAR(30),
    -- 尊称
    TitleOfCourtesy VARCHAR(25),
    -- 出生日期
    BirthDate DATETIME,
    -- 雇用日期
    HireDate DATETIME,
    -- 家庭地址
    Address VARCHAR(60),
    -- 所在城市
    City VARCHAR(15),
    -- 所在地区
    Region VARCHAR(15),
    -- 邮编
    PostalCode VARCHAR(10),
    -- 国家
    Country VARCHAR(15),
    -- 住宅电话
    HomePhone VARCHAR(24),
    -- 分机
    Extension VARCHAR(4),
    -- 照片
    Photo VARCHAR,
    -- 备注
    Notes VARCHAR NOT NULL,
    -- 下级
    ReportsTo VARCHAR,
    -- 照片门路
    PhotoPath VARCHAR(255),
    -- 工资
    Salary FLOAT,
    PRIMARY KEY (EmployeeID)
) WITH "template=manage";

-- 7、雇员销售区域表
CREATE TABLE EmployeeTerritories (
    -- ID 
    ID INTEGER NOT NULL auto,
    -- 员工编号
    EmployeeID INTEGER NOT NULL,
    -- 区域代号
    TerritoryID VARCHAR(20) NOT NULL,
    PRIMARY KEY (ID)
) WITH "template=manage";

-- 8、销售小区域表
CREATE TABLE Territories (
    -- 地区编号
    TerritoryID VARCHAR(20) NOT NULL,
    -- 地区形容
    TerritoryDescription VARCHAR(50) NOT NULL,
    -- 地区编号
    RegionID INTEGER NOT NULL,
    PRIMARY KEY (TerritoryID)
) WITH "template=manage";

-- 9、订单详情表
CREATE TABLE OrderDetails (
    -- 订单编号
    OrderID INTEGER NOT NULL,
    -- 产品编号
    ProductID INTEGER NOT NULL,
    -- 单价
    UnitPrice DECIMAL(10,4) DEFAULT 0,
    -- 订购数量
    Quantity SMALLINT(2) DEFAULT 1,
    -- 折扣
    Discount REAL(8,0) NOT NULL,
    PRIMARY KEY (OrderID, ProductID)
) WITH "template=manage,affinity_key=ProductID";

-- 10、订单表
CREATE TABLE IF NOT EXISTS Orders (
    -- 订单编号
    OrderID INTEGER NOT NULL,
    -- 客户编号
    CustomerID VARCHAR(5),
    -- 员工编号
    EmployeeID INTEGER,
    -- 订购日期
    OrderDate DATETIME,
    -- 预计达到日期
    RequiredDate DATETIME,
    -- 发货日期
    ShippedDate DATETIME,
    -- 运货商
    ShipVia INTEGER,
    -- 运费
    Freight DECIMAL(10,4) DEFAULT 0,
    -- 货主姓名
    ShipName VARCHAR(40),
    -- 货主地址
    ShipAddress VARCHAR(60),
    -- 货主所在城市
    ShipCity VARCHAR(15),
    -- 货主所在地区
    ShipRegion VARCHAR(15),
    -- 货主邮编
    ShipPostalCode VARCHAR(10),
    -- 货主所在国家
    ShipCountry VARCHAR(15),
    PRIMARY KEY (OrderID)
) WITH "template=manage";

在 DawnSql 中导入数据有两种形式。

通过 JDBC 来 insert 来导入数据。
例如：
因为要插入的数据比拟多，所以这里只做实例，具体的数据，咱们放在文档前面的下载链接中。

INSERT INTO Categories (CategoryName, Description, Picture) VALUES('Beverages','Soft drinks, coffees, teas, beers, and ales', '');
INSERT INTO Categories (CategoryName, Description, Picture) VALUES('Condiments','Sweet and savory sauces, relishes, spreads, and seasonings', '');

用 JDBC 导入

        Class.forName("org.apache.ignite.IgniteJdbcDriver");
        String url = "jdbc:ignite:thin://127.0.0.1:10800/public?lazy=true&distributedJoins=true&userToken=dafu";
        Connection conn = DriverManager.getConnection(url);
        Statement stmt = conn.createStatement();
        stmt.executeUpdate("SET STREAMING ON; INSERT INTO public.Categories (CategoryName, Description, Picture) VALUES('Seafood',' 草鱼 ',''), ('"+ CategoryName +"', '"+ Description +"', '"+ Picture +"')");

        stmt.close();
        conn.close();

通过 JDBC 批量导入数据。

-- 批量导入
SET STREAMING ON;
INSERT INTO public.Categories (CategoryName, Description, Picture) VALUES('Seafood','草鱼', ''), (' 吴大富 ',' 金毛 ','');

-- 或者
SET STREAMING ON;
INSERT INTO public.Categories (CategoryName, Description, Picture) VALUES ('Seafood','草鱼', '');
INSERT INTO public.Categories (CategoryName, Description, Picture) VALUES ('吴大富','金毛', '');

疾速批量导入。这种办法能够绕开 SQL 解析，间接将数据存入集群。然而这种办法须要对 Dawn Sql 比拟理解且具备肯定的编程能力。如果想理解这种办法请分割作者。

-- 增加 schema 名字为 myy
create schema myy;
-- 或者
create SCHEMA IF NOT EXISTS myy;

-- 增加用户组
add_user_group('myy_group', 'myy_token', 'all', 'myy');
-- 通过 user_token 获取用户组
get_user_group('myy_token');

为 myy_group 设置用户权限。
1、

-- 对用户组 myy_group 设置拜访  public.Employees 表的权限，让它只能查问
-- EMPLOYEEID < 6 的数据
my_view('myy_group', "SELECT * from public.Employees where EMPLOYEEID < 6");

-- 统计只出过一单的员工数量
function get_emp_count()
{let rs = query_sql("SELECT COUNT(DISTINCT o.EmployeeID)
                        FROM public.Orders o
                        LEFT JOIN public.Employees e  ON o.EmployeeID=e.EmployeeID");
    rs.next().FIRST();
}

-- 查问只卖过一件商品
SELECT p.ProductName,COUNT(DISTINCT wo.EmployeeID)
                FROM public.Orders wo
                JOIN public.Employees e  ON wo.EmployeeID=e.EmployeeID
                JOIN public.OrderDetails od ON wo.OrderID=od.OrderID
                JOIN public.Products p ON od.ProductID=p.ProductID
                GROUP BY p.ProductName
                HAVING COUNT(DISTINCT wo.EmployeeID) = get_emp_count();

例如：在保险中，代理人的组织构造是金字塔型的，佣金项几十个，不同的产品有不同的佣金比例，代理人级别不同也有所不同。能够将代理人的 em_no 作为主键，将代理的上下级、保单、佣金项作为数据，造成一个树形构造。当保单扭转，或者上下级变动时候，动静批改该树。当须要计算佣金的时候，只须要扫描这棵树的佣金项即可。

具体用法：NoSql 的反对

具体方法：自定义扩大办法

DawnSql 文档

正文完

分布式缓存

发表至：分布式缓存

2023-02-25

0

关于分布式缓存:DawnSql解决SAAS的痛点

关于后端:文化你所在的团队有多少人敢讲真话

关于分布式缓存:DawnSql解决SAAS的痛点

SAAS 零碎的痛点

1、大客户定制化水平高

2、客户对本身数据安全的担心，如何避免数据的泄露也滥用

DawnSql 的解决方案

DawnSql 例子

1、设置配置文件

1.1、设置 consistentId，如果是集群的话，每个节点的 consistentId 应该是不一样，这个属性能够不设置。(不过咱们倡议设置)

1.2、设置超级管理员的 root token

1.3、用户是否实现了 log 事务接口。默认是没有实现，这个须要用户依据本人的理论需要来实现。

1.4、是否实现了初始化后就执行的办法，默认是没有实现

1.5、创立表的模板 (这个是必须要设置的)

2、创立表

3、导入数据

4、增加 schema

5、增加用户组

6、为用户组设置权限

7、增加办法

8、用 NoSql 来形容业务流程或晋升程序性能

8.1、在 to B 的零碎中业务的流程和规定往往特地的简单，业务变动大，时效性要求高

8.2、在须要对海量数据高并发读写的场景下

9、DawnSql 的 root 用户能够本人扩大办法

Just My Socks（注册教程内含优惠码）

关于分布式缓存:DawnSql解决SAAS的痛点

SAAS 零碎的痛点

1、大客户定制化水平高

2、客户对本身数据安全的担心，如何避免数据的泄露也滥用

DawnSql 的解决方案

DawnSql 例子

1、设置配置文件

1.1、设置 consistentId，如果是集群的话，每个节点的 consistentId 应该是不一样，这个属性能够不设置。(不过咱们倡议设置)

1.2、设置超级管理员的 root token

1.3、用户是否实现了 log 事务接口。默认是没有实现，这个须要用户依据本人的理论需要来实现。

1.4、是否实现了初始化后就执行的办法，默认是没有实现

1.5、创立表的模板 (这个是必须要设置的)

2、创立表

3、导入数据

4、增加 schema

5、增加用户组

6、为用户组设置权限

7、增加办法

8、用 NoSql 来形容业务流程或晋升程序性能

8.1、在 to B 的零碎中业务的流程和规定往往特地的简单，业务变动大，时效性要求高

8.2、在须要对海量数据高并发读写的场景下

9、DawnSql 的 root 用户能够本人扩大办法

Just My Socks（注册教程 内含优惠码）

Just My Socks（注册教程内含优惠码）