|
5 | 5 | import sys |
6 | 6 | import argparse |
7 | 7 | import datetime |
| 8 | +import getpass |
8 | 9 | from contextlib import contextmanager |
| 10 | +from pymysqlreplication.event import QueryEvent |
9 | 11 | from pymysqlreplication.row_event import ( |
10 | 12 | WriteRowsEvent, |
11 | 13 | UpdateRowsEvent, |
12 | 14 | DeleteRowsEvent, |
13 | 15 | ) |
14 | | -from pymysqlreplication.event import QueryEvent |
| 16 | + |
15 | 17 |
|
16 | 18 | if sys.version > '3': |
17 | 19 | PY3PLUS = True |
@@ -58,7 +60,7 @@ def parse_args(): |
58 | 60 | help='Host the MySQL database server located', default='127.0.0.1') |
59 | 61 | connect_setting.add_argument('-u', '--user', dest='user', type=str, |
60 | 62 | help='MySQL Username to log in as', default='root') |
61 | | - connect_setting.add_argument('-p', '--password', dest='password', type=str, |
| 63 | + connect_setting.add_argument('-p', '--password', dest='password', type=str, nargs='*', |
62 | 64 | help='MySQL Password to use', default='') |
63 | 65 | connect_setting.add_argument('-P', '--port', dest='port', type=int, |
64 | 66 | help='MySQL port to use', default=3306) |
@@ -116,6 +118,10 @@ def command_line_args(args): |
116 | 118 | if (args.start_time and not is_valid_datetime(args.start_time)) or \ |
117 | 119 | (args.stop_time and not is_valid_datetime(args.stop_time)): |
118 | 120 | raise ValueError('Incorrect datetime argument') |
| 121 | + if not args.password: |
| 122 | + args.password = getpass.getpass() |
| 123 | + else: |
| 124 | + args.password = args.password[0] |
119 | 125 | return args |
120 | 126 |
|
121 | 127 |
|
|
0 commit comments