Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions changelog.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ Features
---------
* Add a `--batch` option as an alternative to STDIN.
* Deprecate `$MYSQL_UNIX_PORT` environment variable in favor of `$MYSQL_UNIX_SOCKET`.
* Support `--username` and `$MYSQL_USER` to set username.


Bug Fixes
Expand Down
9 changes: 8 additions & 1 deletion mycli/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -1910,7 +1910,14 @@ def get_last_query(self) -> str | None:
@click.command()
@click.option("-h", "--host", envvar="MYSQL_HOST", help="Host address of the database.")
@click.option("-P", "--port", envvar="MYSQL_TCP_PORT", type=int, help="Port number to use for connection. Honors $MYSQL_TCP_PORT.")
@click.option("-u", "--user", help="User name to connect to the database.")
@click.option(
'-u',
'--user',
'--username',
'user',
envvar='MYSQL_USER',
help='User name to connect to the database.',
)
@click.option("-S", "--socket", envvar="MYSQL_UNIX_SOCKET", help="The socket file to use for connection.")
@click.option(
"-p",
Expand Down
136 changes: 136 additions & 0 deletions test/test_main.py
Original file line number Diff line number Diff line change
Expand Up @@ -1097,6 +1097,142 @@ def run_query(self, query, new_line=True):
assert MockMyCli.connect_args['passwd'] == EMPTY_PASSWORD_FLAG_SENTINEL


def test_username_option_and_mysql_user_envvar(monkeypatch):
class Formatter:
format_name = None

class Logger:
def debug(self, *args, **args_dict):
pass

def warning(self, *args, **args_dict):
pass

class MockMyCli:
config = {
'main': {},
'alias_dsn': {},
'connection': {
'default_keepalive_ticks': 0,
},
}

def __init__(self, **_args):
self.logger = Logger()
self.destructive_warning = False
self.main_formatter = Formatter()
self.redirect_formatter = Formatter()
self.ssl_mode = 'auto'
self.my_cnf = {'client': {}, 'mysqld': {}}
self.default_keepalive_ticks = 0

def connect(self, **args):
MockMyCli.connect_args = args

def run_query(self, query, new_line=True):
pass

import mycli.main

monkeypatch.setattr(mycli.main, 'MyCli', MockMyCli)
runner = CliRunner()

result = runner.invoke(
mycli.main.click_entrypoint,
args=[
'--username',
'option_user',
'--host',
DEFAULT_HOST,
'--port',
f'{DEFAULT_PORT}',
'--database',
'database',
],
)
assert result.exit_code == 0, result.output + ' ' + str(result.exception)
assert MockMyCli.connect_args['user'] == 'option_user'

MockMyCli.connect_args = None
monkeypatch.setenv('MYSQL_USER', 'env_user')
result = runner.invoke(
mycli.main.click_entrypoint,
args=[
'--host',
DEFAULT_HOST,
'--port',
f'{DEFAULT_PORT}',
'--database',
'database',
],
)
assert result.exit_code == 0, result.output + ' ' + str(result.exception)
assert MockMyCli.connect_args['user'] == 'env_user'


def test_mysql_user_envvar_overrides_dsn_resolution(monkeypatch):
class Formatter:
format_name = None

class Logger:
def debug(self, *args, **args_dict):
pass

def warning(self, *args, **args_dict):
pass

class MockMyCli:
config = {
'main': {},
'alias_dsn': {
'prod': 'mysql://alias_user:alias_password@alias_host:4/alias_database',
},
'connection': {
'default_keepalive_ticks': 0,
},
}

def __init__(self, **_args):
self.logger = Logger()
self.destructive_warning = False
self.main_formatter = Formatter()
self.redirect_formatter = Formatter()
self.ssl_mode = 'auto'
self.my_cnf = {'client': {}, 'mysqld': {}}
self.default_keepalive_ticks = 0

def connect(self, **args):
MockMyCli.connect_args = args

def run_query(self, query, new_line=True):
pass

import mycli.main

monkeypatch.setattr(mycli.main, 'MyCli', MockMyCli)
monkeypatch.setenv('MYSQL_USER', 'env_user')
runner = CliRunner()

result = runner.invoke(mycli.main.click_entrypoint, args=['prod'])
assert result.exit_code == 0, result.output + ' ' + str(result.exception)
assert MockMyCli.connect_args['user'] == 'env_user'
assert MockMyCli.connect_args['passwd'] is None
assert MockMyCli.connect_args['host'] is None
assert MockMyCli.connect_args['port'] is None
assert MockMyCli.connect_args['database'] == 'prod'

MockMyCli.connect_args = None
result = runner.invoke(mycli.main.click_entrypoint, args=['mysql://dsn_user:dsn_passwd@dsn_host:6/dsn_database'])
assert result.exit_code == 0, result.output + ' ' + str(result.exception)
assert (
MockMyCli.connect_args['user'] == 'env_user'
and MockMyCli.connect_args['passwd'] == 'dsn_passwd'
and MockMyCli.connect_args['host'] == 'dsn_host'
and MockMyCli.connect_args['port'] == 6
and MockMyCli.connect_args['database'] == 'dsn_database'
)


def test_ssh_config(monkeypatch):
# Setup classes to mock mycli.main.MyCli
class Formatter:
Expand Down
Loading