import MySQLdb#主機名HOST = '127.0.0.1'#用戶名USER = "root"#密碼PASSWD = "123456"#數據庫名DB = "db_name"# 打開數據庫連接db=MySQLdb.connect(HOST,USER,PASSWD,DB)# 獲取操作游標cursor=db.cursor()if __name__ == '__main__':  if cursor:    command_a = "update tables_one set status=5 where status=0"    # 使用execute方法執行SQL語句    cursor.execute(command_a)    # 提交到數據庫執行    db.commit()    command2 = "select field from tables_one where id =12"    ret2 = cursor.execute(command2)    # 獲取所有記錄列表    ret2=cursor.fetchall()    for item in ret2:        command3 = "insert into tables_two(name) values (%s);" % (item[0])        fin=cursor.execute(command3)        db.commit()    # 關閉數據庫連接    db.close()

# -*- coding:utf-8 -*-from flask import Flaskfrom flask_sqlalchemy import SQLAlchemyfrom sqlalchemy.sql import textHOST = '127.0.0.1'USER = "root"PASSWD = "123456"DB = "carrier_test"CHARTSET = "utf8"app = Flask(__name__,instance_relative_config = True)#鏈接數據庫路徑app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://%s:%s@127.0.0.1:3306/%s?charset=%s' %(USER,PASSWD,DB,CHARTSET)#如果設置成 True (默認情況)，Flask-SQLAlchemy 將會追蹤對象的修改并且發送信號。這需要額外的內存， 如果不必要的可以禁用它。app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True#如果設置成 True，SQLAlchemy 將會記錄所有 發到標準輸出(stderr)的語句，這對調試很有幫助。app.config['SQLALCHEMY_ECHO'] = False# 數據庫連接池的大小。默認是數據庫引擎的默認值 （通常是 5）。app.config['SQLALCHEMY_POOL_SIZE'] = 6db = SQLAlchemy(app)class Table_one(db.Model):  __tablename__ = 'table_one'  id = db.Column('id', db.Integer, primary_key=True, autoincrement=True)  com_name = db.Column('com_name', db.String(30), nullable=False)  com_about = db.Column('com_about', db.String(200), nullable=False)  def __repr__(self):    return '<table_one com_name %r>' % self.com_nameclass Table_two(db.Model):  __tablename__ = 'table_two'  id = db.Column('id', db.Integer, primary_key=True, autoincrement=True)  reason = db.Column('reason', db.String(128), nullable=True)  create_time = db.Column('create_time', db.TIMESTAMP, server_default=text('now()'))  status = db.Column('status', db.Integer, nullable=False, default=0)  def __repr__(self):    return '<table_two id %r>' % self.iddef db_commit_all(lists):  try:    db.session.add_all(lists)    db.session.commit()    return 'SUCCESS'  except Exception,e:    return 'Fail!!!'def commits_to_three_judge():  com_sta_obj = Table_one.query.filter_by(com_name='只是測試使用,不用關心表間關系').all()  for ite in com_sta_obj:    ship_obj = Table_two.query.filter_by(id=ite.id).first()    if ship_obj:      if int(ship_obj.status) == 2:        ite.status = 0        print db_commit_all([ite])  print '表同步結束'64 if __name__=='__main__':  #執行更新數據庫函數  commits_to_three_judge()