//go:build !windows // +build !windows /* ** Copyright (C) 2001-2024 Zabbix SIA ** ** This program is free software: you can redistribute it and/or modify it under the terms of ** the GNU Affero General Public License as published by the Free Software Foundation, version 3. ** ** This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; ** without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. ** See the GNU Affero General Public License for more details. ** ** You should have received a copy of the GNU Affero General Public License along with this program. ** If not, see <https://www.gnu.org/licenses/>. **/ package plugin import ( "database/sql" "fmt" "os" "time" "golang.zabbix.com/sdk/log" ) var sharedConn *PGConn func getConnPool() (*PGConn, error) { return sharedConn, nil } func getEnv() (pgAddr, pgUser, pgPwd, pgDb string) { pgAddr = os.Getenv("PG_ADDR") pgUser = os.Getenv("PG_USER") pgPwd = os.Getenv("PG_PWD") pgDb = os.Getenv("PG_DB") if pgAddr == "" { pgAddr = "localhost:5432" } if pgUser == "" { pgUser = "postgres" } if pgPwd == "" { pgPwd = "postgres" } if pgDb == "" { pgDb = "postgres" } return } func createConnection() error { pgAddr, pgUser, pgPwd, pgDb := getEnv() connString := fmt.Sprintf("postgresql://%s:%s@%s/%s", pgUser, pgPwd, pgAddr, pgDb) newConn, err := sql.Open("pgx", connString) if err != nil { log.Critf("[createConnection] cannot create connection to PostgreSQL: %s", err.Error()) return err } var version int err = newConn.QueryRow(`select current_setting('server_version_num');`).Scan(&version) if err != nil { log.Critf("[createConnection] cannot get PostgreSQL version: %s", err.Error()) return err } sharedConn = &PGConn{ client: newConn, lastTimeAccess: time.Now(), version: version, callTimeout: 30, } return nil }