4.1.8 函数之事务管理

史, 昂 • 2024年5月23日 am8:56 • Oinone 7天入门到精通 • 阅读 994

一、事务管理介绍

函数Function支持事务字段为isTransaction（默认为false），事务传播行为propagationBehavior（默认PROPAGATION_SUPPORTS），事务隔离级别isolationLevel（默认使用数据库默认的事务隔离级别），所以不会默认为函数添加事务。另外事务配置提供全局配置。

平台事务管理兼容Spring声明式与编程式事务，支持多数据源事务管理。事务管理中多数据源嵌套独立事务，不会造成死锁风险。使用多数据源或分表操作，不会导致脏读。如果需要多数据源分布式事务，请使用PamirsTransational分布式事务管理方案（@PamirsTransational(enableXa=true)）。分布式事务一般用于量小的跨模块配置管理场景

使用方式

声明式事务，使用@PamirsTransactional注解在需要事务管理的类或方法上标注。在非无代码场景下，与@Transactional注解功能一致。
编程式事务，使用PamirsTransactionTemplate即可。在非无代码场景下，与TransactionTemplate功能一致。
配置式事务，使用TxConfig模型在模块安装时初始化存储事务配置数据。

事务特性

原子性（atomicity）:强调事务的不可分割.
一致性（consistency）:事务的执行的前后数据的完整性保持一致.
隔离性（isolation）:一个事务执行的过程中,不应该受到其他事务的干扰
持久性（durability） :事务一旦结束,数据就持久到数据库

事务隔离级别

事务隔离级别指的是一个事务对数据的修改与另一个并行的事务的隔离程度，当多个事务同时访问相同数据时，如果没有采取必要的隔离机制，就可能发生以下问题：

问题	描述
脏读	一个事务读到另一个事务未提交的更新数据，所谓脏读，就是指事务A读到了事务B还没有提交的数据，比如银行取钱，事务A开启事务，此时切换到事务B，事务B开启事务–>取走100元，此时切换回事务A，事务A读取的肯定是数据库里面的原始数据，因为事务B取走了100块钱，并没有提交，数据库里面的账务余额肯定还是原始余额，这就是脏读
不可重复读	在一个事务里面的操作中发现了未被操作的数据比方说在同一个事务中先后执行两条一模一样的select语句，期间在此次事务中没有执行过任何DDL语句，但先后得到的结果不一致，这就是不可重复读
幻读	是指当事务不是独立执行时发生的一种现象，例如第一个事务对一个表中的数据进行了修改，这种修改涉及到表中的全部数据行。同时，第二个事务也修改这个表中的数据，这种修改是向表中插入一行新数据。那么，以后就会发生操作第一个事务的用户发现表中还有没有修改的数据行，就好象发生了幻觉一样。

表4-1-8-1 事务隔离级别

Pamirs（Spring）支持的隔离级别

隔离级别	描述
DEFAULT	使用数据库本身使用的隔离级别 ORACLE（读已提交） MySQL（可重复读）
READ_UNCOMITTED	读未提交（脏读）最低的隔离级别，一切皆有可能。
READ_COMMITED	读已提交，ORACLE默认隔离级别，有不可重复读以及幻读风险。
REPEATABLE_READ	可重复读，解决不可重复读的隔离级别，但还是有幻读风险。
SERLALIZABLE	串行化，最高的事务隔离级别，不管多少事务，挨个运行完一个事务的所有子事务之后才可以执行另外一个事务里面的所有子事务，这样就解决了脏读、不可重复读和幻读的问题了

表4-1-8-2 隔离级别与描述

隔离级别	脏读可能性	不可重复读可能性	幻读可能性	加锁度
READ_UNCOMITTED	是	是	是	否
READ_COMMITED	否	是	是	否
REPEATABLE_READ	否	否	是	否
SERLALIZABLE	否	否	否	是

表4-1-8-3 隔离级别说明表

事务的传播行为

