如何将AS3连接到MySQL数据库上

日前由于制作任务编辑器，需要连接到数据库中进行一些任务数据的操作，而我们存放任务数据的数据库中MYSQL，所以就找了一下AS3接连MYSQL数据库的资料。

扩张阅读：

ActionScript简称“AS”——动作脚本，是遵循 ECMAscript第四版 的 Adobe Flash Player 运行时环境的编程语言。它在 Flash 内容和应用程序中实现交互性、数据处理以及其他功能。 ActionScript是Flash的脚本语言,与JavaScript相似，ActionScript是一种编程语言，新出的AS3.0使用OOP（面对对象编程），增加更强的报错能力，指定类型也更明确。

找到一个好东西：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。

原文链接：http://www.cnblogs.com/yili16438/archive/2011/04/23/2025936.html