7第一次求3将用户信息写入mysql数据库天下无鱼

将用户信息写⼊MySQLORM的方式将用户注数据库的信息（如地址、端口、用户名和密码等）存放在base.py中，model.py中定义了数据库表并从base.py中获取数据库信息。当main.py启动时，其将调用model.py初始化数据库。而用户名为root，密码为pwd@demo，mysqlmysql-usetpasswordfor'root'@localhostCREATECREATEDATABASEdemoCHARACTERSET'utf8'showdatabasesbase.pyconf/base.py，增fromsqlalchemyimportcreate_enginefromfromsqlalchemyimportcreate_enginefromsqlalchemy.ext.declarativeimportengine=06/demo?charset=utf8',encoding="utf8",BaseDB=表的定义及初始化。从第6小节中看到，用户注册信息包含手机这些信息作为数据库表项，在models.py中定义，在models.py#!#-*-coding:utf-8-fromconf.baseimportBaseDB,engineimportsysfromsqlalchemyimport(Column,)classUsers(BaseDB):"""tableforusers =id=Column(Integer,primary_key=True)phone=Column(String(50),nullable=False)password=Column(String(50),nullable=True)createTime=Column(DateTime, init(self,phone,password,self.phone=self.password=passwordself.createTimeself.password=passwordself.createTime=createTimedefifname=='mainprint("Initializemain.pymodels.py#!#!#-*-coding:utf-8-*-#Author:demo#Email:demo@#Version:demoimporttornado.webimportosimportfromtornado.optionsimportdefine,optionsfromcommon.url_routerimportinclude,fromtornado.optionsimportdefine,optionsfrommodelsimportinitdbfromsqlalchemy.ormimportscoped_session,fromconf.baseimportBaseDB, init(self):handlers=url_wrapper([(r"/users/",settingsdict(static_path=os.path.join(os.path.dirname(),template_path=os.path.join(os.path.dirname(),)tornado.web.Application.init(self,handlers,**settings)self.db=ifname=='mainprint("Tornadoserverisreadyfor修改users_views.py，将用户数据写⼊数据库中，修改内容包括modelsUsers类表，并判断用户是否在数据库中。如果#!#!#-*-coding:utf-8-importtornado.webimportsysfromtornado.escapeimportjson_decodeimportloggingfromlogging.handlersimportfromdatetimeimportdatetimefrommonsimport()fromconf.baseimport)frommodelsimport(Users)##########Configurelogging#############logFilePath="log/users/users.log"logger=logging.getLogger("Users")handler=formatter=logging.Formatter('%(asctime)shandler.suffix="%Y%m%d""""handle/user/registrequest:paramphone:userssignup:parampassword:userssignup:paramcode:userssignupcode,mustsixdigitalcodedefdb(self):returndefpost(self):args=phone=args['phone']password=args['password']verify_code=args['code']("RegistHandlerequestargumentERROR_CODE['1001'],1001)ex_user=ifERROR_CODE['1002'],logger.debug("RegistHandleinsertdb,user:%s"create_time=add_user=Users(phone,

修改base.py，增加错误码"1