odl_ad_tv_record_distribution_update_company_field.py 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. #!/usr/bin/env python
  2. #coding=utf-8
  3. """更新表odl.ad_tv_record_distribution表的theme, first_type, second_type字段,去除空白符
  4. """
  5. import datetime
  6. import os
  7. import sys
  8. import time
  9. from fty_util.common import Mysql
  10. reload(sys)
  11. sys.setdefaultencoding('utf8')
  12. conn = Mysql.createOfflineConn()
  13. # 清空走势数据
  14. sql = """
  15. select id, company, `desc` from odl.ad_tv_record_distribution where id > 5000
  16. """
  17. rows = Mysql.getAll(sql, conn=conn)
  18. for row in rows:
  19. _id = row['id']
  20. company = row['company']
  21. desc = row['desc']
  22. company = company.replace(u'报备机构:', '').replace(u'报备机构:', '').replace('\r', '').replace('\n', '').replace('\t', '').replace('\'', '\\\'').replace('\"', '\\\"')
  23. desc = desc.replace(u'内容提要:','').replace(u'内容提要:','').replace('\r', '').replace('\n', '').replace('\t', '').replace('\'', '\\\'').replace('\"', '\\\"')
  24. sql = """
  25. update odl.ad_tv_record_distribution set company = '%s', `desc` = '%s' where id = '%s'
  26. """
  27. sql = sql % (company, desc, _id)
  28. Mysql.execute(sql, conn=conn)
  29. Mysql.close(conn)