现在的位置: 首页 > IT运维 > 正文

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

2011年04月27日 IT运维 ⁄ 共 4079字 暂无评论 ⁄ 被围观 9+

最近由于制作任务编辑器,需要连接到数据库中进行一些任务数据的操作,而我们存放任务数据的数据库中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。

给我留言

您必须 [ 登录 ] 才能发表留言!

×
#