Golang學習系列第四天：操作資料庫PostgreSQL

来源:https://www.cnblogs.com/dongguangming/archive/2020/07/18/13334302.html
-Advertisement-
Play Games

繼Golang學習系列第三天https://www.cnblogs.com/dongguangming/p/13311198.html：數組、切片、Map、結構體、指針、函數、介面類型、channel通道，今天開始學習golang操作資料庫，以PostgreSQL為例。 0. 安裝PostgreSQ ...


 

      繼Golang學習系列第三天https://www.cnblogs.com/dongguangming/p/13311198.html：數組、切片、Map、結構體、指針、函數、介面類型、channel通道，今天開始學習golang操作資料庫，以PostgreSQL為例。

 

0.  安裝PostgreSQL 資料庫

可以參考PostgreSQL官網https://www.postgresql.org/download/linux/redhat/安裝該資料庫

特別需要說明的是，安裝完成後，自動建立了一個名為postgres的用戶，預設密碼為空；同時也自動創建了一個名字叫postgres的資料庫。

0.1、修改預設生成的資料庫用戶postgres的密碼。

修改PostgreSQL用戶密碼​

把密碼設置為12345678.

0.2  創建示例資料庫

測試資料庫名可以自取，

示例資料庫​

然後建一張測試表讓golang使用

CREATE TABLE users (
    id serial PRIMARY KEY,
    email VARCHAR (355) UNIQUE NOT NULL,
    password VARCHAR (50) NOT NULL
);

insert into users(id,email,password) values(1,'1056764180@qq,com','12345678');
insert into users(id,email,password) values(2,'10567@qq,com','1234567890');
insert into users(id,email,password) values(3,'10567567@qq,com','12345678908');

0.3  開啟遠程訪問

由於資料庫和應用程式不在同一機器上，故資料庫要開啟遠程訪問功能

修改配置文件，即

vim /var/lib/pgsql/12/data/postgresql.conf

找到listen_adderess配置項設為*

​

繼續修改另一配置文件，即

vim /var/lib/pgsql/12/data/pg_hba.conf

 在# IPv4 local connections:處追加客戶端的連接信息

​

重啟postgresql服務

systemctl restart postgresql-12

最後客戶端測試連接

 ​

 

1.   golang操作資料庫

連接資料庫會使用第三方驅動包，由於牆的緣故，可以先設置一下代理

go env -w GO111MODULE=on
go env -w GOPROXY=https://mirrors.aliyun.com/goproxy/,direct

就以基本的增刪改查數據，記錄如何使用go操作資料庫

1. 1  Select查詢數據

新建postgres.go項目，鍵入以下測試連接資料庫的代碼

package main

import (
	"database/sql"
	"fmt"
	"log"
	_ "github.com/lib/pq"
    //_ "github.com/bmizerany/pq"
        
)

const (
	// TODO fill this in directly or through environment variable
	// Build a DSN e.g. postgres://username:[email protected]:5432/dbName
	DB_DSN = "postgres://postgres:[email protected]:5432/douyin?sslmode=disable"
)

type User struct {
	ID       int
	Email    string
	Password string
}

func main() {

	// Create DB pool
	//db, err := sql.Open("postgres", "host=192.168.8.200 port=5432 user=postgres password=12345678 dbname=douyin sslmode=disable")
	db, err := sql.Open("postgres",DB_DSN)
        if err != nil {
		log.Fatal("Failed to open a DB connection: ", err)
	}
	defer db.Close()

	// Create an empty user and make the sql query (using $1 for the parameter)
	var myUser User
	userSql := "SELECT id, email, password FROM users WHERE id = $1"

	err = db.QueryRow(userSql, 1).Scan(&myUser.ID, &myUser.Email, &myUser.Password)
	if err != nil {
		log.Fatal("Failed to execute query: ", err)
	}

	fmt.Printf("你好 郵箱：%s, 密碼：%s,  歡迎回來!\n", myUser.Email, myUser.Password)
}

然後創建一個模塊依賴文件

go mod init  pluginModel

安裝具體的依賴包

go get github.com/lib/pq

 

 最後運行測試代碼

[root@master goworkspace]# go run postgres.go

 從資料庫查詢id等於1的記錄，如圖

​

和資料庫里的數據是對應的

​

 

1.2   增加數據

接上1.1示例代碼，稍作更改即可，文件命名為postgres-create.go

package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/lib/pq"
        //_ "github.com/bmizerany/pq"
        
)

const (
	// TODO fill this in directly or through environment variable
	// Build a DSN e.g. postgres://username:[email protected]:5432/dbName
	DB_DSN = "postgres://postgres:[email protected]:5432/douyin?sslmode=disable"
)

type User struct {
	ID       int
	Email    string
	Password string
}

