golang与pgsql交互的实现

目录

• 1、目的
• 2、代码架构
• 3、代码展示

1、目的

通过读取配置文件获取pgsql用户名和密码及数据库和数据表，从而读取所需字段值。

2、代码架构

• config/config.go:读取配置文件信息
• config/config.json:配置文件
• handle/handle.go:与pgsql数据库交互，获取所需数据
• main.go：主函数

3、代码展示

config.go

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"`
 //数python据库名称
 Database string `json:"database"`
 //表名称
 Table string `json:"table"`
 //账号字段名称
 AccountField string `json:"accountField"`
 //密码字段名称
 PwdField string `json:"开发者_Go入门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转换至config对象中
 err = json.Unmarshal(bytes, PgsqlData)
 if err != nil {
  fmt.Println("json unmarshal:", err)
  os.Exit(1)
 }
}

config.json

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

handle.go

package handle
 
import (
    "database/sql"
    "errors"
    "fmt"
    "pgsql/config"
    _ "github.com/lib/pq"
)
 
func Executl() error {
    config.Init()
    if config.PgsqlData != nil {
        //创建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 fro编程m %s where NAME='%s'", config.Phttp://www.devze.comgsqlData.AccountField, config.PgsqlData.PwdField, config.PgsqlData.Table, config.PgsqlData.jsUsername)
        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")
}

main.go

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

到此这篇关于golang与pgsql交互的实现的文章就介绍到这了,更多相关golang pgsql交互内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！