as3.0怎么连接mysql数据库

为了使用简单，我做了一个简单的包装类(包含一个数据结构)：

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。

as   可理解为：用作、当成，作为；一般是重命名列名或者表名。（主要为了查询方便）

（1）如：表text，  列 column_1,column_2  

你可以写成

 select  column_1  as  列1,column_2 as  列2   from  text as  表

上面的语句可以解释为：选择 column_1  作为   列1,column_2 作为   列2  从 text  当成  表

（2）

select * from blog as B

解析：查找所有blog 表里面的数据，并把blog表格命名为 B；

当你命名一个表之后，你可以在下面用 B 代替 blog；

select *from B

.

MYSQL数据库不仅每个库有编码设置甚至是每个字段都有编码设置.

出现乱码肯定是你现在用的编码混乱造成的

解决办法:

第一步 先改数据库编码

先修改你的数据库,如果你页面用的是UTF-8编码那么你数据库内的编码也需要设置为UTF-8,每个字段都需要设置.要保持内外一致,你可以用Navicat for MySQL工具,这个工具里能看得很清除,如果表\字段很多的话你可以导出SQL语句,然后把SQL语句中相应的编码替换例如gb2312替换成utf8,然后再重新创建一个库,创建的时候字符集选择utf8的再把SQL语句导入,检查一下所有的编码都是utf8的就OK

第二步 程序修改

1\读库的时候

mysql_query("set names utf8")

2\每个页面头部加上一句

header("content-Type: text/htmlcharset=utf-8")

3\检查所有的编码声明是否正确

4\检查页面中现有文字所使用的编码是否正确,推荐你使用editplus在右下角会有显示UTF-8或者ANSI,要保证所有带有中文的文件打开后显示的编码集是UTF-8,如果不是的话可以将所有文件打开然后从菜单选择"文档"-"文件编码"-"文件编码(多文件)",然后选择所有的文件点确定,更改编码为UTF-8确定!

OK到此位置大功告成,所有的编码一致,绝对不会再出现乱码了,多说一句.对于MYSQL *** 作工具的选择本人只推荐两款,一是大家都熟悉的PHPMYADMIN 再就是Navicat for MySQL也有很多人都在用.至于MYSQL-font实在有些垃圾,有时显示出来的数据库结构和实际的都有差别....不敢苟同,另外MYSQL官方出的SQLyog对于编码的支持太差劲了,很难控制具体的编码,所以最好也不要用

---