func main() {
	// Create DB pool
	//db, err := sql.Open("postgres", "host=192.168.8.200 port=5432 user=postgres 
    password=12345678 dbname=douyin sslmode=disable")
	db, err := sql.Open("postgres",DB_DSN)
        if err != nil {
		log.Fatal("Failed to open a DB connection: ", err)
	}
	defer db.Close()
    
    //創建一個用戶，預要插入到資料庫里
    var user User = User{ID:4,Email:"[email protected]",Password:"1234567890"}
    //執行插入操作
    _, err = db.Exec("INSERT INTO users (id,email,password) VALUES($1,$2,$3)", 
    user.ID,user.Email,user.Password)
    if err != nil {
        log.Fatal(err)
    }
    //列印日誌
    log.Printf("create ok!!!")

	//測試數據是否插入成功，執行具體的查詢語句
	var myUser User
	userSql := "SELECT id, email, password FROM users WHERE id = $1"
    
    //設置查詢參數為4，即創建數據時的ID值
	err = db.QueryRow(userSql, 4).Scan(&myUser.ID, &myUser.Email, 
    &myUser.Password)
	if err != nil {
		log.Fatal("Failed to execute query: ", err)
	}
    
    //輸出查詢結果
	fmt.Printf("hello email: %s, password: %s, welcome back!\n", 
    myUser.Email,myUser.Password)

}

執行程式代碼，輸出結果

​

 

1.3  update修改數據

接上1.2示例代碼，稍作更改即可，文件命名為postgres-update.go

package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/lib/pq"
        //_ "github.com/bmizerany/pq"
        
)

const (
	// TODO fill this in directly or through environment variable
	// Build a DSN e.g. postgres://username:[email protected]:5432/dbName
	DB_DSN = "postgres://postgres:[email protected]:5432/douyin?sslmode=disable"
)

type User struct {
	ID       int
	Email    string
	Password string
}

func main() {
	// Create DB pool
	//db, err := sql.Open("postgres", "host=192.168.8.200 port=5432 user=postgres 
    password=12345678 dbname=douyin sslmode=disable")
	db, err := sql.Open("postgres",DB_DSN)
        if err != nil {
		log.Fatal("Failed to open a DB connection: ", err)
	}
	defer db.Close()
    
    //創建一個用戶，預要通過主鍵更改到資料庫里
    var user User = User{ID:4,Email:"[email protected]",Password:"abcdedf120"}
    //執行更改操作
    _, err = db.Exec("UPDATE  users SET email=$1, password=$2 where id=$3", user.Email,user.Password,user.ID)
    if err != nil {
        log.Fatal(err)
    }
    //列印日誌
    log.Printf("update ok!!!")

	//測試數據是否更改成功，執行具體的查詢語句
	var myUser User
	userSql := "SELECT id, email, password FROM users WHERE id = $1"
    
    //設置查詢參數為4，即要更改數據的ID值
	err = db.QueryRow(userSql, 4).Scan(&myUser.ID, &myUser.Email, 
    &myUser.Password)
	if err != nil {
		log.Fatal("Failed to execute query: ", err)
	}
    
    //輸出查詢結果
	fmt.Printf("hello email: %s, password: %s, welcome back!\n", 
    myUser.Email,myUser.Password)

}
 

執行程式代碼，輸出結果

​

 

1.4   delete刪除數據記錄

接上1.3示例代碼，稍作更改即可，文件命名為postgres-delete.go

  
package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/lib/pq"
        //_ "github.com/bmizerany/pq"
        
)

const (
	// TODO fill this in directly or through environment variable
	// Build a DSN e.g. postgres://username:[email protected]:5432/dbName
	DB_DSN = "postgres://postgres:[email protected]:5432/douyin?sslmode=disable"
)

type User struct {
	ID       int
	Email    string
	Password string
}

func main() {
	// Create DB pool
	//db, err := sql.Open("postgres", "host=192.168.8.200 port=5432 user=postgres 
    password=12345678 dbname=douyin sslmode=disable")
	db, err := sql.Open("postgres",DB_DSN)
        if err != nil {
		log.Fatal("Failed to open a DB connection: ", err)
	}
	defer db.Close()
    
    //執行更改操作
    _, err = db.Exec("DELETE FROM  users  where id=$1", 4)
    if err != nil {
        log.Fatal(err)
    }
    //列印日誌
    log.Printf("delete ok!!!")

	//測試數據是否更改成功，執行具體的查詢語句
	var myUser User
	userSql := "SELECT id, email, password FROM users WHERE id = $1"
    
    //設置查詢參數為4，即要更改數據的ID值
	err = db.QueryRow(userSql, 4).Scan(&myUser.ID, &myUser.Email, 
    &myUser.Password)
	if err != nil {
		log.Fatal("Failed to execute query: ", err)
	}
    
    //輸出查詢結果
	fmt.Printf("hello email: %s, password: %s, welcome back!\n", 
    myUser.Email,myUser.Password)
}

