golang postgresql CRUD

package main

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

    _ "github.com/lib/pq" // postgres driver
)

// People - database
type People struct {
    id   int
    name string
    age  int
}

type appContext struct {
    db *sql.DB
}

// ConnectDB connect specify database
func connectDB(driverName string, dbName string) (c *appContext, errorMessage string) {
    db, err := sql.Open(driverName, dbName)
    if err != nil {
        return nil, err.Error()
    }
    if err = db.Ping(); err != nil {
        return nil, err.Error()
    }
    return &appContext{db}, ""
}

// Create
func (c *appContext) Create() {
    // get insert id
    lastInsertId := 0
    err := c.db.QueryRow("INSERT INTO users(name,age) VALUES($1,$2) RETURNING id", "jack", 22).Scan(&lastInsertId)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("inserted id is ", lastInsertId)
}

// Read
func (c *appContext) Read() {
    rows, err := c.db.Query("SELECT * FROM users")

    if err != nil {
        fmt.Println(err.Error())
        return
    }
    defer rows.Close()

    for rows.Next() {
        p := new(People)
        err := rows.Scan(&p.id, &p.name, &p.age)
        if err != nil {
            fmt.Println(err)
        }
        fmt.Println(p.id, p.name, p.age)
    }
}

// UPDATE
func (c *appContext) Update() {
    stmt, err := c.db.Prepare("UPDATE users SET age = $1 WHERE id = $2")
    if err != nil {
        log.Fatal(err)
    }
    result, err := stmt.Exec(10, 1)
    if err != nil {
        log.Fatal(err)
    }
    affectNum, err := result.RowsAffected()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("update affect rows is ", affectNum)
}

// DELETE
func (c *appContext) Delete() {
    stmt, err := c.db.Prepare("DELETE FROM users WHERE id = $1")
    if err != nil {
        log.Fatal(err)
    }
    result, err := stmt.Exec(1)
    if err != nil {
        log.Fatal(err)
    }
    affectNum, err := result.RowsAffected()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("delete affect rows is ", affectNum)
}

// Mypg - Postgresql CRUD
func main() {
    c, err := connectDB("postgres", "user=user1 password=password1 dbname=exampledb")
    defer c.db.Close()

    if err != "" {
        print(err)
    }

    c.Create()
    fmt.Println("add action done!")

    c.Read()
    fmt.Println("get action done!")

    c.Update()
    fmt.Println("update action done!")

    c.Delete()
    fmt.Println("delete action done!")
}
时间: 2024-08-06 20:07:00

golang postgresql CRUD的相关文章

golang sqlite3 CRUD

pacakge mainimport ( "database/sql" "fmt" "log" _ "github.com/mattn/go-sqlite3" // sqlite3 dirver ) // People have database fields type People struct { id int name string age int } type appContext struct { db *sql.D

postgresql一般crud存储过程参考[转]

http://blog.csdn.net/cdnight/article/details/18082255 这里是一份经过再三调试测试而成功的postgres数据库单表crud存储过程,请注意,对于多结果的返回方式,请查看 getPageByCondition的书写方式,用的是refcursor,返回一个cursor,同时可以返回其他out,inout参数,但是 refcursor必须在事务中调用,所以java端的调用过程需要注意,好吧,我同时放出一份dal样板,大家可以直接copy来用. 1

golang自己定义数据类型查询与插入postgresql中point数据

golang自己定义数据类型查询与插入postgresql中point数据 详细代码例如以下: package main import ( "bytes" "database/sql" "database/sql/driver" "fmt" _ "github.com/lib/pq" "strconv" "strings" ) // 自己定义支持类型 type Poi

golang自定义数据类型查询与插入postgresql中point数据

golang自定义数据类型查询与插入postgresql中point数据 具体代码如下: package main import ( "bytes" "database/sql" "database/sql/driver" "fmt" _ "github.com/lib/pq" "strconv" "strings" ) // 自定义支持类型 type Point s

postgreSQL第一天——关系、CRUD和联接

创建表: CREATE TABLE countries( country_code char(2) PRIMARY KEY, country_name text UNIQUE ); 插入数据: INSERT INTO countries(country_code,country_name) VALUES ('us','United States'),('mx','Mexico'),('au','Australia'), ('gb','United Kingdom'),('de','Gemany'

golang(3):beego CRUD demo (1)

本文的原文连接是: http://blog.csdn.net/freewebsys/article/details/46699343 转载请一定注明出处! 1,beego 自带crud生成工具 工具执行非常简单: bee generate scaffold post -fields="title:string,body:text" 设置模块post,里面的fileds有两个 title 和body. bee generate scaffold post -fields="ti

golang 下 mongodb 与 postgresql 插入速度的测试

近期看了篇文章,说是postgresql也支持nosql,定义了专属的jsonb数据类型,而且速度比mongodb还快,今天验证了下,同样的数据,postgre的插入速度只是mongo 的三分一不到.有可能是各自的驱动造成的. 数据结构: type StockDay struct { Date int32 O, H, L, C, V, A float32 } mongo 用了mgo 包,插入代码如下: func ReadHq(conn net.Conn, c *mgo.Collection, C

Go语言(golang)开源项目大全

转http://www.open-open.com/lib/view/open1396063913278.html内容目录Astronomy构建工具缓存云计算命令行选项解析器命令行工具压缩配置文件解析器控制台用户界面加密数据处理数据结构数据库和存储开发工具分布式/网格计算文档编辑器Encodings and Character SetsGamesGISGo ImplementationsGraphics and AudioGUIs and Widget ToolkitsHardwareLangu

Hibernate(4)——主键生成策略、CRUD 基础API区别的总结 和 注解的使用

俗话说,自己写的代码,6个月后也是别人的代码……复习!复习!复习!涉及的知识点总结如下: hibernate的主键生成策略 UUID 配置的补充:hbm2ddl.auto属性用法 注解还是配置文件 hibernate注解的基本用法 使用Session API CRUD操作对象,以及对象状态的转换 hibernate缓存的概念 get()/load()的区别到底是什么,源码分析 代理模式实现的懒加载 saveOrUpdate()/merge()的区别 Assigned(常用,一般情况使用很方便):