保证同一个事务中
PROPAGATION_REQUIRED 支持当前事务，如果不存在就新建一个(默认)
PROPAGATION_SUPPORTS 支持当前事务，如果不存在，就不使用事务
PROPAGATION_MANDATORY 支持当前事务，如果不存在，抛出异常
保证没有在同一个事务中
PROPAGATION_REQUIRES_NEW 如果有事务存在，挂起当前事务，创建一个新的事务
PROPAGATION_NOT_SUPPORTED 以非事务方式运行，如果有事务存在，挂起当前事务
PROPAGATION_NEVER 以非事务方式运行，如果有事务存在，抛出异常
PROPAGATION_NESTED 如果当前事务存在，则嵌套事务执行

A中嵌套B事务，嵌套PROPAGATION_REQUIRES_NEW方法勿与A在同类中。

异常状态	PROPAGATION_REQUIRES_NEW （两个独立事务）	PROPAGATION_NESTED (B的事务嵌套在A的事务中)	PROPAGATION_REQUIRED (同一个事务)
A抛异常 B正常	A回滚，B正常提交	A与B一起回滚	A与B一起回滚
A正常 B抛异常	1.如果A中捕获B的异常，并没有继续向上抛异常，则B先回滚，A再正常提交； 2.如果A未捕获B的异常，默认则会将B的异常向上抛，则B先回滚，A再回滚	B先回滚，A再正常提交	A与B一起回滚
A抛异常B抛异常	B先回滚，A再回滚	A与B一起回滚	A与B一起回滚
A正常 B正常	B先提交，A再提交	A与B一起提交	A与B一起提交

表4-1-8-4 事务传播行为

二、声明式事务（举例）

Step1 修改PetShopBatchUpdateAction

用@PamirsTransactional或者@Transactional注解来声明事务，PamirsTransactional跟Spring的Transactional区别在于PamirsTransactional支持多库事务，但此多库事务为非严格的分布式多库事务，之所以选择这个方案，原因如下

a. 不损害任何性能。

b. 事务保障率超过4个9

c. 经过阿里的大厂验证，特别是在阿里的结算平台中得到了很好的验证

@PamirsTransactional更多配置项请详见4.1.7【函数之元数据详解】一文，自己多试试。同时@PamirsTransactional百分百兼容@Transactional

@Action(displayName = "确定",bindingType = ViewTypeEnum.FORM,contextType = ActionContextTypeEnum.SINGLE)
@PamirsTransactional
//@Transactional
public PetShopBatchUpdate conform(PetShopBatchUpdate data){
    if(data.getPetShopList() == null || data.getPetShopList().size()==0){
        throw  PamirsException.construct(DemoExpEnumerate.PET_SHOP_BATCH_UPDATE_SHOPLIST_IS_NULL).errThrow();
    }
    List<PetShopProxy> proxyList = data.getPetShopList();
    for(PetShopProxy petShopProxy:proxyList){
        petShopProxy.setDataStatus(data.getDataStatus());
    }
    new PetShopProxy().updateBatch(proxyList);
    throw PamirsException.construct(DemoExpEnumerate.SYSTEM_ERROR).errThrow();
    //        return data;
}

图4-1-8-1 修改PetShopBatchUpdateAction

Step2 重启看效果

进入店铺管理列表页，选择记录点击【批量更新数据状态】按钮，修改记录的数据状态为【未启用】，提交看效果。期望效果为：提示系统异常，数据修改失败

图4-1-8-2 数据状态显示已启用

图4-1-8-3 批量更新数据状态

图4-1-8-4 提示系统异常

三、编程式事务（举例）

为了提升性能，特别是在高并发场景，编程式事务开发模式有利于精细化控制事务开启长度，尽可能地在事务开启前，把费时的查询工作、数据准备做完。基本套路如下

Tx.build(new TxConfig().setPropagation(Propagation.REQUIRED.value())).executeWithoutResult(status -> {
      //执行逻辑
});

图4-1-8-5 编程式事务代码示意

Step1 修改PetShopBatchUpdateAction

