一次使用多个SQLite数据库

时间:2020-03-05 18:37:46  来源:igfitidea点击:

我有2个SQLite数据库,一个是从服务器上下载的(server.db),另一个是用作客户端上的存储的客户端(client.db)。我需要使用服务器数据库中的数据对客户端数据库执行各种同步查询。

例如,我想删除" client.db tRole"表中的所有行,并重新填充" server.db tRole"表中的所有行。

另一个例子,我想删除" client.db tFile"表中的所有行,其中" fileID"不在" server.db tFile"表中。

在SQL Server中,我们可以在表的前面加上数据库名称。无论如何,使用Adobe Air在SQLite中可以执行此操作吗?

解决方案

回答

可以在Sqlite中一次打开多个数据库,但是在Flex / AIR中进行操作是否可以做到这一点令人怀疑。在命令行客户端中,运行" ATTACH DATABASE path / to / other.db AS otherDb",然后可以将该数据库中的表称为" otherDb.tableName",就像在MySQL或者SQL Server中一样。

Tables in an attached database can be referred to using the syntax database-name.table-name. 
  
  ATTACH DATABASE documentation at sqlite.org

回答

我只是看了AIR SQL API,在SQLConnection上有一个attach方法,它看起来正是我们所需要的。

我尚未对此进行测试,但是根据文档,它应该可以工作:

var connection : SQLConnection = new SQLConnection();

connection.open(firstDbFile);
connection.attach(secondDbFile, "otherDb");

var statement : SQLStatement = new SQLStatement();

statement.connection = connection;
statement.text = "INSERT INTO main.myTable SELECT * FROM otherDb.myTable";
statement.execute();

该代码段中可能存在错误,最近我对AIR SQL API的使用不多。注意,使用open.open打开的数据库表可以通过main.tableName使用,任何添加的数据库都可以使用任何名称(在上例中为otherDb)。

回答

这段代码可以工作,是我写的:

package lib.tools

import flash.utils.ByteArray;
import flash.data.SQLConnection;
import flash.data.SQLStatement;
import flash.data.SQLResult;
import flash.data.SQLMode; 
import flash.events.SQLErrorEvent;
import flash.events.SQLEvent;
import flash.filesystem.File;
import mx.core.UIComponent;
import flash.data.SQLConnection;

public class getConn {
    public var Conn:SQLConnection;

    public function getConn(database:Array) {       
        Conn = new SQLConnection();
        var Key:ByteArray = new ByteArray();
        Key.writeUTFBytes("Some16ByteString"); 
        Conn.addEventListener(SQLErrorEvent.ERROR, createError);
        var dbFile:File = File.applicationDirectory.resolvePath(database[0]);
        Conn.open(dbFile);
        if(database.length > 1) {
            for(var i:Number = 1; i < database.length; i++) {
                var DBname:String = database[i];
                Conn.attach(DBname.split("\.")[0], File.applicationDirectory.resolvePath(DBname));
            }
        }
        Conn.open(dbFile, SQLMode.CREATE, false, 1024, Key); 
    }

    private function createError(event:SQLErrorEvent):void {
        trace("Error code:", event.error.details);
        trace("Details:", event.error.message);
    }

    public function Rs(sql:Array):Object {
        var stmt:SQLStatement = new SQLStatement();
        Conn.begin();
        stmt.sqlConnection = Conn;
        try {
            for(var i:String in sql) {          
                stmt.text = sql[i]; 
                stmt.execute();
            }
            Conn.commit();
        } catch(error:SQLErrorEvent) {
            createError(error);
            Conn.rollback();
        };
        var result:Object =stmt.getResult();
        return result;
    }
}