duanque3125 2019-04-02 13:06
浏览 451
已采纳

如何在交互式shell中执行多个命令

My application works with all kind of shell commands, provided from the console (curl, date, ping, whatever). Now I'd like to cover the case with interactive shell commands (like mongo shell), using os/exec.

  • e.g. as a first step, connect to mongodb: mongo --quiet --host=localhost blog

  • then perform arbitrary number of commands, getting the result on every step db.getCollection('posts').find({status:'INACTIVE'})

  • and then exit

I tried the following, but it allows me to perform only one command per mongo connection:

func main() {

    cmd := exec.Command("sh", "-c", "mongo --quiet --host=localhost blog")

    cmd.Stdout = os.Stdout
    cmd.Stderr = os.Stderr

    stdin, _ := cmd.StdinPipe()

    go func() {
        defer stdin.Close()
        io.WriteString(stdin, "db.getCollection('posts').find({status:'INACTIVE'}).itcount()")
        // fails, if I'll do one more here
    }()

    cmd.Run()
    cmd.Wait()
}

Is there a way to run multiple commands, getting stdout result per executed command?

  • 写回答

1条回答 默认 最新

  • duanfu3634 2019-04-02 13:44
    关注

    As Flimzy noted, you should absolutely be using a mongo driver to work with mongo, not trying to interact with it via shell exec.

    However, to answer the root question, of course you can execute multiple commands - there's no reason you can't. Every time you write to the process' stdin, it's like you're at a terminal typing into it. There's no secret limitation on that, other than processes which specifically detect if they're connected to a TTY.

    Your code has several issues, though - you should definitely review the os/exec package documentation. You're calling cmd.Run, which:

    starts the specified command and waits for it to complete.

    And then calling cmd.Wait, which... also waits for the command to complete. You're writing to the stdin pipe in a goroutine, even though this is a very serialized process: you want to write to the pipe to execute a command, get the result, write another command, get another result... concurrency only muddles matters and should not be used here. And you're not sending newlines to tell Mongo you're done writing a command (just like you'd do in the shell - Mongo won't just start executing as soon as you enter the closing paren, you have to hit enter).

    What you would want to do to interact with a process via stdin/stdout (again, noting that this is absolutely not the way to interact with a database, but could be valid for other external commands):

    cmd := exec.Command("sh", "-c", "mongo --quiet --host=localhost blog")
    
    cmd.Stdout = os.Stdout
    cmd.Stderr = os.Stderr
    
    stdin, _ := cmd.StdinPipe()
    
    // Start command but don't wait for it to exit (yet) so we can interact with it
    cmd.Start()
    
    // Newlines, like hitting enter in a terminal, tell Mongo you're done writing a command
    io.WriteString(stdin, "db.getCollection('posts').find({status:'INACTIVE'}).itcount()
    ")
    io.WriteString(stdin, "db.getCollection('posts').find({status:'ACTIVE'}).itcount()
    ")
    
    // Quit tells it you're done interacting with it, otherwise it won't exit
    io.WriteString(stdin, "quit()
    ")
    
    stdin.Close()
    
    // Lastly, wait for the process to exit
    cmd.Wait()
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 数据库获取信息反馈出错,直接查询了ref字段并且还使用了User文档的_id而不是自己的
  • ¥15 将安全信息用到以下对象时发生以下错误:c:dumpstack.log.tmp 另一个程序正在使用此文件,因此无法访问
  • ¥15 速度位置规划实现精确定位的问题
  • ¥15 代码问题:df = pd.read_excel('c:\User\18343\Desktop\wpsdata.xlxs')路径读不到
  • ¥15 为什么视频算法现在全是动作识别?
  • ¥15 编写一段matlab代码
  • ¥15 用Python做岩石类别鉴定软件
  • ¥15 关于调取、提交更新数据库记录的问题
  • ¥15 之前删了盘从下vs2022遇见这个问题 搞了一整天了
  • ¥15 从Freecad中宏下载的DesignSPHysics,出现如下问题是什么原因导致的(语言-python)