@Action(displayName = "确定",bindingType = ViewTypeEnum.FORM,contextType = ActionContextTypeEnum.SINGLE)
public PetShopBatchUpdate conform(PetShopBatchUpdate data){
    if(data.getPetShopList() == null || data.getPetShopList().size()==0){
        throw  PamirsException.construct(DemoExpEnumerate.PET_SHOP_BATCH_UPDATE_SHOPLIST_IS_NULL).errThrow();
    }
    List<PetShopProxy> proxyList = data.getPetShopList();
    for(PetShopProxy petShopProxy:proxyList){
        petShopProxy.setDataStatus(data.getDataStatus());
    }
    Tx.build(new TxConfig().setPropagation(Propagation.REQUIRED.value())).executeWithoutResult(status -> {
        new PetShopProxy().updateBatch(proxyList);
        throw PamirsException.construct(DemoExpEnumerate.SYSTEM_ERROR).errThrow();
    });
    return data;
}

图4-1-8-6 修改PetShopBatchUpdateAction

Step2 重启看效果

跟声明式事务一致的效果

四、配置式事务

略，该模式一般用于平台内部使用以及无代码编辑器管理事务时用到，就不举例了

分布式事务（不建议使用）

如果要严格意义上的分布式事务，需要配置enableXa为true，@PamirsTransational(enableXa=true)。同时引入依赖包

<groupId>pro.shushi.pamirs.framework</groupId>
<artifactId>pamirs-connectors-data-xa</artifactId>

图4-1-8-7 分布式事务依赖包

注：该版本还不支持远程RPC后的分布式事务，因该模式有很大的弊端，也就是把原本无状态的服务变成有状态，导致性能和耦合度都极差。所以我们一般使用事务性消息、异步任务等最终一致性方案去替代。

Oinone社区作者：史, 昂原创文章，如若转载，请注明出处：https://doc.oinone.top/oio4/9283.html

访问Oinone官网:https://www.oinone.top获取数式Oinone低代码应用平台体验

Oinone 7天从入门到精通

史, 昂数式管理员

0 0

4.1.9 函数之元位指令

上一篇 2024年5月23日 am8:55

4.1.7 函数之元数据详解

下一篇 2024年5月23日

Oinone 7天入门到精通

4.1.6 模型之元数据详解

介绍Model相关元数据，以及对应代码注解方式。大家还是可以通读并练习每种不同的使用方式，这个是oinone的设计精华所在。当您不知道如何配置模型、字段、模型间的关系、以及枚举都可以到这里找到。一、模型元数据安装与更新使用@Model.model来配置模型的不可变更编码。模型一旦安装，无法在对该模型编码值进行修改，之后的模型配置更新会依据该编码进行查找并更新；如果仍然修改该注解的配置值，则系统会将该模型识别为新模型，存储模型会创建新的数据库表，而原表将会rename为废弃表。如果模型配置了@Base注解，表明在studio中该模型配置不可变更；如果字段配置了@Base注解，表明在studio中该字段配置不可变更。注解配置模型类必需使用@Model注解来标识当前类为模型类。可以使用@Model.model、@Fun注解模型的模型编码（也表示命名空间），先取@Model.model注解值，若为空则取@Fun注解值，若皆为空则取全限定类名。模型元信息模型的priority，当展示模型定义列表时，使用priority配置来对模型进行排序。模型的ordering，使用ordering属性来配置该模型的数据列表的默认排序。模型元信息继承形式：不继承（N）同编码以子模型为准（C）同编码以父模型为准（P）父子需保持一致，子模型可缺省（P=C）注意：模型上配置的索引和唯一索引不会继承，所以需要在子模型重新定义。数据表的表名、表备注和表编码最终以父模型配置为准；扩展继承父子模型字段编码一致时，数据表字段定义以父模型配置为准。名称描述抽象继承同表继承代理继承多表继承基本信息 displayName 显示名称 N N N N summary 描述摘要 N N N N label 数据标题 N N N N check 模型校验方法 N N N N rule 模型校验表达式 N N N N 模型编码 model 模型编码 N N N N 高级特性 name 技术名称 N N N N table 逻辑数据表名 N P=C P=C N type 模型类型 N N N N chain 是否是链式模型 N N N N index 索引 N N N N unique 唯一索引 N N N N managed 需要数据管理器 N N N N priority 优先级，默认100 N N N N ordering 模型查询数据排序 N N N N relationship 是否是多对多关系模型 N N N N inherited 多重继承 N N N N unInheritedFields 不从父类继承的字段 N N N N unInheritedFunctions 不从父类继承的函数 N N N N 高级特性-数据源 dsKey 数据源 N P=C P=C N 高级特性-持久化 logicDelete 是否逻辑删除 P P P N logicDeleteColumn 逻辑删除字段 P P P N logicDeleteValue 逻辑删除状态值 P P P N logicNotDeleteValue 非逻辑删除状态值 P P P N underCamel 字段是否驼峰下划线映射 P P P N capitalMode 字段是否大小写映射…

