完全通过 FIFO 连接到 MySQL 客户端

在 Bash 脚本中，我想在多个顺序访问中保持 MySQL 会话打开；访问 MySQL 的常见方法是为每个 SQL 命令或命令集打开一个单独的会话，例如

mysql -u user -e "show tables;"

此方法的限制是那些需要双重事务的原子性和锁定状态的丢失：例如，不可能保留表上的锁定状态T对于以下双重操作的整个长度：

### Minimalistic example
data=$(mysql -e "\
    lock table T write;
    select col from T;
")
# ...
# parse 'data' and compute 'output' variable
# ...
mysql -e "insert into T values ($output);"

我的解决方案方法是使用两个 FIFO 保持 MySQL 会话在多个访问中打开，并将进程挂在后台。

建议的解决方案：
创建一对 FIFO：mkfifo IN OUT.
将 MySQL 客户端实例以及虚拟实例设置到位while保持管道畅通并防止SIGPIPE信号：

mysql --xml --batch --raw --skip-column-names \
    -h "$hostname" -u "$username" "$db" >IN <OUT &
while :; do sleep 1; done               <IN >OUT &

然后测试一下：

echo "show tables;" >OUT
read <IN

Result:
这是行不通的。这echo命令完成并且 bash 跳过它，这意味着 MySQL 接收到输入，但是read永远挂起，因此不会产生任何输出。
我发现消除INFIFO 整个任务不会挂起：

mysql --xml --batch --raw --skip-column-names \
    -h "$hostname" -u "$username" "$db" <OUT &
while :; do sleep 1; done               >OUT &

echo "show tables;" >OUT  # this produces the expected output

这种行为是预期的吗？我还想知道是否可以在没有自定义自制程序的情况下在 Bash 中运行双重操作。

FIFO 的问题在于，当每个正在输入数据的进程终止时，它会向正在读取数据的进程发出信号（在本例中）mysql）这是数据的结尾，因此它终止。

诀窍是确保有一个进程使 FIFO 输入始终保持活动状态。您可以通过运行来做到这一点sleep 999999999 > fifofile在背景中。

Exemple:

#!/bin/sh

mkfifo /tmp/sqlpipe

sleep 2147483647 > /tmp/sqlpipe &
PID=$!

mysql -B -uUSER -pPASSWORD < /tmp/sqlpipe &

# all set up, now just push the SQL queries to the pipe, exemple:
echo "INSERT INTO table VALUES (...);" > /tmp/sqlpipe
echo "INSERT INTO table VALUES (...);" > /tmp/sqlpipe
echo "INSERT INTO table VALUES (...);" > /tmp/sqlpipe
cat "mysqldump.sql" > /tmp/sqlpipe
echo "DELETE FROM table WHERE ...;" > /tmp/sqlpipe

# done! terminate pipe
kill -s SIGINT $PID
rm /tmp/sqlpipe

最后我们终止sleep进程完全释放 FIFO 输入。它将发出信号mysql输入已经结束，结果会自动死亡。

还有一种不需要 FIFO 的替代方案，但您需要两个脚本：

run.sh:

#!/bin/sh
./querygenerator.sh | mysql -B -uUSER -pPASSWORD

查询生成器.sh：

#!/bin/sh
echo "INSERT INTO table VALUES (...);"
echo "INSERT INTO table VALUES (...);"
echo "INSERT INTO table VALUES (...);"
cat "mysqldump.sql"
echo "DELETE FROM table WHERE ...;"