Nodejs sequelize 事物处理

2024-09-07 02:48
文章标签 处理 nodejs 事物 sequelize

本文主要是介绍Nodejs sequelize 事物处理,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Transactions - 事务

Sequelize 支持两种使用事务的方法:

  • 一个将根据 promise 链的结果自动提交或回滚事务,(如果启用)用回调将该事务传递给所有调用
  • 而另一个 leave committing,回滚并将事务传递给用户。

主要区别在于托管事务使用一个回调,对非托管事务而言期望 promise 返回一个 promise 的结果。

托管事务(auto-callback)

托管事务自动处理提交或回滚事务。你可以通过将回调传递给 sequelize.transaction 来启动托管事务。

注意回传传递给 transaction 的回调是否是一个 promise 链,并且没有明确地调用t.commit()或 t.rollback()。 如果返回链中的所有 promise 都已成功解决,则事务被提交。 如果一个或几个 promise 被拒绝,事务将回滚。

return sequelize.transaction(function (t) {// 在这里链接您的所有查询。 确保你返回他们。return User.create({firstName: 'Abraham',lastName: 'Lincoln'}, {transaction: t}).then(function (user) {return user.setShooter({firstName: 'John',lastName: 'Boothe'}, {transaction: t});});}).then(function (result) {// 事务已被提交// result 是 promise 链返回到事务回调的结果
}).catch(function (err) {// 事务已被回滚// err 是拒绝 promise 链返回到事务回调的错误
});

抛出错误到回滚

使用托管事务时,你应该 永不 手动提交或回滚事务。 如果所有查询都成功,但您仍然希望回滚事务(例如因为验证失败),则应该抛出一个错误来断开和拒绝链接:

