go语言 xorm框架 postgresql 的用法及详细注解
作者:fwhezfwhez 发布时间:2024-04-25 15:26:45
标签:go,xorm,postgresql
xorm用于在golang中链接数据库,并完成增删改差操作,不管是orm还是raw方式都十分的新颖简单。
sql语句
postgresql pgadmin
/*表结构*/
CREATE TABLE public.user
(
id serial primary key,
name varchar(20)
);
ALTER TABLE public.user ADD COLUMN created timestamp default now();
ALTER TABLE public.user ADD COLUMN class_id integer default 1;
insert into public.user(name) values('ft');
insert into public.user(name) values('ft2');
insert into public.user(name,class_id) values('ft8',2)
CREATE TABLE public.class
(
id serial primary key,
name varchar(20)
);
insert into public.class(name) values('高中一班');
insert into public.class(name) values('高中二班');
/*常用到的操作*/
select * from public.class;
select * from public.user;
select u.id,u.name,c.name from public.user as u left join public.class as c on u.class_id=c.id;
main.go
每个功能都使用了if语句来方便开关,测试那块就打开哪块~~~
package main
import (
_ "github.com/lib/pq"
"github.com/xormplus/xorm"
"fmt"
"time"
"strconv"
)
//用户表结构
type User struct {
Id int `xorm:"not null pk autoincr INTEGER"`
Name string `xorm:"VARCHAR(20)"`
Created time.Time `xorm:"default 'now()' DATETIME"`
ClassId int `xorm:"default 1 INTEGER"`
}
//Class表结构
type Class struct {
Id int `xorm:"not null pk autoincr INTEGER"`
Name string `xorm:"VARCHAR(20)"`
}
//临时表结构
type UserClass struct{
User `xorm:"extends"`
Name string
}
//此方法仅用于orm查询时,查询表认定
func (UserClass) TableName() string {
return "public.user"
}
func main() {
//1.创建db引擎
db, err := xorm.NewPostgreSQL("postgres://postgres:123@localhost:5432/test?sslmode=disable")
if err != nil {
fmt.Println(err)
}
//2.显示sql语句
db.ShowSQL(true)
//3.设置连接数
db.SetMaxIdleConns(2000)
db.SetMaxOpenConns(1000)
cacher := xorm.NewLRUCacher(xorm.NewMemoryStore(), 500)//缓存的条数
db.SetDefaultCacher(cacher)
//4.执行插入语句的几种方式
//4.1 orm插入方式:不好控制,如果仅仅插入的对象的属性是name='ftq',那么其他的零值会一同insert,orm方式对零值的处理有点不太好
if false {
user := new(User)
user.Name = "ftq"
_, err = db.Insert(user)
if err != nil {
fmt.Println(err)
}
}
//4.2 命令插入方式
//4.2.1 db.Exec():单事务单次提交
if false{
sql:="insert into public.user(name) values(?)"
db.Exec(sql,"ft4")
}
//4.2.2 db.SQL().Execute():单事务准备了Statement处理sql语句
if false{
sql:="insert into public.user(name) values(?)"
db.SQL(sql,"ft5").Execute()
}
//4.2.3使用sql配置文件管理语句,两种载入配置的方式LoadSqlMap()和RegisterSqlMap(),以及SqlMapClient()替代SQL()
if false {
err = db.LoadSqlMap("./sql.xml")
//err = db.RegisterSqlMap(xorm.Xml("./","sql.xml"))
if err != nil {
fmt.Println(err)
}
db.SqlMapClient("insert_1","ft7").Execute()
}
//5.执行查询的几种方式
//5.1 orm查询:在user初始化的时候,该orm查询直接通过扫描user类型确定表名;组合使用Where(),Get()
if false {
user := new(User)
boolget ,err2 :=db.Where("id=?",5).Get(user)
fmt.Println(boolget,err2,user)
}
//5.2 orm查询:组合使用Where(),Get(),And()
if false {
user := new(User)
boolget ,err2 :=db.Where("id=?",5).And("name=?","ft7").And("id>?",3).Get(user)
fmt.Println(boolget,err2,user)
}
//5.3 orm查询: AllCols()查询所有列,Cols()查询部分列,Find()解析多行结果,Get()解析单行结果
if false {
users := new ([]User)
err = db.AllCols().Find(users)
//err = db.Cols("id","name").Find(users)
if err !=nil {
fmt.Println(err)
}
fmt.Println(users)
}
//5.4 orm查询:连接查询Join()
if false {
users := new([]UserClass)
db.Join("INNER","class","user.class_id=class.id").Find(users)
//db.SQL("select u.id,u.name,c.name from public.user as u left join public.class as c on u.class_id=c.id").Find(users)
fmt.Println(users)
}
//5.5 sql查询略
if false {
//和insert类似,Find查找多行结果,Get获取 单行结果
users := new([]UserClass)
db.SQL("select u.id,u.name,c.name from public.user as u left join public.class as c on u.class_id=c.id").Find(users)
fmt.Println(users)
}
//5.6 链式查找
if false {
//值得一提的是,支持查找某行的某个字段,不过一般在sql语句中就可以完成过滤,如果sql语句过于复杂,可以链式查找过滤
id := db.SQL("select * from public.user").Query().Results[0]["id"]
fmt.Println(id)
}
//6.执行更新
//6.1 ORM方式: 只有非0值的属性会被更新,user的id和created都是默认零值,不被处理
if false {
user :=new(User)
user.Name="ftx"
//[xorm] [info] 2018/02/08 12:04:01.330624 [SQL] UPDATE "user" SET "name" = $1 WHERE "id"=$2 []interface {}{"ftx", 4}
db.Id(4).Update(user)
}
//6.2 SQL方式略,和insert类似
//7.事务
//7.1简单事务
if false {
session :=db.NewSession()
defer session.Close()
session.Begin()
//业务:新添加学生,并且创建新的班级,如果班级因为主键冲突创建失败,则整个事务回滚
_,err =session.SQL("insert into public.user(name,class_id) values('ft13',2)").Execute()
//表中已经有id=3的班级了
_,err =session.SQL("insert into public.class(id,name) values(3,'高中3班')").Execute()
if err!=nil {
session.Rollback()
}
session.Commit()
}
//7.2嵌套事务
if false {
session := db.NewSession()
defer session.Close()
session.Begin()
_,err=session.Exec("insert into public.user(name,class_id) values('ft23',2)")
if err!=nil {
session.Rollback()
}
_,err=session.Exec("insert into public.user(id,name,class_id) values(1,'ft24',2)")
if err!=nil {
session.Rollback()
}
tx,_:=session.BeginTrans()
_,err=tx.Session().Exec("insert into public.user(name,class_id) values('ft25',2)")
if err!=nil {
tx.RollbackTrans()
}
tx.CommitTrans()
session.Commit()
}
//8.缓存:使用Raw方式修改以后,需要清理缓存
if true {
//建立500条数据
session := db.NewSession()
defer session.Close()
if false {
session.Begin()
for i := 30; i < 530; i++ {
value := "ft" + strconv.Itoa(i)
_, err = session.Exec("insert into public.user(name) values(?)", value)
if err != nil {
session.Rollback()
}
}
session.Commit()
}
//查询前531条数据,并随意输出其中一条
users := make([]User,10)
db.SQL("select * from public.user where id<531 order by id").Find(&users)
fmt.Println("读第一遍:","id:",users[50].Id,"name:",users[50].Name)
db.SQL("select * from public.user where id<531 order by id").Find(&users)
fmt.Println("读第二遍:","id:",users[50].Id,"name:",users[50].Name)
var step int =1
stepString := users[50].Name + strconv.Itoa(step)
session.Exec("update public.user set name=? where id =45",stepString)
//清理缓存
db.ClearCache(new(User))
time.Sleep(5*time.Second)
session.SQL("select * from public.user where id<531 order by id").Find(&users)
fmt.Println("读第三遍:","id:",users[50].Id,"name:",users[50].Name)
//虽然很不好意思,但是就算开启了缓存数据也是脏了
}
//9.读写分离
if false {
//假设有多台服务器用来响应客户的读请求
var dbGroup *xorm.EngineGroup
conns :=[]string {
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
}
//负载均衡策略:(特性自行百度)
// 1.xorm.RandomPolicy()随机访问负载均衡,
// 2.xorm.WeightRandomPolicy([]int{2, 3,4})权重随机负载均衡
// 3.xorm.RoundRobinPolicy() 轮询访问负载均衡
// 4.xorm.WeightRoundRobinPolicy([]int{2, 3,4}) 权重轮训负载均衡
// 5.xorm.LeastConnPolicy()最小连接数负载均衡
dbGroup, err = xorm.NewEngineGroup("postgres", conns, xorm.RoundRobinPolicy())
//dbGroup使用方法和db一致
//简单查询
dbGroup.SQL("inser into public.users(name) values('ft2000')").Execute()
dbGroup.Exec("inser into public.users(name) values('ft2001')")
//事务查询
session :=dbGroup.NewSession()
defer session.Close()
session.Begin()
_,err = session.Exec("inser into public.users(name) values('ft2001')")
if err!=nil {
session.Rollback()
}
session.Commit()
}
}
//注意:
//1.postgresql好像不会默认按id增长排序,所以书写sql语句要提前写好order by id ,楼主没怎么写,咳咳
//2. [5.4] postgresql建表会建在public策略的table里,所以查询语句表明写的是public.xxxx,这也造成了连表orm查询会发生前缀报错,比如变成了"SELECT * FROM "public"."user" INNER JOIN "class" ON user.class_id=class.id 这和内部的split有关,
//3.[8.]带的缓存好像很容易失效,在创建500个数据后,经过查查改查的操作,查询到的结果是一样的始终是一样的,本来改值之后应该最后一遍查会变化,然而并没有,缓存功能即使清理了缓存,还是会读到脏的
补充:golang xorm框架对应pg数据库字段类型参照表
1.左边是golang字段类型,右边是pg数据库字段类型
int integer
time.Time timestamp
int8 smallint
float64 numeric(8,3) (只要是numeric统统使用float64)
string text
string varchar
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。如有错误或未考虑完全的地方,望不吝赐教。
来源:https://blog.csdn.net/fwhezfwhez/article/details/79291492
![](https://www.aspxhome.com/images/zang.png)
![](https://www.aspxhome.com/images/jiucuo.png)
猜你喜欢
- 一、前言越来越多的网站和App开始为用户搭建签到系统,以此来吸引和留住用户。签到系统是一种轻量、互动性强的营销方式,通过用户签到获取免费权益
- 插件说明:插件根据提供的10位ISBN书号,在Amazon网站上查找该图书的详细信息。如果找到结果,则返回一个两元素的数组,其中第一个元素是
- 在上一章我们学习了 异常的三个关键字,分别是try、except 以及 finally。我们知道在 try 代码块中如果遇到错误就会抛出异常
- 上次版本如果在没有找到轮廓或轮廓的点集数很小无法拟合椭圆或在RANSAC中寻找最优解时会死循环中,优化后的代码import cv2impor
- 目录1.爬虫文件2.items.py3.pipelines.py4.进行持久化存储之前我们使用lxml对梨视频网站中的视频进行了下载,感兴趣
- 1、实现目标编写一个命令行通讯录程序,可以添加、查询、删除通讯录好友及电话2、实现方法创建一个类来表示一个人的信息。使用字典存储每个人的对象
- 本文实例为大家分享了js实现简易计算器的具体代码,供大家参考,具体内容如下最近,博主闲来无聊,就没事用js写了个简易计算器(博主是搞后端的,
- 1、自动化代码中,用到了哪些设计模式?单例设计模式工厂模式PO设计模式数据驱动模式面向接口编程设计模式2、什么是断言( Assert) ?断
- 方法一、使用os模块的system方法:os.system(cmd),其返回值是shell指令运行后返回的状态码,int类型,0表示shel
- 中文文本中可能出现的标点符号来源比较复杂,通过匹配等手段对他们处理的时候需要格外小心,防止遗漏。以下为在下处理中文标点的时候采用的两种方法:
- python实现MySQL指定表增量同步数据到clickhouse,脚本如下:#!/usr/bin/env python3# _*_ cod
- 本文实例讲述了PHP依赖注入原理与用法。分享给大家供大家参考,具体如下:引言依然是来自到喜啦的一道面试题,你知道什么是依赖注入吗?依赖注入(
- 打开cmder1.移动到D盘输入命令:D:2.创建文件夹λ mkdir myApp3.创建python自带的虚拟环境λ python -m
- Python中的最大整数Python中可以通过sys模块来得到int的最大值. python2中使用的方法是import sysmax =
- 本文实例为大家分享了wxPython实现计算器的具体代码,供大家参考,具体内容如下# -*- coding: utf-8 -*-######
- 所谓匿名函数,即是不需要定义函数,像表达式一样使用,不需要函数名(很多时候名字让我很困扰),一些简单的函数简单化, 举个例子我需要两个整数相
- blankzheng的blog:http://www.planabc.net/1、使用fieldset和legend标签在form中,我们经
- 目录1、typing介绍2、typing的作用3、常用类型3.1 代码示例4、typing模块的其他用法4.1 类型别名4.2 NewTyp
- 表单验证做网站程序多多少少都会碰到,其中emai地址的合法性验证也算是一个典型的例子,网页表单的验证我们一般是先在客户端使用javascri
- 本文为大家分享了如何用Navicat把csv数据导入mysql,供大家参考,具体内容如下1.获取csv数据,用office另存为功能把exc