7d9c3d8f62
pgpass jest prsowany i przy uruchomieniu psql podawane jest wybrane hasło pasujące do połaczenia
122 lines
2.5 KiB
Go
122 lines
2.5 KiB
Go
package psql
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
"os"
|
|
"os/exec"
|
|
"path"
|
|
"path/filepath"
|
|
"runtime"
|
|
|
|
"baal.ar76.eu/x/pub/multisql/cfg"
|
|
"baal.ar76.eu/x/pub/multisql/pass"
|
|
)
|
|
|
|
type Instance struct {
|
|
outdir string
|
|
scripts []string
|
|
pasdb *pass.PassDb
|
|
psqlExe string
|
|
conn cfg.Connection
|
|
verbose bool
|
|
}
|
|
|
|
type Result struct {
|
|
Script string
|
|
Err error
|
|
}
|
|
|
|
func Create(passdb *pass.PassDb, outdir string, scripts []string, conn cfg.Connection, psqlExe string, verbose bool) (instnace Instance) {
|
|
|
|
instnace = Instance{
|
|
outdir: outdir,
|
|
scripts: scripts,
|
|
pasdb: passdb,
|
|
conn: conn,
|
|
psqlExe: psqlExe,
|
|
verbose: verbose,
|
|
}
|
|
return instnace
|
|
}
|
|
|
|
func (self Instance) Exec(result chan<- Result) {
|
|
|
|
|
|
connString := fmt.Sprintf("host=%s port=%d dbname=%s user=%s", self.conn.Host, self.conn.Port, self.conn.DbName, self.conn.User)
|
|
|
|
for _, scr := range self.scripts {
|
|
srcName := path.Base(scr)
|
|
outdir := path.Join(self.outdir, srcName)
|
|
err := os.Mkdir(outdir, 0o775)
|
|
if err != nil {
|
|
result <- Result{
|
|
Script: scr,
|
|
Err: err,
|
|
}
|
|
continue
|
|
}
|
|
password := self.pasdb.FindPassword(self.conn.Host, self.conn.Port, self.conn.DbName, self.conn.User)
|
|
err = self.cmdPsql(outdir, connString, scr, password)
|
|
result <- Result{
|
|
Script: scr,
|
|
Err: err,
|
|
}
|
|
}
|
|
close(result)
|
|
}
|
|
|
|
func (self Instance) cmdPsql(outdir string, connString string, script string, password string) error {
|
|
absScript, err := filepath.Abs(script)
|
|
if err != nil {
|
|
return fmt.Errorf("problem ze zbudowaniem ściezki do skryptu: %w", err)
|
|
}
|
|
psqlExe := "psql"
|
|
if runtime.GOOS == "windows" {
|
|
psqlExe = "psql.exe"
|
|
}
|
|
if self.psqlExe != "" {
|
|
psqlExe = self.psqlExe
|
|
}
|
|
stdoutFile := path.Join(outdir, "stdout.txt")
|
|
stderrFile := path.Join(outdir, "stderr.txt")
|
|
logFile := "log.txt"
|
|
|
|
fhOut, err := os.Create(stdoutFile)
|
|
if err != nil {
|
|
return fmt.Errorf("Problem utworzenie pliku wyników: %v", err)
|
|
}
|
|
defer fhOut.Close()
|
|
|
|
fhErr, err := os.Create(stderrFile)
|
|
if err != nil {
|
|
return fmt.Errorf("Problem utworzenie pliku błędów: %v", err)
|
|
}
|
|
defer fhErr.Close()
|
|
|
|
cmd := exec.Command(psqlExe,
|
|
"-w",
|
|
"-f", absScript,
|
|
"-L", logFile,
|
|
connString,
|
|
)
|
|
cmd.Stderr = fhErr
|
|
cmd.Stdout = fhOut
|
|
cmd.Dir = outdir
|
|
|
|
if password != "" {
|
|
env := os.Environ()
|
|
env = append(env, "PGPASSWORD="+password)
|
|
cmd.Env = env
|
|
}
|
|
|
|
if self.verbose {
|
|
log.Printf("Uruchamiam %s", cmd.String())
|
|
}
|
|
err = cmd.Run()
|
|
if err != nil {
|
|
return fmt.Errorf("Błąd uruchamiania psql: %v", err)
|
|
}
|
|
return nil
|
|
}
|