author = 'eason'

! /usr/bin/env python

-- coding:utf-8 --

import os

print 'Process (%s) start...' % os.getpid()
pid = os.fork()
if pid==0:
print 'I am child process (%s) and my parent is %s.' % (os.getpid(), os.getppid())
else:
print 'I (%s) just created a child process (%s).' % (os.getpid(), pid)

from flask import Flask,request,render_template,session
from flask.ext.sqlalchemy import SQLAlchemy
import json

app = Flask(name)

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:chenym1021@localhost/demo'
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
db = SQLAlchemy(app)

class user(db.Model) :
tablename='test'
userid = db.Column(db.Integer,primary_key = True)
name = db.Column(db.String(20))

@app.route('/',methods=['GET'])
def hello_world():
result = user.query.filter_by(userid=1).first()
if result is None:
json_result={'user_id':None}
return json.dumps(json_result)
else:
json_result={'user_id':result.userid,'userName':result.name}
return json.dumps(json_result)

if name=='main':
app.run(debug='true')

from flask import Flask,request,render_template,session
from flask.ext.sqlalchemy import SQLAlchemy
from flask import Flask,request,render_template,session
from flask.ext.sqlalchemy import SQLAlchemy

import json

app = Flask(name)
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:[email protected]:3306/andriodpi'
db = SQLAlchemy(app)

class device(db.Model):
tablename='device'

deviceId=db.Column(db.String(20),primary_key=True)
deviceName=db.Column(db.String(45))
deviceIp=db.Column(db.String(45))
devicePort=db.Column(db.String(45))
deviceProductionDate=db.Column(db.Date)
deviceStaus=db.Column(db.String(45))
user_userId=db.Column(db.Integer,db.ForeignKey('user.userId'))

class state(db.Model):
tablename='state'
stateId=db.Column(db.Integer,primary_key=True)
stateBulb=db.Column(db.String(4))
device_deviceId=db.Column(db.String(20),db.ForeignKey('device.deviceId'))
class test(db.Model):
tablename='test'
id=db.Column(db.Integer,primary_key=True)
name=db.Column(db.String(10))
number=db.Column(db.String(10))
#device_deviceId=db.Column(db.String(20),db.ForeignKey('device.deviceId'))
class user(db.Model):
tablename = 'user'
userId = db.Column(db.Integer, primary_key = True)
userPasswd = db.Column(db.String(45))
userName = db.Column(db.String(45))
userEmail = db.Column(db.String(50))
userMobile = db.Column(db.String(13))
userTel=db.Column(db.String(13))
userAddr=db.Column(db.String(50))
userIspaid = db.Column(db.Integer)
userRegtime=db.Column(db.Date)

@app.route('/state/<user_id>&<device_id>',methods=['GET'])
def hello_world(user_id,device_id):
deviceresult=device.query.filter_by(user_userId=user_id).first()
if(deviceresult is None):
json_result={'state_info':error}
return json.dumps(json_result)
else:
result=state.query.filter_by(device_deviceId=device_id).first()
json_result={'state_id':result.stateId,'stateBulb':result.stateBulb}
return json.dumps(json_result)

@app.route('/update' ,methods=['GET','POST'])
def user_commit():
new_state=user(userId=3,userPasswd='123456',userName='eason')
db.session.merge(new_state)
db.session.commit()
return 'sueeccd'

@app.route('/delete/<user_Id>' ,methods=['GET','POST'])
def user_delete(user_Id):
result=user.query.filter_by(userId=user_Id).first()
db.session.delete(result)
#new_state=user(userId=3,userPasswd='123456',userName='eason')
#db.session.merge(new_state)
db.session.commit()
return 'sueeccd'
if name=='main':
app.run(debug='true')