当前位置：极客教程 > SQLite > SQLite Perl 教程 > Perl 进行 SQLite 事务

Perl 进行 SQLite 事务

在本章中，我们将处理事务。 首先，我们提供一些基本定义。 然后，我们介绍 Perl 脚本，该脚本显示如何在 Perl DBI 中处理事务。 我们还将讨论自动提交模式，这对于理解事务是必不可少的。

定义

事务 是针对一个或多个数据库中数据的数据库操作的基本单位。 事务中所有 SQL 语句的影响可以全部提交给数据库，也可以全部回滚。 在 自动提交模式 中，更改立即生效。 要处理事务，我们要么关闭自动提交模式，要么使用begin_work()方法启动事务。 事务以commit()或rollback()方法结束。

默认情况下，数据库连接处于自动提交模式。 AutoCommit数据库句柄属性用于设置或读取自动提交模式。

当AutoCommit打开时，对begin_work()的呼叫将AutoCommit关闭。 commit()和rollback()方法重新打开AutoCommit。 如果关闭AutoCommit属性，然后再调用begin_work()方法，则会收到一条错误消息，提示我们已经在事务中。

在 SQLite 中，除SELECT以外的任何命令都将启动隐式事务。 同样，在事务中，诸如CREATE TABLE …，VACUUM和PRAGMA之类的命令将在执行之前提交先前的更改。 手动事务以BEGIN TRANSACTION语句开始，并以COMMIT或ROLLBACK语句结束。

SQLite 支持三种非标准事务级别：DEFERRED，IMMEDIATE和EXCLUSIVE。

例子

现在，我们将有一些可用于事务处理的脚本。

#!/usr/bin/perl

use strict;
use DBI;

my dbh = DBI->connect(            "dbi:SQLite:dbname=test.db",
    "",                            "",                            { RaiseError => 1, AutoCommit => 0 },         
) or dieDBI::errstr;

dbh->do("DROP TABLE IF EXISTS Friends");dbh->do("CREATE TABLE Friends(Id INTEGER PRIMARY KEY, Name TEXT)");
dbh->do("INSERT INTO Friends(Name) VALUES ('Tom')");dbh->do("INSERT INTO Friends(Name) VALUES ('Rebecca')");
dbh->do("INSERT INTO Friends(Name) VALUES ('Jim')");dbh->do("INSERT INTO Friends(Name) VALUES ('Robert')");
dbh->do("INSERT INTO Friends(Name) VALUES ('Julian')");dbh->disconnect();
Perl

我们创建一个Friends表，并尝试用数据填充它。 但是，正如我们将看到的，数据不会被提交。

{ RaiseError => 1, AutoCommit => 0 },
Perl

我们已经将AutoCommit参数设置为 0。更改不会自动提交。 而且没有提交语句。 因此，更改不会写入数据库。

$ ./noautocommit.pl
$ sqlite3 test.db 
SQLite version 3.7.7 2011-06-23 19:49:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"
sqlite> .tables
Cars    Images
Perl

我们的数据库中没有Friends表。

在第二个示例中，我们将使用commit()方法将数据写入数据库。

#!/usr/bin/perl

use strict;
use DBI;

my dbh = DBI->connect(            "dbi:SQLite:dbname=test.db",
    "",                            "",                            { RaiseError => 1, AutoCommit => 0},         
) or dieDBI::errstr;

dbh->do("DROP TABLE IF EXISTS Friends");dbh->do("CREATE TABLE Friends(Id INTEGER PRIMARY KEY, Name TEXT)");
dbh->do("INSERT INTO Friends(Name) VALUES ('Tom')");dbh->do("INSERT INTO Friends(Name) VALUES ('Rebecca')");
dbh->do("INSERT INTO Friends(Name) VALUES ('Jim')");dbh->do("INSERT INTO Friends(Name) VALUES ('Robert')");
dbh->do("INSERT INTO Friends(Name) VALUES ('Julian')");dbh->commit();

$dbh->disconnect();
Perl

当关闭自动提交模式时，每个语句都在事务内，直到我们调用commit()方法为止。

$dbh->commit();
Perl

所有更改都将写入数据库。

sqlite> SELECT * FROM Friends;
1|Tom
2|Rebecca
3|Jim
4|Robert
5|Julian
Perl

我们使用sqlite3命令行工具验证是否已写入更改。

当事务中存在错误时，将回滚事务，并且不会将任何更改提交到数据库。

#!/usr/bin/perl

use strict;
use DBI;

my dbh = DBI->connect(            "dbi:SQLite:dbname=test.db",
    "",                            "",                            { RaiseError => 1, AutoCommit => 0},         
) or dieDBI::errstr;

dbh->do("UPDATE Friends SET Name='Thomas' WHERE Id=1");dbh->do("UPDATE Friend SET Name='Bob' WHERE Id=4");

dbh->commit();dbh->disconnect();
Perl

在代码示例中，自动提交已关闭。 有两个语句构成一个事务。 第二个 SQL 语句中有错误。 因此，该事务将回滚。

$dbh->do("UPDATE Friend SET Name='Bob' WHERE Id=4");
Perl

表名称不正确。 数据库中没有 Friend 表。

$ ./rollingback.pl
DBD::SQLite::db do failed: no such table: Friend at ./rollingback.pl line 15.
DBD::SQLite::db do failed: no such table: Friend at ./rollingback.pl line 15.
Issuing rollback() due to DESTROY without explicit disconnect() 
of DBD::SQLite::db handle dbname=test.db at ./rollingback.pl line 15.
Perl

