如何将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); } }