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 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。

这是原码: