PHP操作SQLite的例子
PHP操作SQLite的例子
在本章中，您将学习如何在PHP程序中使用SQLite。
安装
从PHP 5.3.0开始SQLite 3扩展默认是启用状态。除非用户在编译时使用--without-sqlite3来禁用它。
为了使用这个扩展，windows用户须启用php_sqlite3.dll。从PHP 5.3.0开始，这个DLL包含在PHP的Windows发行版中。
有关详细的安装说明，请查看我们的PHP教程及其官方网站。
PHP接口APIs
以下是比较重要的PHP接口，这些接口可以满足在PHP中调用SQLite数据库的要求。如果您想开发更复杂的应用程序，那么您可以查看PHP官方文档。
| API | 说明 |
|---|---|
| public void SQLite3::open ( filename, flags, encryption_key ) | 打开SQLite 3数据库的连接。如果构建包括加密，那么它将尝试使用密钥。 如果文件名为':memory:'，则SQLite3::open()将在RAM中创建一个内存数据库，该数据库仅在会话期间持续。 如果文件名是实际的文件名，SQLite3::open()会尝试使用其值打开数据库文件。如果不存在同名文件，则创建一个同名的新数据库文件。 用于确定如何打开SQLite数据库的可选标志。默认情况下，open方法使用SQLITE3_OPEN_READWRITE | SQLITE3_OPEN_CREATE. |
| public bool SQLite3::exec ( string $query ) | 这个接口提供了一种快速、简单的方法来执行SQL参数提供的SQL命令，它可以由多个SQL命令组成。此接口用于对指定数据库执行无结果查询。 |
| public SQLite3Result SQLite3::query ( string $query ) | 此接口执行SQL查询，如果查询有返回结果，则返回sqlite3 result对象。 |
| public int SQLite3::lastErrorCode ( void ) | 返回最近失败的SQLite错误代码。 |
| public string SQLite3::lastErrorMsg ( void ) | 返回最近失败的SQLite错误消息。 |
| public int SQLite3::changes ( void ) | 返回最近的SQL语句更新、插入或删除操作影响的行数。 |
| public bool SQLite3::close ( void ) | 关闭以前通过调用SQLite3::open()打开的数据库连接。 |
| public string SQLite3::escapeString ( string $value ): | 返回一个字符串，该字符串已被正确转义以安全地包含在SQL语句中。 |
连接数据库
下面的PHP代码展示了如何连接到现有数据库。如果数据库不存在，那么它将被创建，最后返回数据库对象。
<?php
class MyDB extends SQLite3 {
function __construct() {
$this->open('test.db');
}
}
$db = new MyDB();
if(!$db) {
echo $db->lastErrorMsg();
} else {
echo "Opened database successfully\n";
}
?>现在，运行上面的程序，在当前目录中创建数据库test.db。你可以根据需求改变你的路劲。如果数据库创建成功，它将显示以下消息：
Open database successfully
创建表格
下面的PHP程序将在上面创建的数据库中新建一张表。
<?php
class MyDB extends SQLite3 {
function __construct() {
$this->open('test.db');
}
}
$db = new MyDB();
if(!$db) {
echo $db->lastErrorMsg();
} else {
echo "Opened database successfully\n";
}
$sql =<<<EOF
CREATE TABLE COMPANY
(ID INT PRIMARY KEY NOT NULL,
NAME TEXT NOT NULL,
AGE INT NOT NULL,
ADDRESS CHAR(50),
SALARY REAL);
EOF;
$ret = $db->exec($sql);
if(!$ret){
echo $db->lastErrorMsg();
} else {
echo "Table created successfully\n";
}
$db->close();
?>执行上述程序时，它将在test.db中创建COMPANY表，并显示以下消息
Opened database successfully Table created successfully
INSERT操作
下面的PHP程序展示了在上面例子中创建的COMPANY表中新增记录。
<?php
class MyDB extends SQLite3 {
function __construct() {
$this->open('test.db');
}
}
$db = new MyDB();
if(!$db){
echo $db->lastErrorMsg();
} else {
echo "Opened database successfully\n";
}
$sql =<<<EOF
INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
VALUES (1, 'Paul', 32, 'California', 20000.00 );
INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
VALUES (2, 'Allen', 25, 'Texas', 15000.00 );
INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
VALUES (3, 'Teddy', 23, 'Norway', 20000.00 );
INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)
VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 );
EOF;
$ret = $db->exec($sql);
if(!$ret) {
echo $db->lastErrorMsg();
} else {
echo "Records created successfully\n";
}
$db->close();
?>执行上述程序时，它将在COMPANY表中增加指定的记录，并显示以下两行。
Opened database successfully Records created successfully
SELECT 操作
下面的PHP程序展示了如何从上面示例中创建的COMPANY表中获取并显示记录
<?php
class MyDB extends SQLite3 {
function __construct() {
$this->open('test.db');
}
}
$db = new MyDB();
if(!$db) {
echo $db->lastErrorMsg();
} else {
echo "Opened database successfully\n";
}
$sql =<<<EOF
SELECT * from COMPANY;
EOF;
$ret = $db->query($sql);
while($row = $ret->fetchArray(SQLITE3_ASSOC) ) {
echo "ID = ". $row['ID'] . "\n";
echo "NAME = ". $row['NAME'] ."\n";
echo "ADDRESS = ". $row['ADDRESS'] ."\n";
echo "SALARY = ".$row['SALARY'] ."\n\n";
}
echo "Operation done successfully\n";
$db->close();
?>当执行上述程序时，它将产生以下结果。
Opened database successfully ID = 1 NAME = Paul ADDRESS = California SALARY = 20000 ID = 2 NAME = Allen ADDRESS = Texas SALARY = 15000 ID = 3 NAME = Teddy ADDRESS = Norway SALARY = 20000 ID = 4 NAME = Mark ADDRESS = Rich-Mond SALARY = 65000 Operation done successfully
UPDATE 操作
下面的PHP代码展示了如何使用UPDATE语句更新记录，然后从COMPANY表中获取并显示更新的记录。
<?php
class MyDB extends SQLite3 {
function __construct() {
$this->open('test.db');
}
}
$db = new MyDB();
if(!$db) {
echo $db->lastErrorMsg();
} else {
echo "Opened database successfully\n";
}
$sql =<<<EOF
UPDATE COMPANY set SALARY = 25000.00 where ID=1;
EOF;
$ret = $db->exec($sql);
if(!$ret) {
echo $db->lastErrorMsg();
} else {
echo $db->changes(), " Record updated successfully\n";
}
$sql =<<<EOF
SELECT * from COMPANY;
EOF;
$ret = $db->query($sql);
while($row = $ret->fetchArray(SQLITE3_ASSOC) ) {
echo "ID = ". $row['ID'] . "\n";
echo "NAME = ". $row['NAME'] ."\n";
echo "ADDRESS = ". $row['ADDRESS'] ."\n";
echo "SALARY = ".$row['SALARY'] ."\n\n";
}
echo "Operation done successfully\n";
$db->close();
?>当执行上述程序时，它将产生以下结果。
Opened database successfully 1 Record updated successfully ID = 1 NAME = Paul ADDRESS = California SALARY = 25000 ID = 2 NAME = Allen ADDRESS = Texas SALARY = 15000 ID = 3 NAME = Teddy ADDRESS = Norway SALARY = 20000 ID = 4 NAME = Mark ADDRESS = Rich-Mond SALARY = 65000 Operation done successfully
DELETE 操作
下面的PHP代码展示了如何使用DELETE语句删除记录，然后从COMPANY表中获取并显示剩余的记录。
<?php
class MyDB extends SQLite3 {
function __construct() {
$this->open('test.db');
}
}
$db = new MyDB();
if(!$db) {
echo $db->lastErrorMsg();
} else {
echo "Opened database successfully\n";
}
$sql =<<<EOF
DELETE from COMPANY where ID = 2;
EOF;
$ret = $db->exec($sql);
if(!$ret){
echo $db->lastErrorMsg();
} else {
echo $db->changes(), " Record deleted successfully\n";
}
$sql =<<<EOF
SELECT * from COMPANY;
EOF;
$ret = $db->query($sql);
while($row = $ret->fetchArray(SQLITE3_ASSOC) ) {
echo "ID = ". $row['ID'] . "\n";
echo "NAME = ". $row['NAME'] ."\n";
echo "ADDRESS = ". $row['ADDRESS'] ."\n";
echo "SALARY = ".$row['SALARY'] ."\n\n";
}
echo "Operation done successfully\n";
$db->close();
?>执行上述代码，将产生如下结果：
Opened database successfully 1 Record deleted successfully ID = 1 NAME = Paul ADDRESS = California SALARY = 25000 ID = 3 NAME = Teddy ADDRESS = Norway SALARY = 20000 ID = 4 NAME = Mark ADDRESS = Rich-Mond SALARY = 65000 Operation done successfully