DBMNG数据库管理与应用

科学是实事求是的学问,来不得半点虚假。
当前位置:首页 > MySQL > 驱动连接

AS3连接MYSQL数据库

最近由于制作任务编辑器,需要连接到数据库中进行一些任务数据的操作,而我们存放任务数据的数据库中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 DataBaseextends 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 (resultis ResultSet)
                {
                    var fieldList:Array = result.getColumns();
                    while (result.next())
                    {
                        var item:Object = {};
                        for each (var field:Fieldin 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。

出处:http://www.cnblogs.com/yili16438/
本站文章内容,部分来自于互联网,若侵犯了您的权益,请致邮件chuanghui423#sohu.com(请将#换为@)联系,我们会尽快核实后删除。
Copyright © 2006-2023 DBMNG.COM All Rights Reserved. Powered by DEVSOARTECH            豫ICP备11002312号-2

豫公网安备 41010502002439号