原文: http://zetcode.com/db/sqliteperltutorial/connect/

SQLite Perl 教程的这一部分将展示如何创建与数据库的数据库连接。

第一步是连接到数据库。 我们使用connect() DBI 方法建立连接。 disconnect()方法用于关闭数据库连接。

  1. $dbh = DBI->connect($dsn, $username, $password)
  2. or die $DBI::errstr;
  3. $dbh = DBI->connect($dsn, $username, $password, \%attr)
  4. or die $DBI::errstr;

connect()方法建立与请求的数据源的数据库连接。 如果连接成功,它将返回数据库句柄对象。 我们使用disconnect()方法终止连接。

$dsn是数据源名称。 它是一个字符串,告诉 Perl DBI 模块,应加载哪种驱动程序以及将要建立连接的数据库的位置。

  1. dbi:DriverName:database_name
  2. dbi:DriverName:database_name@hostname:port
  3. dbi:DriverName:database=database_name;host=hostname;port=port

上面的字符串是 Perl DBI 中数据源名称的示例。

  1. dbi:SQLite:dbname=test.db

我们将使用此数据源名称。 dsn始终以dbi:子字符串开头。 然后我们有驱动程序名称。 在我们的例子中,驱动程序名称为 SQLite。 第三部分是数据库名称。 在本教程中,我们将使用test.db

  1. dbi:SQLite:dbname=:memory:

我们还可以使用上述数据源名称在内存中创建数据库。

对于 SQLite 数据库,我们不提供$username$password。 数据库不支持它。 我们在那儿留下了两个空弦。 最后一个参数是对哈希的引用,在哈希中,我们可以设置属性以更改连接的默认设置。 例如,RaiseError属性可用于强制错误引发异常,而不是返回错误代码。 HandleError属性可用于提供子程序,以防发生错误。 AutoCommit属性设置或取消设置自动提交模式。

$DBI::errstr是一个 DBI 动态属性,它返回本地数据库引擎错误消息。 如果连接失败,则会显示此消息,并且脚本将中止。

版本

在第一个代码示例中,我们将获得 SQLite 数据库的版本。

  1. #!/usr/bin/perl
  2. use strict;
  3. use DBI;
  4. my $dbh = DBI->connect(
  5. "dbi:SQLite:dbname=test.db",
  6. "",
  7. "",
  8. { RaiseError => 1 },
  9. ) or die $DBI::errstr;
  10. my $sth = $dbh->prepare("SELECT SQLITE_VERSION()");
  11. $sth->execute();
  12. my $ver = $sth->fetch();
  13. print @$ver;
  14. print "\n";
  15. $sth->finish();
  16. $dbh->disconnect();

在上面的 Perl 脚本中,我们连接到先前创建的test.db数据库。 我们执行一条 SQL 语句,该语句返回 SQLite 数据库的版本。

  1. use DBI;

我们使用 Perl DBI 模块连接到 SQLite 数据库。

  1. my $dbh = DBI->connect(
  2. "dbi:SQLite:dbname=test.db",
  3. "",
  4. "",
  5. { RaiseError => 1 },
  6. ) or die $DBI::errstr;

在这里,我们连接到test.db数据库。 第一个参数是数据源名称。 在字符串中,我们指定数据库驱动程序和数据库名称。 第二个和第三个参数为空。 在其他情况下,我们在那里提供用户名和密码。 最后一个参数是数据库选项。 我们将RaiseError选项设置为 1。这将导致引发异常,而不是返回错误代码。

  1. my $sth = $dbh->prepare("SELECT SQLITE_VERSION()");
  2. $sth->execute();

prepare()方法准备一条 SQL 语句供以后执行。 execute()方法执行 SQL 语句。

  1. my $ver = $sth->fetch();

我们获取数据。

  1. print @$ver;
  2. print "\n";

我们将检索到的数据打印到控制台。

  1. $sth->finish();

在这里,我们指示将不再从此语句句柄中获取任何数据。

  1. $dbh->disconnect();

我们关闭与数据库的连接。

  1. $ ./version.pl
  2. 3.7.9

执行verion.pl脚本,我们得到 SQLite 数据库的版本。

插入数据

我们将创建一个Cars表并在其中插入几行。

  1. #!/usr/bin/perl
  2. use strict;
  3. use DBI;
  4. my $dbh = DBI->connect(
  5. "dbi:SQLite:dbname=test.db",
  6. "",
  7. "",
  8. { RaiseError => 1}
  9. ) or die $DBI::errstr;
  10. $dbh->do("DROP TABLE IF EXISTS Cars");
  11. $dbh->do("CREATE TABLE Cars(Id INT PRIMARY KEY, Name TEXT, Price INT)");
  12. $dbh->do("INSERT INTO Cars VALUES(1,'Audi',52642)");
  13. $dbh->do("INSERT INTO Cars VALUES(2,'Mercedes',57127)");
  14. $dbh->do("INSERT INTO Cars VALUES(3,'Skoda',9000)");
  15. $dbh->do("INSERT INTO Cars VALUES(4,'Volvo',29000)");
  16. $dbh->do("INSERT INTO Cars VALUES(5,'Bentley',350000)");
  17. $dbh->do("INSERT INTO Cars VALUES(6,'Citroen',21000)");
  18. $dbh->do("INSERT INTO Cars VALUES(7,'Hummer',41400)");
  19. $dbh->do("INSERT INTO Cars VALUES(8,'Volkswagen',21600)");
  20. $dbh->disconnect();

