1
0
Fork 0

Compare commits

..

No commits in common. "a916700d98c3fa3dbabfce568bf987db09f0e30e" and "1b2f180fc657c88ea89ec992c37d1fa988f04b4e" have entirely different histories.

13 changed files with 18 additions and 133 deletions

View file

@ -42,7 +42,6 @@ jobs:
env:
PYTEST_PASSWORD: root
PYTEST_HOST: 127.0.0.1
TERM: xterm
run: |
uv run tox -e py${{ matrix.python-version }}

View file

@ -1,13 +1,3 @@
1.30.0 (2025/04/19)
===================
Features
--------
* DSN specific init-command in myclirc. Fixes (#1195)
* Add `\\g` to force the horizontal output.
1.29.2 (2024/12/11)
===================

7
debian/changelog vendored
View file

@ -1,10 +1,3 @@
mycli (1.30.0-1) sid; urgency=medium
* Merging upstream version 1.30.0.
* Updating year in upstream copyright for 2025.
-- Daniel Baumann <daniel@debian.org> Mon, 21 Apr 2025 09:44:51 +0200
mycli (1.29.2-7) sid; urgency=medium
* Using codename instead of suitename in changelog.

2
debian/copyright vendored
View file

@ -4,7 +4,7 @@ Upstream-Contact: Amjith Ramanujam <amjith.r@gmail.com>
Source: https://www.mycli.net
Files: *
Copyright: 2015-2025 Amjith Ramanujam <amjith.r@gmail.com>
Copyright: 2015-2024 Amjith Ramanujam <amjith.r@gmail.com>
License: BSD-3-clause
Files: debian/*

View file

@ -32,7 +32,6 @@ Contributors:
* Daniel West
* Daniël van Eeden
* Fabrizio Gennari
* FatBoyXPC
* François Pietka
* Frederic Aoustin
* Georgy Frolov

View file

@ -10,8 +10,6 @@ import re
import stat
from collections import namedtuple
from pygments.lexer import combined
try:
from pwd import getpwuid
except ImportError:
@ -526,14 +524,14 @@ class MyCli(object):
port = int(port)
except ValueError:
self.echo("Error: Invalid port number: '{0}'.".format(port), err=True, fg="red")
sys.exit(1)
exit(1)
_connect()
except Exception as e: # Connecting to a database could fail.
self.logger.debug("Database connection failed: %r.", e)
self.logger.error("traceback: %r", traceback.format_exc())
self.echo(str(e), err=True, fg="red")
sys.exit(1)
exit(1)
def get_password_from_file(self, password_file):
password_from_file = None
@ -676,7 +674,6 @@ class MyCli(object):
return
special.set_expanded_output(False)
special.set_forced_horizontal_output(False)
try:
text = self.handle_editor_command(text)
@ -746,9 +743,6 @@ class MyCli(object):
else:
max_width = None
if special.forced_horizontal():
max_width = None
formatted = self.format_output(title, cur, headers, special.is_expanded_output(), max_width)
t = time() - start
@ -1230,10 +1224,10 @@ def cli(
alias_dsn = mycli.config["alias_dsn"]
except KeyError:
click.secho("Invalid DSNs found in the config file. " 'Please check the "[alias_dsn]" section in myclirc.', err=True, fg="red")
sys.exit(1)
exit(1)
except Exception as e:
click.secho(str(e), err=True, fg="red")
sys.exit(1)
exit(1)
for alias, value in alias_dsn.items():
if verbose:
click.secho("{} : {}".format(alias, value))
@ -1268,13 +1262,9 @@ def cli(
dsn_uri = None
# Treat the database argument as a DSN alias only if it matches a configured alias
if (
database
and "://" not in database
and not any([user, password, host, port, login_path])
and database in mycli.config.get("alias_dsn", {})
):
# Treat the database argument as a DSN alias if we're missing
# other connection information.
if mycli.config["alias_dsn"] and database and "://" not in database and not any([user, password, host, port, login_path]):
dsn, database = database, ""
if database and "://" in database:
@ -1289,7 +1279,7 @@ def cli(
err=True,
fg="red",
)
sys.exit(1)
exit(1)
else:
mycli.dsn_alias = dsn
@ -1316,29 +1306,6 @@ def cli(
ssh_key_filename = ssh_key_filename if ssh_key_filename else ssh_config.get("identityfile", [None])[0]
ssh_key_filename = ssh_key_filename and os.path.expanduser(ssh_key_filename)
# Merge init-commands: global, DSN-specific, then CLI
init_cmds = []
# 1) Global init-commands
global_section = mycli.config.get("init-commands", {})
for _, val in global_section.items():
if isinstance(val, (list, tuple)):
init_cmds.extend(val)
elif val:
init_cmds.append(val)
# 2) DSN-specific init-commands
if dsn:
alias_section = mycli.config.get("alias_dsn.init-commands", {})
if dsn in alias_section:
val = alias_section.get(dsn)
if isinstance(val, (list, tuple)):
init_cmds.extend(val)
elif val:
init_cmds.append(val)
# 3) CLI-provided init_command
if init_command:
init_cmds.append(init_command)
combined_init_cmd = "; ".join(cmd.strip() for cmd in init_cmds if cmd)
mycli.connect(
database=database,
@ -1354,14 +1321,11 @@ def cli(
ssh_port=ssh_port,
ssh_password=ssh_password,
ssh_key_filename=ssh_key_filename,
init_command=combined_init_cmd,
init_command=init_command,
charset=charset,
password_file=password_file,
)
if combined_init_cmd:
click.echo("Executing init-command: %s" % combined_init_cmd, err=True)
mycli.logger.debug("Launch Params: \n" "\tdatabase: %r" "\tuser: %r" "\thost: %r" "\tport: %r", database, user, host, port)
# --execute argument
@ -1378,10 +1342,10 @@ def cli(
mycli.formatter.format_name = "tsv"
mycli.run_query(execute)
sys.exit(0)
exit(0)
except Exception as e:
click.secho(str(e), err=True, fg="red")
sys.exit(1)
exit(1)
if sys.stdin.isatty():
mycli.run_cli()
@ -1393,7 +1357,7 @@ def cli(
click.secho("Failed! Ran out of memory.", err=True, fg="red")
click.secho("You might want to try the official mysql client.", err=True, fg="red")
click.secho("Sorry... :(", err=True, fg="red")
sys.exit(1)
exit(1)
if mycli.destructive_warning and is_destructive(stdin_text):
try:
@ -1402,7 +1366,7 @@ def cli(
except (IOError, OSError):
mycli.logger.warning("Unable to open TTY as stdin.")
if not warn_confirmed:
sys.exit(0)
exit(0)
try:
new_line = True
@ -1413,10 +1377,10 @@ def cli(
mycli.formatter.format_name = "tsv"
mycli.run_query(stdin_text, new_line=new_line)
sys.exit(0)
exit(0)
except Exception as e:
click.secho(str(e), err=True, fg="red")
sys.exit(1)
exit(1)
def need_completion_refresh(queries):

View file

@ -151,22 +151,9 @@ output.null = "#808080"
# sql.whitespace = ''
# Favorite queries.
# You can add your favorite queries here. They will be available in the
# REPL when you type `\f` or `\f <query_name>`.
[favorite_queries]
# example = "SELECT * FROM example_table WHERE id = 1"
# Initial commands to execute when connecting to any database.
[init-commands]
# read_only = "SET SESSION TRANSACTION READ ONLY"
# Use the -d option to reference a DSN.
# Special characters in passwords and other strings can be escaped with URL encoding.
[alias_dsn]
# example_dsn = mysql://[user[:password]@][host][:port][/dbname]
# Initial commands to execute when connecting to a DSN alias.
[alias_dsn.init-commands]
# Define one or more SQL statements per alias (semicolon-separated).
# example_dsn = "SET sql_select_limit=1000; SET time_zone='+00:00'"

View file

@ -20,7 +20,6 @@ from mycli.packages.prompt_utils import confirm_destructive_query
TIMING_ENABLED = False
use_expanded_output = False
force_horizontal_output = False
PAGER_ENABLED = True
tee_file = None
once_file = None
@ -98,14 +97,6 @@ def set_expanded_output(val):
def is_expanded_output():
return use_expanded_output
@export
def set_forced_horizontal_output(val):
global force_horizontal_output
force_horizontal_output = val
@export
def forced_horizontal():
return force_horizontal_output
_logger = logging.getLogger(__name__)

View file

@ -233,7 +233,7 @@ class SQLExecute(object):
ssl=ssl_context,
program_name="mycli",
defer_connect=defer_connect,
init_command=init_command or None,
init_command=init_command,
)
if ssh_host:
@ -298,12 +298,6 @@ class SQLExecute(object):
if sql.endswith("\\G"):
special.set_expanded_output(True)
sql = sql[:-2].strip()
# \g is treated specially since we might want collapsed output when
# auto vertical output is enabled
elif sql.endswith('\\g'):
special.set_expanded_output(False)
special.set_forced_horizontal_output(True)
sql = sql[:-2].strip()
cur = self.conn.cursor()
try: # Special command

View file

@ -9,7 +9,7 @@ authors = [{ name = "Mycli Core Team", email = "mycli-dev@googlegroups.com" }]
urls = { homepage = "http://mycli.net" }
dependencies = [
"click >= 7.0,<8.1.8",
"click >= 7.0",
"cryptography >= 1.0.0",
"Pygments>=1.6",
"prompt_toolkit>=3.0.6,<4.0.0",

View file

@ -151,25 +151,11 @@ output.null = "#808080"
# sql.whitespace = ''
# Favorite queries.
# You can add your favorite queries here. They will be available in the
# REPL when you type `\f` or `\f <query_name>`.
[favorite_queries]
check = 'select "✔"'
foo_args = 'SELECT $1, "$2", "$3"'
# example = "SELECT * FROM example_table WHERE id = 1"
# Initial commands to execute when connecting to any database.
[init-commands]
# read_only = "SET SESSION TRANSACTION READ ONLY"
global_limit = "set sql_select_limit=9999"
# Use the -d option to reference a DSN.
# Special characters in passwords and other strings can be escaped with URL encoding.
[alias_dsn]
# example_dsn = mysql://[user[:password]@][host][:port][/dbname]
# Initial commands to execute when connecting to a DSN alias.
[alias_dsn.init-commands]
# Define one or more SQL statements per alias (semicolon-separated).
# example_dsn = "SET sql_select_limit=1000; SET time_zone='+00:00'"

View file

@ -553,14 +553,3 @@ def test_init_command_multiple_arg(executor):
assert result.exit_code == 0
assert expected_sql_select_limit in result.output
assert expected_max_join_size in result.output
@dbtest
def test_global_init_commands(executor):
"""Tests that global init-commands from config are executed by default."""
# The global init-commands section in test/myclirc sets sql_select_limit=9999
sql = 'show variables like "sql_select_limit";'
runner = CliRunner()
result = runner.invoke(cli, args=CLI_ARGS, input=sql)
expected = "sql_select_limit\t9999\n"
assert result.exit_code == 0
assert expected in result.output

View file

@ -173,13 +173,6 @@ def test_favorite_query_expanded_output(executor):
assert_result_equal(results, status="test-ae: Deleted")
@dbtest
def test_collapsed_output_special_command(executor):
set_expanded_output(True)
run(executor, "select 1\\g")
assert is_expanded_output() is False
@dbtest
def test_special_command(executor):
results = run(executor, "\\?")