return sequelize.transaction(function (t) {return User.create({firstName: 'Abraham',lastName: 'Lincoln'}, {transaction: t}).then(function (user) {// 查询成功,但我们仍然想回滚!throw new Error();});
});

自动将事务传递给所有查询

在上面的例子中,事务仍然是手动传递的,通过传递 {transaction:t} 作为第二个参数。 要自动将事务传递给所有查询,您必须安装 continuation local storage (CLS) 模块,并在您自己的代码中实例化一个命名空间:

const cls = require('continuation-local-storage'),namespace = cls.createNamespace('my-very-own-namespace');

要启用CLS,您必须通过使用sequelize构造函数的静态方法来告诉Sequelize要使用的命名空间:

const Sequelize = require('sequelize');
Sequelize.useCLS(namespace);new Sequelize(....);

请注意, useCLS() 方法在 构造函数 上,而不是在 sequelize 的实例上。 这意味着所有实例将共享相同的命名空间,并且 CLS 是全部或全无方式 - 你不能仅在某些实例中启用它。

CLS 的工作方式就像一个用于回调的本地线程存储。 这在实践中意味着不同的回调链可以通过使用 CLS 命名空间来访问局部变量。 当启用 CLS 时,创建新事务时,Sequelize 将在命名空间上设置 transaction 属性。 由于回调链中设置的变量对该链是私有的,因此可以同时存在多个并发事务:

sequelize.transaction(function (t1) {namespace.get('transaction') === t1; // true
});sequelize.transaction(function (t2) {namespace.get('transaction') === t2; // true
});

在大多数情况下,你不需要直接访问 namespace.get('transaction'),因为所有查询都将自动在命名空间中查找事务:

sequelize.transaction(function (t1) {// 启用 CLS 后,将在事务中创建用户return User.create({ name: 'Alice' });
});

在使用 Sequelize.useCLS() 后,从 sequelize 返回的所有 promise 将被修补以维护 CLS 上下文。 

并行/部分事务

你可以在一系列查询中执行并发事务,或者将某些事务从任何事务中排除。 使用 {transaction: } 选项来控制查询所属的事务:

不启用CLS

sequelize.transaction(function (t1) {return sequelize.transaction(function (t2) {// 启用CLS,这里的查询将默认使用 t2    // 通过 `transaction` 选项来定义/更改它们所属的事务。return Promise.all([User.create({ name: 'Bob' }, { transaction: null }),User.create({ name: 'Mallory' }, { transaction: t1 }),User.create({ name: 'John' }) // 这将默认为 t2]);});
});

隔离等级

启动事务时可能使用的隔离等级:

Sequelize.Transaction.ISOLATION_LEVELS.READ_UNCOMMITTED // "READ UNCOMMITTED"
Sequelize.Transaction.ISOLATION_LEVELS.READ_COMMITTED // "READ COMMITTED"
Sequelize.Transaction.ISOLATION_LEVELS.REPEATABLE_READ  // "REPEATABLE READ"
Sequelize.Transaction.ISOLATION_LEVELS.SERIALIZABLE // "SERIALIZABLE"

默认情况下,sequelize 使用数据库的隔离级别。 如果要使用不同的隔离级别,请传入所需级别作为第一个参数:

return sequelize.transaction({isolationLevel: Sequelize.Transaction.ISOLATION_LEVELS.SERIALIZABLE}, function (t) {//  你的事务});

注意: 在MSSQL的情况下,SET ISOLATION LEVEL 查询不被记录, 指定的 isolationLevel 直接传递到tedious

非托管事务(then-callback)

非托管事务强制您手动回滚或提交交易。 如果不这样做,事务将挂起,直到超时。 要启动非托管事务,请调用 sequelize.transaction() 而不用 callback(你仍然可以传递一个选项对象),并在返回的 promise 上调用 then。 请注意,commit() 和 rollback() 返回一个 promise。

return sequelize.transaction().then(function (t) {return User.create({firstName: 'Homer',lastName: 'Simpson'}, {transaction: t}).then(function (user) {return user.addSibling({firstName: 'Lisa',lastName: 'Simpson'}, {transaction: t});}).then(function () {return t.commit();}).catch(function (err) {return t.rollback();});
});

参数

可以使用options对象作为第一个参数来调用transaction方法,这允许配置事务。

return sequelize.transaction({ /* options */ });

以下选项(使用默认值)可用:

{autocommit: true,isolationLevel: 'REPEATABLE_READ',deferrable: 'NOT DEFERRABLE' // postgres 的默认设置
}

在为 Sequelize 实例或每个局部事务初始化时,isolationLevel可以全局设置:

// 全局
new Sequelize('db', 'user', 'pw', {isolationLevel: Sequelize.Transaction.ISOLATION_LEVELS.SERIALIZABLE
});// 局部
sequelize.transaction({isolationLevel: Sequelize.Transaction.ISOLATION_LEVELS.SERIALIZABLE
});

deferrable 选项在事务开始后触发一个额外的查询,可选地将约束检查设置为延迟或立即。 请注意,这仅在PostgreSQL中受支持。

sequelize.transaction({// 推迟所有约束:deferrable: Sequelize.Deferrable.SET_DEFERRED,// 推迟具体约束:deferrable: Sequelize.Deferrable.SET_DEFERRED(['some_constraint']),// 不推迟约束:deferrable: Sequelize.Deferrable.SET_IMMEDIATE
})

使用其他 Sequelize 方法

transaction 选项与其他大多数选项一起使用,通常是方法的第一个参数。
对于取值的方法,如 .create.update().updateAttributes() 等。应该传递给第二个参数的选项。
如果不确定,请参阅API文档中的用于确定签名的方法。


这篇关于Nodejs sequelize 事物处理的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

无人叉车3d激光slam多房间建图定位异常处理方案-墙体画线地图切分方案

墙体画线地图切分方案 针对问题:墙体两侧特征混淆误匹配,导致建图和定位偏差,表现为过门跳变、外月台走歪等 ·解决思路:预期的根治方案IGICP需要较长时间完成上线,先使用切分地图的工程化方案,即墙体两侧切分为不同地图,在某一侧只使用该侧地图进行定位 方案思路 切分原理:切分地图基于关键帧位置,而非点云。 理论基础:光照是直线的,一帧点云必定只能照射到墙的一侧,无法同时照到两侧实践考虑:关

安装nodejs环境

本文介绍了如何通过nvm(NodeVersionManager)安装和管理Node.js及npm的不同版本,包括下载安装脚本、检查版本并安装特定版本的方法。 1、安装nvm curl -o- https://raw.githubusercontent.com/nvm-sh/nvm/v0.39.0/install.sh | bash 2、查看nvm版本 nvm --version 3、安装

【生成模型系列(初级)】嵌入(Embedding)方程——自然语言处理的数学灵魂【通俗理解】

【通俗理解】嵌入(Embedding)方程——自然语言处理的数学灵魂 关键词提炼 #嵌入方程 #自然语言处理 #词向量 #机器学习 #神经网络 #向量空间模型 #Siri #Google翻译 #AlexNet 第一节:嵌入方程的类比与核心概念【尽可能通俗】 嵌入方程可以被看作是自然语言处理中的“翻译机”,它将文本中的单词或短语转换成计算机能够理解的数学形式,即向量。 正如翻译机将一种语言

Thymeleaf:生成静态文件及异常处理java.lang.NoClassDefFoundError: ognl/PropertyAccessor

我们需要引入包: <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-thymeleaf</artifactId></dependency><dependency><groupId>org.springframework</groupId><artifactId>sp

jenkins 插件执行shell命令时,提示“Command not found”处理方法

首先提示找不到“Command not found,可能我们第一反应是查看目标机器是否已支持该命令,不过如果相信能找到这里来的朋友估计遇到的跟我一样,其实目标机器是没有问题的通过一些远程工具执行shell命令是可以执行。奇怪的就是通过jenkinsSSH插件无法执行,经一番折腾各种搜索发现是jenkins没有加载/etc/profile导致。 【解决办法】: 需要在jenkins调用shell脚

明明的随机数处理问题分析与解决方案

明明的随机数处理问题分析与解决方案 引言问题描述解决方案数据结构设计具体步骤伪代码C语言实现详细解释读取输入去重操作排序操作输出结果复杂度分析 引言 明明生成了N个1到500之间的随机整数,我们需要对这些整数进行处理,删去重复的数字,然后进行排序并输出结果。本文将详细讲解如何通过算法、数据结构以及C语言来解决这个问题。我们将会使用数组和哈希表来实现去重操作,再利用排序算法对结果

8. 自然语言处理中的深度学习:从词向量到BERT

引言 深度学习在自然语言处理(NLP)领域的应用极大地推动了语言理解和生成技术的发展。通过从词向量到预训练模型(如BERT)的演进,NLP技术在机器翻译、情感分析、问答系统等任务中取得了显著成果。本篇博文将探讨深度学习在NLP中的核心技术,包括词向量、序列模型(如RNN、LSTM),以及BERT等预训练模型的崛起及其实际应用。 1. 词向量的生成与应用 词向量(Word Embedding)

使用协程实现高并发的I/O处理

文章目录 1. 协程简介1.1 什么是协程?1.2 协程的特点1.3 Python 中的协程 2. 协程的基本概念2.1 事件循环2.2 协程函数2.3 Future 对象 3. 使用协程实现高并发的 I/O 处理3.1 网络请求3.2 文件读写 4. 实际应用场景4.1 网络爬虫4.2 文件处理 5. 性能分析5.1 上下文切换开销5.2 I/O 等待时间 6. 最佳实践6.1 使用 as

Level3 — PART 3 — 自然语言处理与文本分析

目录 自然语言处理概要 分词与词性标注 N-Gram 分词 分词及词性标注的难点 法则式分词法 全切分 FMM和BMM Bi-direction MM 优缺点 统计式分词法 N-Gram概率模型 HMM概率模型 词性标注(Part-of-Speech Tagging) HMM 文本挖掘概要 信息检索(Information Retrieval) 全文扫描 关键词

PHP7扩展开发之数组处理

前言 这次,我们将演示如何在PHP扩展中如何对数组进行处理。要实现的PHP代码如下: <?phpfunction array_concat ($arr, $prefix) {foreach($arr as $key => $val) {if (isset($prefix[$key]) && is_string($val) && is_string($prefix[$key])) {$arr[