Python&Flash开发斗兽棋-3.1在Twisted框架*问MySql数据库

Python&Flash开发斗兽棋---3.1在Twisted框架下访问MySql数据库

最近业余时间一直在做斗兽棋-野兽争霸这个WebGame项目，www.doushouqi.net，目前版本是2.5，下一个版本准备加上用户注册和积分、成就系统，所以需要用到数据库，简单研究了一下Twisted框架下是如何访问MySql数据库的，现与大家分享如下：

首先，介绍一下用于实验的数据库环境。我用的是MySQL 5.5，新建了一个名为 test 的库，该库里面有一个test表，test表有两个字段k,v，分别为字符串类型和数值型。

创建数据表的SQL语句如下：

CREATE DATABASE `test`;

USE `test`

CREATE TABLE `test` (
  `k` char(32) DEFAULT NULL,
  `v` int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1

然后，介绍一下Twisted框架下面如何访问数据库。Twisted框架内置了一个数据库连接池 twisted.enterprise.adbapi.ConnectionPool，关于ConnectionPool的更多详细信息，建议参考Twisted官网文档 http://twistedmatrix.com/documents/10.0.0/api/twisted.enterprise.adbapi.ConnectionPool.html

下面我们写一个简单的例子

# -*- coding: utf-8 -*-

from twisted.enterprise import adbapi
from twisted.internet import reactor

def printResult(result):
	if result:
		print "%s's value is : %i" % (result[0][0], result[0][1])
	else:
		print "No such key"

def printError(error):
	print error

#初始化连接池
cp = adbapi.ConnectionPool('MySQLdb', db='test',\
	user='root', passwd='root', host='localhost',\
	cp_max=10)
	
query_string = "SELECT k,v FROM test WHERE k='%s'"\
	% ('k1',)
	
cp.runQuery(query_string)\
	.addCallback(printResult)\
	.addErrback(printError)

#让reactor跑起来，否则Twisted不会做任何事情
reactor.callLater(5, reactor.stop)
reactor.run()

如果顺利的话，可以看到以下输出结果

k1's value is : 1

需要特殊说明的是，在测试的过程中，一定要执行

reactor.run()