執行以上程式代碼，執行輸出結果

​

 

至此到這裡關於golang操作資料庫postgresql就告一段落了，收工。

代碼已上傳到github：https://github.com/dongguangming/golang-learn/tree/master/go-postgresql

註：由於我沒有用可視化編程工具，是用vi編寫的go代碼，請你們自行排版其結構。

 

參考：

    1.  Postgresql 密碼設置 http://www.mamicode.com/info-detail-1977540.html

    2. golang連接postgresql資料庫 https://msd.misuland.com/pd/3181438578597038522

    3. cannot find module providing package github.com/xxx: working directory is not part of a module  https://www.sunzhongwei.com/cannot-find-module-providing-package-githubcomxxx-working-directory-is-not-part-of-a-module

    4. SSL is not enabled on the server https://stackoverflow.com/questions/21959148/ssl-is-not-enabled-on-the-server

    5. Resolve "FATAL:no pg_hba.conf entry for host" Error when you Connect from PGAdmin4 https://www.cisco.com/c/en/us/support/docs/cloud-systems-management/cloudcenter/212585-resolve-fatal-no-pg-hba-conf-entry-for.html

    6. Connect to PostgreSQL and Run a Query https://golangcode.com/postgresql-connect-and-query/

    7. golang postgresql CRUD  https://www.cnblogs.com/ibgo/p/6010245.html 

    8.  


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 011.Nginx防盜鏈
    一 盜鏈 1.1 盜鏈概述 盜鏈指的是在自己的界面展示非本伺服器上的內容，通過技術手段獲得其他伺服器的資源。繞過他人資源展示頁面，在自己頁面向用戶提供此內容，從而減輕自己伺服器的負擔，因為真實的空間和流量來自其他伺服器。 因此，通常為了避免被盜鏈，通常Web伺服器建議配置防盜鏈，其主要防盜鏈思路是能 ...
  • Centos7離線安裝gcc4.8
    有時候CentOS工作在無互聯網的環境下，需要在離線環境下安裝一些組件，這次實現的是模擬在離線環境下安裝gcc4.8。 第一步： 先去http://mirrors.aliyun.com/centos/7/isos/x86_64/下載CentOS7的安裝鏡像。 第二步： 用虛擬機安裝CentOS7 1 ...
  • Porter 進入 CNCF 雲原生全景圖，新版本即將發佈！
    近日，KubeSphere 社區子項目面向物理機環境的負載均衡器 Porter 正式進入 CNCF Landscape。CNCF Landscape 在雲原生實踐過程中的每個環節幫助用戶瞭解有哪些具體的軟體和產品選擇，Porter 進入 CNCF Landscape，意味著 Porter 正式成為了 ...
  • Docker部署LNMP完整教程
    在Docker中部署LNMP環境可以分為以下幾個步驟： 安裝Docker 創建鏡像 創建Dockerfile build Docerfile 複製/修改配置文件 運行鏡像，並映射埠 為了方便分散式部署，Nginx、PHP、MySQL和Web目錄會分別放在4個不同的容器中，最後我們會打包成4個鏡像。 ...
  • Linux ADF(Atomic Display Framework)淺析---概述
    概述 因為工作關係，最近有涉及到ADF(Atomic Display Framework)相關的內容，部分內容來自互聯網 ADF(Atomic Display Framework)是Google新增的Display框架，用來替換Framebuffer。 ADF在Android hwcomposer ...
  • Java應用伺服器之tomcat基礎配置（二）
    connector連接器組件：主要作用負責接收請求，常見的連接器有三種，分別是http連接器，https連接器，和ajp連接器；進入tomcat的請求可分為兩類，一類是來自客戶端瀏覽器的訪問，一類是來自其他web server反代訪問；如果想配置tomcat只能通過代理來訪問，並且不能繞過代理來訪... ...
  • 010.Nginx正反代理
    一 Nginx代理 1.1 Nginx代理概述 nginx是一款自由的、開源的、高性能的HTTP伺服器和反向代理伺服器。同時也是一個IMAP、POP3、SMTP代理伺服器。nginx可以作為一個HTTP伺服器進行網站的發佈處理，同時nginx可以作為反向代理進行負載均衡的實現。 1.2 Nginx代 ...
  • 痞子衡嵌入式：SNVS Master Key僅在i.MXRT10xx Hab關閉時才能用於DCP加解密
    i.MXRT不僅僅是處理性能超強的MCU，也是安全等級極高的MCU。如果大家用過痞子衡開發的一站式安全啟動工具 NXP-MCUBootUtility，應該會從其用戶手冊3.3節中瞭解到i.MXRT支持的幾種安全啟動等級，其中HAB加密啟動方式和BEE/OTFAD加密啟動方式中都提及了一種神秘的密鑰 ... ...
