电脑软硬件应用网
当前位置: 电脑软硬件应用网 > 设计学院 > 网络编程 > 数据库 > 正文
分享AS3连接mysql数据库的详细代码
分享AS3连接mysql数据库的详细代码
2011-4-25 12:45:47  文/YiLi   出处:cnblogs   

最近由于制作任务编辑器,需要连接到数据库中进行一些任务数据的操作,而我们存放任务数据的数据库中MYSQL,所以就找了一下AS3接连MYSQL数据库的资料。
找到一个好东西:ActionScript 3 MySql Driver,用SVN的童鞋可以直接checkout: 
http://assql.googlecode.com/svn/trunk/为了使用简单,我做了一个简单的包装类(包含一个数据结构):
package com.easily.ds 


    public class DataBaseData 
    { 
        public var host:String; 
        public var port:int; 
        public var username:String; 
        public var password:String; 
        public var database:String; 
    } 
}
package com.easily.util 

    import com.easily.ds.DataBaseData; 
    import com.maclema.mysql.Connection; 
    import com.maclema.mysql.Field; 
    import com.maclema.mysql.MySqlResponse; 
    import com.maclema.mysql.MySqlToken; 
    import com.maclema.mysql.ResultSet; 
    import com.maclema.mysql.Statement; 
      
    import flash.events.Event; 
    import flash.events.EventDispatcher; 
      
    import mx.rpc.AsyncResponder; 
  
    /** 
     * @author Easily 
     */
    public class DataBase extends EventDispatcher 
    { 
        private var mDataBase:DataBaseData; 
        private var mConnection:Connection; 
          
        public function DataBase(database:DataBaseData) 
        { 
            mDataBase = database; 
        } 
          
        public function connect():void
        { 
            mConnection = new Connection(mDataBase.host, mDataBase.port,  
                mDataBase.username, mDataBase.password, mDataBase.database); 
            mConnection.addEventListener(Event.CONNECT, onConnected); 
              
            mConnection.connect(); 
              
            function onConnected(event:Event):void
            { 
                mConnection.removeEventListener(Event.CONNECT, onConnected); 
                  
                dispatchEvent(event); 
            } 
        } 
          
        public function disconnect():void
        { 
            mConnection.disconnect(); 
        } 
          
        public function select(sql:String, completeHandler:Function, errorHandler:Function = null):void
        { 
            var st:Statement = mConnection.createStatement(); 
            var token:MySqlToken = st.executeQuery(sql); 
            var responder:AsyncResponder = new AsyncResponder(resultHandler, faultHandler, token); 
            token.addResponder(responder); 
              
            function resultHandler(result:Object/*ResultSet*/, token:Object/*MySqlToken*/):void
            { 
                var data:Array = []; 
                  
                if (result is ResultSet) 
                { 
                    var fieldList:Array = result.getColumns(); 
                    while (result.next()) 
                    { 
                        var item:Object = {}; 
                        for each (var field:Field in fieldList) 
                        { 
                            item[field.getName()] = result.getString(field.getName()); 
                        } 
                        data.push(item); 
                    } 
                } 
                  
                completeHandler(data); 
            } 
              
            function faultHandler(info:Object, token:Object):void
            { 
                if (errorHandler == null) return; 
                  
                errorHandler(); 
            } 
        } 
          
        public function insert(sql:String, completeHandler:Function, errorHandler:Function = null):void
        { 
            var st:Statement = mConnection.createStatement(); 
            var token:MySqlToken = st.executeQuery(sql); 
            var responder:AsyncResponder = new AsyncResponder(resultHandler, faultHandler, token); 
            token.addResponder(responder); 
              
            function resultHandler(result:Object/*MySqlResponse*/, token:Object/*MySqlToken*/):void
            { 
                completeHandler(result.insertID); 
            } 
              
            function faultHandler(info:Object, token:Object):void
            { 
                if (errorHandler == null) return; 
                  
                errorHandler(); 
            } 
        } 
          
        public function remove(sql:String, completeHandler:Function, errorHandler:Function = null):void
        { 
            var st:Statement = mConnection.createStatement(); 
            var token:MySqlToken = st.executeQuery(sql); 
            var responder:AsyncResponder = new AsyncResponder(resultHandler, faultHandler, token); 
            token.addResponder(responder); 
              
            function resultHandler(result:Object/*MySqlResponse*/, token:Object/*MySqlToken*/):void
            { 
                completeHandler(); 
            } 
              
            function faultHandler(info:Object, token:Object):void
            { 
                if (errorHandler == null) return; 
                  
                errorHandler(); 
            } 
        } 
    } 
}
其中有3个方法,select,insert,remove,分别对应了SQL语句中的select,insert,delete
用法很简单,先连接:
var databaseData:DataBaseData = new DataBaseData();      
databaseData.host = "127.0.0.1"; 
databaseData.database = "game"; 
databaseData.password = "123456"; 
databaseData.port = 3306; 
databaseData.username = "root"; 
  
var dataBase:DataBase = new DataBase(databaseData); 
dataBase.addEventListener(Event.CONNECT, onConnected); 
dataBase.connect(); 
  
function onConnected(event:Event):void

    dataBase.removeEventListener(Event.CONNECT, onConnected); 
      
    dispatchEvent(new Event(Event.COMPLETE)); 
}
 
如果不需要用了可以先断开连接:
dataBase.disconnect();
下面是select语句:
var sql:String = "select id,name from `npc`"; 
dataBase.select(sql, endQuery); 
  
function endQuery(data:Array):void

    var npcList:Array=  []; 
    for each (var item:Object in data) 
    { 
        var npc:Object = {id:item.id, name:item.name}; 
          
        npcList.push(npc); 
    }    
}
insert语句用法会返回一个insertID,也就是插入的那条数据的ID。

  • 上一篇文章:

  • 下一篇文章: 没有了
  • 最新热点 最新推荐 相关文章
    mysql插入数据后提示:数据提供程序…
    MYSQL数据库中将一个查询结果写入一…
    推荐总结一些数据库性能优化的方法介…
    Mysql数据库名和表名在不同系统下的…
    mysql全文搜索:sql的写法
    解答SQL不许在视图定义ORDER BY子句…
    数据库海量数据查询与优化
    SQL分组实例使用GROUP BY做示例
    图解Slide Window来做SqlServer性能…
    解决附加SQL Server数据库后出现只读…
    关于45IT | About 45IT | 联系方式 | 版权声明 | 网站导航 |

    Copyright © 2003-2011 45IT. All Rights Reserved 浙ICP备09049068号