史, 昂
2024年5月23日
1.3K000
Oinone 7天入门到精通

3.5.7.6 自定义字段

字段是什么字段的基本概念定义：字段通常指的是数据的一个单独项，它可以是一个文本框、下拉菜单、复选框等，用于在用户界面上收集或展示数据。用途：在表单中，字段用于收集用户输入；在表格或列表中，字段用于显示数据。类型：字段可以有不同的类型，如文本、数字、日期等，这些类型通常由数据模型定义。 Oinone框架中的字段在Oinone框架中，字段的设计和实现遵循以下原则：后端模型驱动：前端的字段直接由后端的数据模型决定。这意味着后端定义了哪些数据应该展示，以及如何展示。减少前后端联调：由于字段的定义和行为是由后端控制的，前后端的联调需求大大减少。前端开发者主要关注于如何呈现这些字段，而后端则负责数据的逻辑和结构。灵活性与规范性：虽然Oinone推荐所有场景都遵循后端模型驱动字段的原则，以保持前后端的一致性和减少沟通成本，但它也为高度定制化的前端页面提供了灵活性。元数据使用：Oinone可能还使用元数据来进一步定义字段的行为，例如它们是否可见、如何验证用户输入等。结合前后端在使用Oinone时，理解前后端如何合作来定义和展示字段是很重要的。这种方法不仅提高了开发效率，而且有助于确保数据的一致性和应用程序的可维护性。同时，对于那些需要特定定制或特殊处理的场景，开发团队能够灵活地适应这些需求，在遵守总体架构原则的同时进行一些特定的调整和优化。作用场景在Oinone框架中，字段扮演着连接后端数据模型和前端用户界面的重要角色。其作用场景包括但不限于以下几点：业务组件的核心： Oinone集成了AntdDesignVue的全部UI组件，将它们转化为业务组件。这些业务组件以字段的形式存在，使得前端开发变得简单高效。开发人员可以直接使用这些现成的业务组件来构建用户界面，大大减少了开发工作量。无代码开发支持：字段的设计使得Oinone支持无代码开发。开发者可以通过拖拉拽的方式在前端快速构建界面，而后端模型的定义直接决定了这些界面的生成。这种模式简化了传统的前端开发流程，提升了开发效率。个性化定制：虽然标准的UI组件可以满足大部分需求，但复杂多变的业务场景往往需要更多个性化的处理。在Oinone中，开发者可以根据具体业务需求和公司的UI指南，定义专门针对特定行业或客户的定制化字段和组件。与无代码平台的结合： Oinone允许将个性化的字段和组件与无代码平台相结合。这意味着即使在进行个性化定制时，也能保持使用无代码工具的便利性，实现更灵活、更高效的前端开发。适应多维度业务需求：由于字段在Oinone中的灵活性和可定制性，它们能够适应多维度的业务需求，无论是从UI设计、用户体验还是业务逻辑的角度，字段都能提供合适的解决方案自定义字段示例工程目录以下是需关注的工程目录示例，main.ts更新导入./field：图3-5-7-24 自定义字段工程目录示例示例代码创建自定义字段组件：使用Vue框架创建一个新的组件（例如 CustomStringFieldVue），并定义其模板、脚本和样式。在模板中定义字段的HTML结构。在脚本中使用 defineComponent 来定义Vue组件。字段类的定义：导入必要的模块，如 FormFieldWidget, ModelFieldType, SPI, ViewType 等。使用 @SPI.ClassFactory 装饰器来注册自定义字段。在类内部初始化并设置组件。 SPI注册参数解释： viewType: 指定视图类型，如表单视图或搜索视图。 widget: 可以指定组件名称。 ttype: 字段的业务类型，例如字符串、数字等。 multi: 指明字段是否支持多值。 model: 定义字段所属的模型。 viewName: 指定视图名称。 name: 定义所属字段的名称。 import {FormFieldWidget, ModelFieldType, SPI, ViewType} from '@kunlun/dependencies'; import CustomStringFieldVue from './CustomStringField.vue'; @SPI.ClassFactory( FormFieldWidget.Token({ viewType: [ViewType.Form, ViewType.Search], ttype: ModelFieldType.String }) ) export class CustomStringField extends FormFieldWidget { public initialize(props) { super.initialize(props); this.setComponent(CustomStringFieldVue); return this; } } 图3-5-7-24 自定义字段组件(TS)示例 <template> <div class="custom-string-filed-wrapper"> 字段组件 </div> </template> <script lang="ts"> import { defineComponent } from 'vue' export default defineComponent({ inheritAttrs: false, name: 'CustomStringFieldVue' }) </script> <style lang="scss"> .custom-string-filed-wrapper { } </style> 图3-5-7-24 自定义字段组件(Vue)示例效果图3-5-7-24 自定义字段效果示例

