package config
?
import (
?? ?"io/ioutil"
?? ?"os"
?? ?"fmt"
?? ?"encoding/json"
)
?
type Pgsql struct {
?? ?//Pgsql賬號
?? ?Username string `json:"username"`
?? ?//Pgsql密碼
?? ?Password string `json:"password"`
?? ?//Pgsql地址
?? ?Address string `json:"address"`
?? ?//Pgsql端口
?? ?Port int `json:"port"`
?? ?//數(shù)據(jù)庫名稱
?? ?Database string `json:"database"`
?? ?//表名稱
?? ?Table string `json:"table"`
?? ?//賬號字段名稱
?? ?AccountField string `json:"accountField"`
?? ?//密碼字段名稱
?? ?PwdField string `json:"pwdField"`
}
?
?
//配置文件路徑
var ConfigPath string = "config/config.json"
?
// pgsql配置信息緩存
var PgsqlData *Pgsql
?
?
func Init() {
?? ?//初始化配置對象
?? ?PgsqlData = new(Pgsql)
?? ?//讀取配置文件
?? ?file, err := os.Open(ConfigPath)
?? ?if err != nil {
?? ??? ?fmt.Println("config path:", err)
?? ??? ?os.Exit(1)
?? ?}
?? ?bytes, err := ioutil.ReadAll(file)
?? ?if err != nil {
?? ??? ?fmt.Println("config file:", err)
?? ??? ?os.Exit(1)
?? ?}
?? ?//使用json轉(zhuǎn)換至config對象中
?? ?err = json.Unmarshal(bytes, PgsqlData)
?? ?if err != nil {
?? ??? ?fmt.Println("json unmarshal:", err)
?? ??? ?os.Exit(1)
?? ?}
}

{
? ? "username": "***",
? ? "password": "*********",
? ? "address": "localhost",
? ? "port": 5432,
? ? "database": "***",
? ? "table": "***",
? ? "accountField": "***",
? ? "pwdField": "***"
}

package handle
 
import (
    "database/sql"
    "errors"
    "fmt"
    "pgsql/config"
    _ "github.com/lib/pq"
)
 
func Executl() error {
    config.Init()
    if config.PgsqlData != nil {
        //創(chuàng)建mysql連接
        db, err := sql.Open("postgres", fmt.Sprintf("host=%s port=%d user=%s password=%s dbname=%s sslmode=disable", config.PgsqlData.Address, config.PgsqlData.Port, config.PgsqlData.Username, config.PgsqlData.Password, config.PgsqlData.Database))
        if err != nil {
            return err
        }
        defer db.Close()
        str := fmt.Sprintf("select %s,%s from %s where NAME='%s'", config.PgsqlData.AccountField, config.PgsqlData.PwdField, config.PgsqlData.Table, config.PgsqlData.Username)
        rows := db.QueryRow(str)
        var name *sql.NullString
        var pwd *sql.NullString
        err = rows.Scan(&name, &pwd)
        if err != nil {
            return err
        }
        if name.String == "" || pwd.String == "" {
            return errors.New("data is null")
        }
        fmt.Println("name:",name.String)
        fmt.Println("passwd:",pwd.String)
        return nil
    }
    return errors.New("open config file failed")
}

package main
 
import (
    "pgsql/handle"
    "os"
)
 
func main() {
    err := handle.Executl()
    if err != nil {
        os.Exit(1)
    }
}