SAE Tornado 应用连接并使用 Mysql

大家好，今天本人给大家带来文章《SAE Tornado 应用连接并使用 Mysql》，文中内容主要涉及到MySQL、tornado、sina-app-engine，如果你对数据库方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

今天因为要提供几个开放的接口给我毕设相关的平台调用，所以又开始折腾之前在

SAE

Tornado

之前记录过一个 如何在 SAE 上使用 Tornado，这次续上，关于在

SAE

Tornado

MySQL

Tornado

MySQL

首先在

应用控制台

共享型MySQL

• 点击

  管理MySQL

  可以进入管理后台，标准的

  PHPMyAdmin

  。

根据 SAE官方文档 底部介绍，你可以通过以下方法获得连接数据库所需的参数。

import sae.const

sae.const.MYSQL_DB      # 数据库名
sae.const.MYSQL_USER    # 用户名
sae.const.MYSQL_PASS    # 密码
sae.const.MYSQL_HOST    # 主库域名（可读写）
sae.const.MYSQL_PORT    # 端口，类型为，请根据框架要求自行转换为int
sae.const.MYSQL_HOST_S  # 从库域名（只读）

注意：需要将

sae.const.MYSQL_PORT

转成

int型

。

SAE Python

MySQLdb模块

1 导入

sae

MySQLdb

import sae.const
import MySQLdb

2 连接数据库：

db=MySQLdb.connect(host=sae.const.MYSQL_HOST,port=int(sae.const.MYSQL_PORT ),user=sae.const.MYSQL_USER ,passwd=sae.const.MYSQL_PASS ,db=sae.const.MYSQL_DB)

3 获取

cursor

cursor = db.cursor() #默认类型，返回结果如：(u'ccc', 33L)
cursor = db.cursor(cursorclass=MySQLdb.cursors.DictCursor) #返回字典形式，如：{'name': u'ccc', 'created': 33L}

4 执行

SQL

cursor.execute(“select * from table_name where what = ‘what’”) #模拟数据: [{‘name’: ’chengkang’, ‘gender’: ‘male’},{‘name’: ’xiaoli’, ‘gender’: ’female’}]

5 输出返回结果:

result = cursor.fetchone()
if result is None:
        print “None”
else:
        print “%s”%result #{‘name’: ’chengkang’, ‘gender’: ‘male’}
        print result[‘name’] #chengkang
        result = cursor.fetchall()
        for row in result:
                print “%s”%row #{‘name’: ’chengkang’, ‘gender’: ‘male’}
                    for col in row:
                        print “%s”%col #chengkangmale     

以上是最基本的使用。反正我暂时就用到这些：）。一些细节的问题之后再来吧。

参考了这个博客。

下面附上我自己试验时候的代码，可能会有一些参考价值。

class TestHandler(tornado.web.RequestHandler):
    def get(self):
        premise = self.get_argument('premise', "no_data")
        consequence = self.get_argument('consequence', "no_data")
        
        try:
            import sae.const
            import MySQLdb
            try:
                db=MySQLdb.connect(host=sae.const.MYSQL_HOST,port=int(sae.const.MYSQL_PORT ),user=sae.const.MYSQL_USER ,passwd=sae.const.MYSQL_PASS ,db=sae.const.MYSQL_DB)
                cursor = db.cursor(cursorclass=MySQLdb.cursors.DictCursor)
                #cursor = db.cursor()
                try:
                    cursor.execute("SELECT * FROM immediate_consequences")
                    one = cursor.fetchall()
                    #cursor.execute("SELECT * FROM immediate_consequences WHERE premise='"+premise+"' and consequence='"+consequence+"'")
                    #one = cursor.fetchone()
                    a = ""
                    #for row in cursor.fetchall():
                    #   for item in row:
                    #      a += item
                    if one is None:
                        self.write("Not in the database")
                    else:
                        #self.write(one['premise']+one['consequence'])
                        for item in one:
                            self.write("Yes%s"%item)
                    #self.write(a.fetchone())
                    #self.write("premise:",one['premise']," and consequence:",one['consequence'])
                except:
                    self.write(“wtf”)
                cursor.close()
            except:
                self.write("database connection error")
        except:
            self.write("Hello Tornado")

以上。

到这里，我们也就讲完了《SAE Tornado 应用连接并使用 Mysql》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于mysql的知识点！