史, 昂
2024年5月23日
1.5K000
Oinone 7天入门到精通

4.2.5 框架之网络请求-Request

在中后台业务场景中，大部分的请求时候是可以被枚举的，比如创建、删除、更新、查询。在上文中，我们讲了httpClient如何自定义请求，来实现自己的业务诉求。本文中讲到的Request是离业务更近一步的封装，他提供了开箱即用的API，比如insertOne、updateOne，它是基于HttpClient做的二次封装，当你熟悉Request时，在中后台的业务场景中，所有的业务接口自定义将事半功倍。一、Request详细介绍元数据-model 获取模型实例 import { getModel } from '@kunlun/dependencies' getModel('modelName'); 图4-2-5-1 获取模型实例清除所有缓存的模型 import { cleanModelCache } from '@kunlun/dependencies' cleanModelCache(); 图4-2-5-2 清除所有缓存的模型元数据-module 获取应用实例，包含应用入口和菜单 import { queryModuleByName } from '@kunlun/dependencies' queryModuleByName('moduleName') 图4-2-5-3 获取应用实例查询当前用户所有的应用 import { loadModules } from '@kunlun/dependencies' loadModules() 图4-2-5-4 查询当前用户所有的应用 query 分页查询 import { queryPage } from '@kunlun/dependencies' queryPage(modelName, { pageSize: 15, // 一次查询几条 currentPage, 1, // 当前页码 condition?: '' // 查询条件 maxDepth?: 1, // 查几层模型出来，如果有2，会把所有查询字段的关系字段都查出来 sort?: []; // 排序规则 }, fields, variables, context) 图4-2-5-5 分页查询自定义分页查询-可自定义后端接口查询数据 import { customQueryPage } from '@kunlun/dependencies' customQueryPage(modelName, methodName, { pageSize: 15, // 一次查询几条 currentPage, 1, // 当前页码 condition?: '' // 查询条件 maxDepth?: 1, // 查几层模型出来，如果有2，会把所有查询字段的关系字段都查出来 sort?: []; // 排序规则 }, fields, variables, context) 图4-2-5-6 自定义分页查询查询一条-根据params匹配出一条数据 import { queryOne } from '@kunlun/dependencies' customQueryPage(modelName, params, fields, variables, context) 图4-2-5-7 根据params匹配出一条数据自定义查询 import { customQuery } from '@kunlun/dependencies' customQuery(methodName, modelName, record, fields, variables, context) 图4-2-5-8 自定义查询 update import { updateOne } from '@kunlun/dependencies' updateOne(modelName, record, fields, variables, context) 图4-2-5-9 update insert import { insertOne } from '@kunlun/dependencies' insertOne(modelName, record, fields, variables, context) 图4-2-5-10 insert delete import { deleteOne } from '@kunlun/dependencies'…

史, 昂
2024年5月23日
1.2K000
4.5.2 研发辅助之SQL优化

Oinone体系中是不需要针对模型写SQL的，默认提供了通用的数据管理器。在带来便利的情况下，也导致传统的sql审查就没办法开展。但是我们可以以技术的手段收集慢SQL和限制问题SQL执行。慢SQL搜集目的：去发现非原则性问题的慢SQL，并进行整改限制问题SQL执行：对应一些不规范的SQL系统上直接做限制，如果有特殊情况手动放开一、发现慢SQL 这个功能并没有直接加入到oinone的版本中，需要业务自行写插件，插件代码如下。大家可以根据实际情况进行改造比如：堆栈入口，例子中只是放了pamirs，可以根据实际情况改成业务包路径对慢SQL的定义是5s还是3s，根据实际情况变 package pro.shushi.pamirs.demo.core.plugin; import org.apache.ibatis.executor.Executor; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.plugin.*; import org.apache.ibatis.session.ResultHandler; import org.apache.ibatis.session.RowBounds; import org.springframework.stereotype.Component; import pro.shushi.pamirs.meta.annotation.fun.extern.Slf4j; @Intercepts({ @Signature(type = Executor.class,method = "query",args = {MappedStatement.class,Object.class, RowBounds.class, ResultHandler.class}) }) @Component @Slf4j public class SlowSQLAnalysisInterceptor implements Interceptor { @Override public Object intercept(Invocation invocation) throws Throwable { long start = System.currentTimeMillis(); Object result = invocation.proceed(); long end = System.currentTimeMillis(); if (end – start > 10000) {//大于10秒 try { StackTraceElement[] stackTraceElements = Thread.currentThread().getStackTrace(); StringBuffer slowLog = new StringBuffer(); slowLog.append(System.lineSeparator()); for (StackTraceElement element : stackTraceElements) { if (element.getClassName().indexOf("pamirs") > 0) { slowLog.append(element.getClassName()).append(":").append(element.getMethodName()).append(":").append(element.getLineNumber()).append(System.lineSeparator()); } } Object parameter = null; if (invocation.getArgs().length > 1) { parameter = invocation.getArgs()[1]; } MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0]; BoundSql boundSql = mappedStatement.getBoundSql(parameter); Configuration configuration = mappedStatement.getConfiguration(); String originalSql = showSql(configuration, boundSql); originalSql = originalSql.replaceAll("\'", "").replace("\"", ""); log.warn("检测到的慢SQL为：" + originalSql); log.warn("业务慢SQL入口为：" + slowLog.toString()); } catch (Throwable e1) { //忽略 } } return result; } public String showSql(Configuration configuration, BoundSql boundSql) { Object parameterObject = boundSql.getParameterObject(); List<ParameterMapping> parameterMappings = boundSql.getParameterMappings(); String sql = boundSql.getSql().replaceAll("[\\s]+", " "); if (parameterMappings.size() > 0 && parameterObject != null) { TypeHandlerRegistry typeHandlerRegistry…

史, 昂
Oinone 7天入门到精通 2024年5月23日
1.2K000
3.4.3 函数的相关特性

本小章会从oinone的函数拥有三方面特性，展开介绍面向对象，继承与多态面向切面编程，拦截器 SPI机制，扩展点

史, 昂
Oinone 7天入门到精通 2024年5月23日
1.0K000

登录后才能评论

4.1.8 函数之事务管理

一、事务管理介绍

使用方式

事务特性

事务隔离级别

Pamirs（Spring）支持的隔离级别

事务的传播行为

二、声明式事务（举例）

Step1 修改PetShopBatchUpdateAction

Step2 重启看效果

三、编程式事务（举例）

Step1 修改PetShopBatchUpdateAction

Step2 重启看效果

四、配置式事务

分布式事务（不建议使用）

相关推荐

4.1.6 模型之元数据详解

3.5.7.6 自定义字段

4.2.5 框架之网络请求-Request

4.5.2 研发辅助之SQL优化

3.4.3 函数的相关特性

Leave a Reply