设为首页 收藏本站
查看: 1323|回复: 0

[经验分享] action的使用之封装AIR对本地数据库sqlite的操作

[复制链接]

尚未签到

发表于 2016-12-1 10:59:37 | 显示全部楼层 |阅读模式
使用air开发除了可以使用xml和后台语言来存储提供数据外,还可以拥有自己的小型本地数据库sqlite,数据库的格式为db或db3。使用本地数据库的好处是轻量,可以存储复杂的数据关系,而且air提供有专门的api来访问它,这就不需要其它后台语言来支撑,air程序员就可以独立地完成项目了,熟悉其它大型数据库操作的开发人员可以方便地访问本地数据库(因为语法也大致相同)。在管理工具上,本地小型数据库有Sqlite Developer(推荐使用)、Sqlite Administrator、Sqlite Expert等。一般的flash程序员主要负责表现界面上,不怎么熟悉数据库的设计与操作。数据库结构设计是很重要的,如果一开始设计的数据库结构不合理,那么到后面的项目就难以开发维护了。 所以没有数据库开发经验的开发者要慎用本地数据库。
在我的air项目开发中,我使用了本地小型数据库来存储数据结构,并创建了一些类(SQLConnection和SQLiteAction)来封装数据库的操作,有了这些类之后,对数据库的操作和管理就方便多了。 关于这些类的使用,请看例子:http://sunnyluo.iyunv.com/blog/800136
首先是SQLiteConnection类封装SQLConnection,主要负责打开、关闭数据库:
/**
* 说明:SQLite数据库连接类。
* 该类用于与数据库建立连接。
* 外部可通过调用该类的connect()方法来建立与指定路径的数据库(文件)的连接.
* 在调用connect与数据库建立连接时,如果成功建立(即成功打开数据库)会触发 SQLEvent.OPEN 事件
* 如果打开失败,将触发 SQLErrorEvent.ERROR 事件;
*/
package sunnyluo.sqlite
{
import flash.data.SQLConnection;
import flash.data.SQLMode;
import flash.events.EventDispatcher;
import flash.events.SQLErrorEvent;
import flash.events.SQLEvent;
import flash.filesystem.File;
import flash.filesystem.FileMode;
import flash.filesystem.FileStream;
[Event(name="open",type="flash.events.SQLEvent")]
[Event(name="error",type="flash.events.SQLErrorEvent")]
public class SQLiteConnection extends EventDispatcher
{
private var _conn : SQLConnection;
private var _connected : Boolean = false;;
private var _connecting:Boolean = false;
private var _path : String;
private var _dbFile:File;
/**
* 构造函数.
*
*/
public function SQLiteConnection(path : String)
{
_path = path;_conn = new SQLConnection();
_connected = false;
}
/**
* 与指定路径的数据库文件建立连接.
*
*/
public function connect():void
{
if(!_conn)
{
_conn = new SQLConnection();
_connected = false;
}
if(_connected){
this.dispatchEvent(new SQLEvent(SQLEvent.OPEN));
return;
}
if(_connecting)
{
return;
}
_connecting = true;
addHandler();     
try{         
//_dbFile?"":_dbFile=new File(_path).resolvePath(_path);
_dbFile =new File(_path);
//如果数据库文件不存在,就先创建
if(! _dbFile.exists)
{
var fs:FileStream = new FileStream();
fs=new FileStream();
fs.open(_dbFile,FileMode.APPEND);
fs.close();
}
_conn.openAsync(_dbFile, SQLMode.CREATE);
}catch(e:Error)
{
trace(e.message, _path);
}
}
/**
* 添加数据库连接事件侦听函数;
*
*/
private function addHandler():void
{
if(_conn)
{
_conn.addEventListener(SQLEvent.OPEN, sqlOpenHandler);
_conn.addEventListener(SQLErrorEvent.ERROR, openErrorHandler);
}
}
/**
* 移除数据库连接事件侦听函数;
*
*/
private function removeHandler():void
{
if(_conn)
{
_conn.removeEventListener(SQLEvent.OPEN, sqlOpenHandler);
_conn.removeEventListener(SQLErrorEvent.ERROR, openErrorHandler);
}
}
/**
* 成功打开数据库的事件处理函数;
* @param event
*
*/
private function sqlOpenHandler(event : SQLEvent):void
{
_connected = true;
_connecting = false;
removeHandler();
this.dispatchEvent(event);
}
/**
* 打开数据库失败的事件处理函数.
* @param event
*
*/
private function openErrorHandler(event : SQLErrorEvent):void
{
_connected = false;
_connecting = false;
removeHandler();
this.dispatchEvent(event);
}
/**
* 是否已经建立了连接.
* @return
*
*/
public function isConnected() : Boolean
{
return _connected;
}
/**
* 获得 SQLConnection 对象
* @return
*
*/
public function getConn():SQLConnection
{
return _conn ? _conn : new SQLConnection();
}
/**
*关闭数据库
*
*/
public function close():void
{
if(_conn)
{
_conn.close();
_conn=null;
}
if(_dbFile){
_dbFile.cancel();
_dbFile=null;
}
_connected = false;
_connecting = false;
}
}
}
然后是SQLiteAction类,它封装对数据库的操作,如创建表、插入、删除、更新等单一项的操作:
/**
* 说明:SQLite数据库操作类.
* 该类是所有数据库操作的基类,如创建表、插入、删除、更新等单一项操作。
* 该类有两个主要方法,一个是setSql(sql : String),另一个是execute()。
* 其中setSql用于设置要执行的SQL语句,execute()用于执行此项操作。
* 在调用execute()时,如果成功执行将触发SQLEvent.RESULT事件;
* 如果操作失败,将触发SQLErrorEvent.ERROR事件。
*/
package sunnyluo.sqlite
{
import flash.data.SQLStatement;
import flash.events.SQLErrorEvent;
import flash.events.SQLEvent;
import sunnyluo.action.Action;
import sunnyluo.action.ActionEvent;
public class SQLiteAction extends Action
{
private var _sql : String;//数据库SQL操作语句
private var _conn : SQLiteConnection;//数据库连接类
public function SQLiteAction(conn : SQLiteConnection, sql:String)
{
_conn = conn;
_sql = sql;
}
/**
* 设置需要执行的SQL语句。
* @param sql
*
*/
public function setSql(sql : String):void
{
_sql = sql;
}
/**
* 获取需要执行的SQL语句。  
* @return
*
*/
public function getSql():String
{
return _sql;
}
/**
* 执行数据库操作。
*
*/
override public function execute(event:ActionEvent = null):void
{
if(! _conn || (! _sql)){
this.dispatchEvent(new SQLErrorEvent(SQLErrorEvent.ERROR));
return;
}
//判断数据库是否已经连接
if(_conn.isConnected()){
executeSql();
}else{
connectSqlite();
}
}
/**
* 连接数据库。
* 在还未与数据库建立连接时,会先调用此方法与数据库建立连接。
*
*/
private function connectSqlite():void
{
_conn.addEventListener(SQLEvent.OPEN, connectedHandler);
_conn.addEventListener(SQLErrorEvent.ERROR,connectErrorHandler);
_conn.connect();
}
/**
* 与数据库建立了连接后的处理函数。
* @param event
*
*/
private function connectedHandler(event : SQLEvent):void
{
_conn.removeEventListener(SQLEvent.OPEN, connectedHandler);
_conn.removeEventListener(SQLErrorEvent.ERROR,connectErrorHandler);
executeSql();
}
/**
* 与数据库建立连接失败的处理函数
* @param event
*
*/
private function connectErrorHandler(event : SQLErrorEvent):void
{
_conn.removeEventListener(SQLEvent.OPEN, connectedHandler);
_conn.removeEventListener(SQLErrorEvent.ERROR,connectErrorHandler);
this.dispatchEvent(event);
}
/**
* 执行SQL语句。
* 在此添加了操作的返回和操作失败的事件侦听函数。
*/
private function executeSql():void
{
var stmt : SQLStatement = new SQLStatement();
stmt.sqlConnection = _conn.getConn();
stmt.text = _sql;
stmt.addEventListener(SQLEvent.RESULT, executeResult);
stmt.addEventListener(SQLErrorEvent.ERROR, executeError);
stmt.execute();
}
/**
* 操作返回处理函数。
* 该方法派发了SQLEvent.RESULT事件,
* 外部可通过侦听SQLEvent.RESULT来侦听和处理操作返回后的数据。
* @param event
*
*/
private function executeResult(event : SQLEvent):void
{
event.target.removeEventListener(SQLEvent.RESULT, executeResult);
event.target.removeEventListener(SQLErrorEvent.ERROR, executeError);
var __result:* = event.target.getResult().data;
//this.dispatchEvent(event);
this.actionCompleteHandler(__result);
}
/**
* 操作出错的处理函数。
* @param event
*
*/
private function executeError(event : SQLErrorEvent):void
{
event.target.removeEventListener(SQLEvent.RESULT, executeResult);
event.target.removeEventListener(SQLErrorEvent.ERROR, executeError);
this.actionErrorHandler();
trace(event.error, getSql());
}
}
}

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-308150-1-1.html 上篇帖子: android SQLite数据库使用总结之(一)从加载本地数据库开始 下篇帖子: android开发我的新浪微博客户端-载入页面sqlite篇(1.2)
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表