AS3链接MySqL.doc

AS3连接MYSQL数据库 最近由于制作任务编辑器，需要连接到数据库中进行一些任务数据的操作，而我们存放任务数据的数据库中MYSQL，所以就找了一下AS3接连MYSQL数据库的资料。找到一个好东西：ActionScript 3 MySql Driver，用SVN的童鞋可以直接checkout: /svn/trunk/为了使用简单，我做了一个简单的包装类(包含一个数据结构)：view sourceprint?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; view sourceprint?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) itemfield.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用法很简单，先连接：view sourceprint?var databaseData:DataBaseData = new DataBaseData(); databaseData.host = ; 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); 如果不需要用了可以先断开连接：view sourceprint?dataBase.disconnect(); 下面是select语句：view sourceprint?var sql:String = select id,name from npc; dataBase.select(sq