Merge pull request #146 from oceanbase/repaire_md5

change md5 to sha256 ref:#145

db.cfg

@@ -1,10 +1,10 @@
 {
  'db': {
- 'host': 'db host',
- 'port': *,
- 'dbname': 'your database name',
- 'user': 'your user name',
- 'pswd': 'password',
- 'charset': 'charset'
+ 'host': 'localhost',
+ 'port': 3306,
+ 'dbname': 'test',
+ 'user': 'root',
+ 'pswd': '123456',
+ 'charset': 'big5'
  }
 }

src/common/db_query.py

@@ -36,7 +36,7 @@
 
 f.close()
 
-hl = hashlib.md5()
+hl = hashlib.sha256()
 
 SQLESS_DEFULT_PASSWORD = '*e9c2bcdc178a99b7b08dd25db58ded2ee5bff05'
 

src/consume/mysql_slowlog_parse.py

@@ -70,7 +70,7 @@ def pattern(self, sql):
  log.error(statement)
  log.exception(e)
 
- sql_id = hashlib.md5(statement.encode('utf-8')).hexdigest().upper()
+ sql_id = hashlib.sha256(statement.encode('utf-8')).hexdigest().upper()
  return sql_id, statement
 
  def skip_sql(self, sql):

src/schedule_task/oceanbase/schedule_plan_oceanbase.py

@@ -397,7 +397,7 @@ def schedule_plan_ob(db_conf, queue_info, schedule_type):
  if plan_info and is_need_insert:
  plan_info = plan_info[:-2].replace('\'', '')
  plan_full = plan_full.replace('\'', '')[:60000]
- outline_hash = hashlib.md5(
+ outline_hash = hashlib.sha256(
  outline_data.encode("utf8")
  ).hexdigest()
  # result_sql