一周排行
    -Advertisement-
    Play Games
  • GoF之工廠模式
    GoF之工廠模式 @目錄GoF之工廠模式每博一文案1. 簡單說明“23種設計模式”1.2 介紹工廠模式的三種形態1.3 簡單工廠模式（靜態工廠模式）1.3.1 簡單工廠模式的優缺點:1.4 工廠方法模式1.4.1 工廠方法模式的優缺點:1.5 抽象工廠模式1.6 抽象工廠模式的優缺點：2. 總結:3 ...
  • dotnet C# 簡單的追加文件夾到 ZipArchive 壓縮文件的方法
    新改進提供的Taurus Rpc 功能，可以簡化微服務間的調用，同時可以不用再手動輸出模塊名稱，或調用路徑，包括負載均衡，這一切，由框架實現並提供了。新的Taurus Rpc 功能，將使得服務間的調用，更加輕鬆、簡約、高效。 ...
  • Elasticsearch 系列（六）- ES數據同步和ES集群
    本章將和大家分享ES的數據同步方案和ES集群相關知識。廢話不多說，下麵我們直接進入主題。 一、ES數據同步 1、數據同步問題 Elasticsearch中的酒店數據來自於mysql資料庫，因此mysql數據發生改變時，Elasticsearch也必須跟著改變，這個就是Elasticsearch與my ...
  • 自動化測試數據生成：Asp.Net Core單元測試利器AutoFixture詳解
    引言 在我們之前的文章中介紹過使用Bogus生成模擬測試數據，今天來講解一下功能更加強大自動生成測試數據的工具的庫"AutoFixture"。 什麼是AutoFixture? AutoFixture 是一個針對 .NET 的開源庫，旨在最大程度地減少單元測試中的“安排（Arrange）”階段，以提高 ...
  • .NET Emit 入門教程：第七部分：實戰項目1：將 DbDataReader 轉實體
    經過前面幾個部分學習，相信學過的同學已經能夠掌握 .NET Emit 這種中間語言，並能使得它來編寫一些應用，以提高程式的性能。隨著 IL 指令篇的結束，本系列也已經接近尾聲，在這接近結束的最後，會提供幾個可供直接使用的示例，以供大伙分析或使用在項目中。 ...
  • Windows下綁定線程到指定的CPU核心
    當從不同來源導入Excel數據時，可能存在重覆的記錄。為了確保數據的準確性，通常需要刪除這些重覆的行。手動查找並刪除可能會非常耗費時間，而通過編程腳本則可以實現在短時間內處理大量數據。本文將提供一個使用C# 快速查找並刪除Excel重覆項的免費解決方案。 以下是實現步驟： 1. 首先安裝免費.NET ...
  • mORMot 1.18 第07章 簡單的讀寫操作
    C++ 異常處理 C++ 異常處理機制允許程式在運行時處理錯誤或意外情況。它提供了捕獲和處理錯誤的一種結構化方式，使程式更加健壯和可靠。 異常處理的基本概念： 異常: 程式在運行時發生的錯誤或意外情況。 拋出異常: 使用 throw 關鍵字將異常傳遞給調用堆棧。 捕獲異常: 使用 try-catch ...
  • mORMot 1.18 第06章 概念
    優秀且經驗豐富的Java開發人員的特征之一是對API的廣泛瞭解，包括JDK和第三方庫。 我花了很多時間來學習API，尤其是在閱讀了Effective Java 3rd Edition之後 ，Joshua Bloch建議在Java 3rd Edition中使用現有的API進行開發，而不是為常見的東西編 ...
  • php 開發規範
    框架 · 使用laravel框架，原因：tp的框架路由和orm沒有laravel好用 · 使用強制路由，方便介面多時，分多版本，分文件夾等操作 介面 · 介面開發註意欄位類型，欄位是int，查詢成功失敗都要返回int（對接java等強類型語言方便） · 查詢介面用GET、其他用POST 代碼 · 所 ...
  • 2024 年 4 月 28 日 周日 晴 熱（1253 字）
    正文 下午找企業的人去鎮上做貸後。 車上聽同事跟那個司機對罵，火星子都快出來了。司機跟那同事更熟一些，連我在內一共就三個人，同事那一手指桑罵槐給我都聽愣了。司機也是老社會人了，馬上聽出來了，為那個無辜的企業經辦人辯護，實際上是為自己辯護。 “這個事情你不能怪企業。”“但他們總不能讓銀行的人全權負責， ...
所有分類