运行示例将显示此错误消息。 事务回滚。

$ sqlite3 test.db 
SQLite version 3.7.7 2011-06-23 19:49:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"
sqlite> SELECT * FROM Friends;
1|Tom
2|Rebecca
3|Jim
4|Robert
5|Julian
sqlite>
Perl

即使第一个UPDATE语句正确，在Friends表中也没有发生任何变化。

正如我们在教程中已经提到的那样，默认模式是自动提交。 在这种模式下，我们可以使用begin_work()方法开始新的事务，并使用commit()或rollback()完成它。 begin_work()方法将关闭自动提交，commit()和rollback()方法将重新打开自动提交。

#!/usr/bin/perl

use strict;
use DBI;

my dbh = DBI->connect(            "dbi:SQLite:dbname=test.db",
    "",                            "",                            { RaiseError => 1, HandleError=>\&handle_error },         
) or dieDBI::errstr;

dbh->begin_work();dbh->do("UPDATE Friends SET Name='Thomas' WHERE Id=1");
dbh->do("UPDATE Friend SET Name='Bob' WHERE Id=4");dbh->commit();

dbh->do("INSERT INTO Friends(Name) VALUES('Ronald')");dbh->disconnect();

sub handle_error {

    my error = shift;
    print "An error occurred in the script\n";
    print "Message:error\n";
    return 1;
}
Perl

再次，我们有一个不正确的第二条 SQL 语句。 这次，我们没有明确关闭自动提交。

{ RaiseError => 1, HandleError=>\&handle_error },
Perl

我们将把错误处理委托给handle_error()子例程。

$dbh->begin_work();
Perl

使用begin_work()方法，我们开始一个新事务。 自动提交已关闭。

$dbh->do("UPDATE Friends SET Name='Thomas' WHERE Id=1");
$dbh->do("UPDATE Friend SET Name='Bob' WHERE Id=4");
Perl

这两个语句构成一个事务。 第二个是不正确的。

sub handle_error {

    my error = shift;
    print "An error occurred in the script\n";
    print "Message:error\n";
    return 1;
}
Perl

当我们遇到错误时，将调用此子例程。 我们打印一条错误消息。 请注意，该脚本不会退出。

$dbh->do("INSERT INTO Friends(Name) VALUES('Ronald')");
Perl

事务已回滚，我们没有退出脚本。 它继续。 回滚后，自动提交已重新打开。 在Friends表中添加了新行。

$ ./rollingback2.pl
An error occurred in the script
Message: DBD::SQLite::db do failed: no such table: Friend
Perl

我们可以从the handle_error()子例程中看到我们的自定义错误消息。

sqlite> SELECT * FROM Friends;
1|Thomas
2|Rebecca
3|Jim
4|Robert
5|Julian
6|Ronald
Perl

一个新朋友被插入了桌子。

Python教程

Python 教程

Python 教程
Tkinter 教程

Tkinter 教程
Pandas 教程

Pandas 教程
NumPy 教程

NumPy 教程
Flask 教程

Flask 教程
Django 教程

Django 教程
PySpark 教程

PySpark 教程
wxPython 教程

wxPython 教程
SymPy 教程

SymPy 教程
Seaborn 教程

Seaborn 教程
SciPy 教程

SciPy 教程
RxPY 教程

RxPY 教程
Pycharm 教程

Pycharm 教程
Pygame 教程

Pygame 教程
PyGTK 教程

PyGTK 教程
PyQt 教程

PyQt 教程
PyQt5 教程

PyQt5 教程
PyTorch 教程

PyTorch 教程
Matplotlib 教程

Matplotlib 教程
Web2py 教程

Web2py 教程
BeautifulSoup 教程

BeautifulSoup 教程

Java教程

Java 教程

Java 教程

Web教程

HTML 教程

HTML 教程
CSS 教程

CSS 教程
CSS3 教程

CSS3 教程
jQuery 教程

jQuery 教程
Ajax 教程

Ajax 教程
AngularJS 教程

AngularJS 教程
TypeScript 教程

TypeScript 教程
WordPress 教程

WordPress 教程
Laravel 教程

Laravel 教程
Next.js 教程

Next.js 教程
PhantomJS 教程

PhantomJS 教程
Three.js 教程

Three.js 教程
Underscore.JS 教程

Underscore.JS 教程
WebGL 教程

WebGL 教程
WebRTC 教程

WebRTC 教程
VueJS 教程

VueJS 教程

数据库教程

SQL 教程

SQL 教程
MySQL 教程

MySQL 教程
MongoDB 教程

MongoDB 教程
PostgreSQL 教程

PostgreSQL 教程
SQLite 教程

SQLite 教程
Redis 教程

Redis 教程
MariaDB 教程

MariaDB 教程

图形图像教程

Vulkan 教程

Vulkan 教程
OpenCV 教程

OpenCV 教程

大数据教程

R语言 教程

R语言 教程

开发工具教程

Git 教程

Git 教程
VSCode 教程

VSCode 教程
Docker 教程

Docker 教程
Gerrit 教程

Gerrit 教程
Excel 教程

Excel 教程

计算机教程

Go语言 教程

Go语言 教程
C++ 教程

C++ 教程

SQLite Perl 教程

登录

找回密码？

注册