上面的脚本创建一个Cars表,并将 8 行插入到该表中。

  1. $dbh->do("CREATE TABLE Cars(Id INT PRIMARY KEY, Name TEXT, Price INT)");

do()方法执行 SQL 语句。 它将两个方法调用prepare()execute()组合为一个调用。 do()方法用于非选择语句。

  1. $dbh->do("INSERT INTO Cars VALUES(1,'Audi',52642)");
  2. $dbh->do("INSERT INTO Cars VALUES(2,'Mercedes',57127)");

这两行将两辆车插入表。 请注意,默认情况下,我们处于自动提交模式,其中对表的所有更改均立即生效。

  1. sqlite> .mode column
  2. sqlite> .headers on

我们使用sqlite3工具验证写入的数据。 首先,我们修改数据在控制台中的显示方式。 我们使用列模式并打开标题。

  1. sqlite> SELECT * FROM Cars;
  2. Id Name Price
  3. ---------- ---------- ----------
  4. 1 Audi 52642
  5. 2 Mercedes 57127
  6. 3 Skoda 9000
  7. 4 Volvo 29000
  8. 5 Bentley 350000
  9. 6 Citroen 21000
  10. 7 Hummer 41400
  11. 8 Volkswagen 21600

这是我们已写入Cars表的数据。

最后插入的行 ID

有时,我们需要确定最后插入的行的 ID。 在 Perl DBI 中,我们使用last_insert_id()方法进行查找。

  1. #!/usr/bin/perl
  2. use strict;
  3. use DBI;
  4. my $dbh = DBI->connect(
  5. "dbi:SQLite:dbname=:memory:",
  6. "",
  7. "",
  8. { RaiseError => 1 },
  9. ) or die $DBI::errstr;
  10. $dbh->do("CREATE TABLE Friends(Id INTEGER PRIMARY KEY, Name TEXT)");
  11. $dbh->do("INSERT INTO Friends(Name) VALUES ('Tom')");
  12. $dbh->do("INSERT INTO Friends(Name) VALUES ('Rebecca')");
  13. $dbh->do("INSERT INTO Friends(Name) VALUES ('Jim')");
  14. $dbh->do("INSERT INTO Friends(Name) VALUES ('Robert')");
  15. $dbh->do("INSERT INTO Friends(Name) VALUES ('Julian')");
  16. my $id = $dbh->last_insert_id("", "", "Friends", "");
  17. print "The last Id of the inserted row is $id\n";
  18. $dbh->disconnect();

我们在内存中创建一个Friends表。 Id自动递增。

$dbh->do("CREATE TABLE Friends(Id INTEGER PRIMARY KEY, Name TEXT)");

在 SQLite 中,INTEGER PRIMARY KEY列自动增加。 还有一个AUTOINCREMENT关键字。 在INTEGER PRIMARY KEY AUTOINCREMENT中使用时,会使用稍微不同的算法来创建Id

$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')");

这五个 SQL 语句将五行插入到Friends表中。

my $id = $dbh->last_insert_id("", "", "Friends", "");

使用last_insert_id()方法,我们获得最后插入的行 ID。

$ ./lastrowid.pl
The last Id of the inserted row is 5

我们看到了脚本的输出。

取得数据

在本章的最后一个示例中,我们获取一些数据。 有关数据获取的更多信息将在“查询”一章中进行讨论。

#!/usr/bin/perl

use strict;
use DBI;

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

my $sth = $dbh->prepare( "SELECT * FROM Cars WHERE Id=1" );  
$sth->execute();

my ($id, $name, $price) = $sth->fetchrow();
print "$id $name $price\n";

my $fields = $sth->{NUM_OF_FIELDS};
print "We have selected $fields field(s)\n";

my $rows = $sth->rows();
print "We have selected $rows row(s)\n";

$sth->finish();
$dbh->disconnect();

在示例中,我们从Cars表中获取一行。 我们还将找出我们选择了多少字段&行。

my $sth = $dbh->prepare( "SELECT * FROM Cars WHERE Id=1" );  
$sth->execute();

我们使用prepare()方法准备一条 SQL 语句。 SQL 字符串被发送到 SQLite 数据库引擎进行处理。 检查其语法和有效性。 该方法返回一个语句句柄。 然后执行 SQL 语句。 准备将数据发送到客户端程序。

my ($id, $name, $price) = $sth->fetchrow();
print "$id $name $price\n";

使用fetchrow()方法从数据库中检索数据。 该方法以 Perl 列表的形式从表中返回一行。

my $fields = $sth->{NUM_OF_FIELDS};

NUM_OF_FIELDS是一个语句句柄属性,它为我们提供了返回字段的数量。 在我们的情况下,我们返回了三个字段:IdNamePrice

my $rows = $sth->rows();

我们得到选定的行数。 我们仅从表中检索到一行。 rows()方法返回受影响的行数。 它可以用于SELECTUPDATEDELETE SQL语句。

$ ./fetchrow.pl 
1 Audi 52642
We have selected 3 field(s)
We have selected 1 row(s)

fetchrow.pl脚本的输出。

在 SQLite Perl 教程的这一章中,我们展示了如何建立与 SQLite 数据库的数据库连接。 我们已经解释了对数据库进行一些基本工作的脚本。