AS（AeroSpike）数据库常用 *** 作

登录AS：先登录到服务器上，然后直接输入命令： aql

连接： aql -p 3000 -h 192.168.0.1

显示所有命名空间： show namespaces

显示所有表(集合)： show sets

显示所有列（字段）： show bins

查询信息： select * from 命名空间.表名 where PK='主键名'

比如查看配置了哪些namespaces： show namespaces

比如命名空间有：testFile、testMemory

1.插入数据

insert into 命名空间.表名(PK,name,password) VALUES('key1','abc','123')

比如执行如下命令：insert into testMemory.demo(PK,name,password) VALUES('key1','abc','123')

2.查看所有列

查看所有列，通过执行命令： show bins ，可以看到有718列

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

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的用法的用法你知道吗？下面我就跟你们详细介绍下数据库中as的用法的用法，希望对你们有用。

数据库中as的用法的用法如下：

要从一个表中检索数据就是查询这个表。SQL 的 SELECT 语句就是做这个用途的。该语句分为选择列表(列出要返回的字段)、表列表(列出从中检索数据的表)、以及可选的条件(声明任意限制)。比如，要检索表 weather 的所有行，键入：

SELECT * FROM weather这里的 * 是"所有字段"的缩写。[1]因此同样的结果可以用下面的语句获得：

SELECT city, temp_lo, temp_hi, prcp, date FROM weather而输出应该是：

city      | temp_lo | temp_hi | prcp |    date

---------------+---------+---------+------+------------

San Francisco |      46 |      50 | 0.25 | 1994-11-27

San Francisco |      43 |      57 |    0 | 1994-11-29

Hayward       |      37 |      54 |      | 1994-11-29

(3 rows)你可以在选择列表中写任意表达式，而不仅仅是字段列表。比如，你可以：

SELECT city, (temp_hi+temp_lo)/2 AS temp_avg, date FROM weather这样应该得到：

city      | temp_avg |    date

---------------+----------+------------

San Francisco |       48 | 1994-11-27

San Francisco |       50 | 1994-11-29

Hayward       |       45 | 1994-11-29

(3 rows)请注意这里的 AS 子句是如何给输出字段重新命名的。AS 子句是可选的。

一个查询可以使用 WHERE 子句进行"修饰"，声明需要哪些行。WHERE 子句包含一个布尔表达式，只有那些布尔表达式为真的行才会被返回。允许你在条件中使用常用的布尔 *** 作符(AND, OR, NOT)。比如，下面的查询检索旧金山的下雨天的天气：

SELECT * FROM weather

WHERE city = 'San Francisco' AND prcp >0.0结果：

city      | temp_lo | temp_hi | prcp |    date

---------------+---------+---------+------+------------

San Francisco |      46 |      50 | 0.25 | 1994-11-27

(1 row)你可以要求返回的查询是排好序的：

SELECT * FROM weather

ORDER BY city    city      | temp_lo | temp_hi | prcp |    date

---------------+---------+---------+------+------------

Hayward       |      37 |      54 |      | 1994-11-29

San Francisco |      43 |      57 |    0 | 1994-11-29

San Francisco |      46 |      50 | 0.25 | 1994-11-27在这个例子里，排序的顺序并非绝对清晰的，因此你可能看到 San Francisco 行随机的排序。但是如果你使用下面的语句，那么就总是会得到上面的结果

SELECT * FROM weather

ORDER BY city, temp_lo你可以要求查询的结果按照某种顺序排序，并且消除重复行的输出：

SELECT DISTINCT city

FROM weather    city

---------------

Hayward

San Francisco

(2 rows)再次声明，结果行的顺序可能是随机的。你可以组合使用 DISTINCT 和 ORDER BY 来获取一致的结果：[2]

SELECT DISTINCT city

FROM weather

ORDER BY city注意

[1] 虽然 SELECT * 可以把查询的结果翻出来，但我们普遍认为在生产代码中这是很糟糕的风格，因为给表增加一个字段就改变了结果。

[2] 在一些数据库系统里，包括老版本的 PostgreSQL ，DISTINCT 自动对行进行排序，因此 ORDER BY 是多余的。但是这一点并不是 SQL 标准的要求，并且目前的 PostgreSQL 并不保证 DISTINCT 导致数据行被排序。

---