| OLD | NEW |
| 1 # Copyright 2015 The Chromium Authors. All rights reserved. | 1 # Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 import sys | 5 import sys |
| 6 | 6 |
| 7 try: | 7 try: |
| 8 sys.path.append('/usr/lib/python2.7/dist-packages/') | 8 sys.path.append('/usr/lib/python2.7/dist-packages/') |
| 9 import MySQLdb | 9 import MySQLdb |
| 10 except ImportError: # pragma: no cover | 10 except ImportError: # pragma: no cover |
| 11 pass | 11 pass |
| 12 finally: | 12 finally: |
| 13 sys.path.remove('/usr/lib/python2.7/dist-packages/') | 13 sys.path.remove('/usr/lib/python2.7/dist-packages/') |
| 14 | 14 |
| 15 DB_INSTANCE_IP = '173.194.225.193' | 15 DB_INSTANCE_IP = '173.194.225.193' |
| 16 DEFAULT_DATABASE = 'ANTIBODY_DB' | 16 DEFAULT_DATABASE = 'ANTIBODY_2' |
| 17 USERNAME = 'antibody-team' | 17 USERNAME = 'antibody-team' |
| 18 | 18 |
| 19 | 19 |
| 20 def connect(password): # pragma: no cover | 20 def connect(password): # pragma: no cover |
| 21 """Connect to Cloud SQL instance google.com:antibody-978:antibody-sql""" | 21 """Connect to Cloud SQL instance google.com:antibody-978:antibody-sql""" |
| 22 connection = MySQLdb.connect(host=DB_INSTANCE_IP, | 22 connection = MySQLdb.connect(host=DB_INSTANCE_IP, |
| 23 user=USERNAME, passwd=password, | 23 user=USERNAME, passwd=password, |
| 24 db=DEFAULT_DATABASE) | 24 db=DEFAULT_DATABASE) |
| 25 cc = connection.cursor() | 25 cc = connection.cursor() |
| 26 return connection, cc | 26 return connection, cc |
| (...skipping 14 matching lines...) Expand all Loading... |
| 41 | 41 |
| 42 VARCHAR(200)|VARCHAR(40)|TIMESTAMP|VARCHAR(10) | 42 VARCHAR(200)|VARCHAR(40)|TIMESTAMP|VARCHAR(10) |
| 43 | 43 |
| 44 type: author or tbr | 44 type: author or tbr |
| 45 """ | 45 """ |
| 46 cursor.executemany("""REPLACE INTO commit_people VALUES (%s,%s,%s,%s)""", | 46 cursor.executemany("""REPLACE INTO commit_people VALUES (%s,%s,%s,%s)""", |
| 47 rows) | 47 rows) |
| 48 | 48 |
| 49 | 49 |
| 50 def write_to_git_commit(cursor, rows): # pragma: no cover | 50 def write_to_git_commit(cursor, rows): # pragma: no cover |
| 51 """hash|bug_url|timestamp|review_url|project_prj_id | 51 """hash|bug_url|timestamp|review_url|project_prj_id|subject |
| 52 | 52 |
| 53 VARCHAR(40)|VARCHAR(200)|TIMESTAMP|VARCHAR(200)|INT | 53 VARCHAR(40)|VARCHAR(200)|TIMESTAMP|VARCHAR(200)|INT|VARCHAR(500) |
| 54 """ | 54 """ |
| 55 cursor.executemany("""REPLACE INTO git_commit VALUES (%s,%s,%s,%s,%s)""", | 55 cursor.executemany("""REPLACE INTO git_commit VALUES (%s,%s,%s,%s,%s,%s)""", |
| 56 rows) | 56 rows) |
| 57 | 57 |
| 58 | 58 |
| 59 def write_to_people(cursor, rows): # pragma: no cover | 59 def write_to_people(cursor, rows): # pragma: no cover |
| 60 """email_address|committer_since | 60 """email_address|committer_since |
| 61 | 61 |
| 62 VARCHAR(200)|TIMESTAMP | 62 VARCHAR(200)|TIMESTAMP |
| 63 """ | 63 """ |
| 64 cursor.execute("""REPLACE INTO people VALUES (%s,%s)""", rows) | 64 cursor.execute("""REPLACE INTO people VALUES (%s,%s)""", rows) |
| 65 | 65 |
| (...skipping 27 matching lines...) Expand all Loading... |
| 93 | 93 |
| 94 | 94 |
| 95 def commit(conn): # pragma: no cover | 95 def commit(conn): # pragma: no cover |
| 96 conn.commit() | 96 conn.commit() |
| 97 | 97 |
| 98 | 98 |
| 99 def close(conn, cursor): # pragma: no cover | 99 def close(conn, cursor): # pragma: no cover |
| 100 cursor.close() | 100 cursor.close() |
| 101 conn.commit() | 101 conn.commit() |
| 102 conn.close() | 102 conn.close() |
| OLD | NEW |