Beego中ORM操作各类数据库连接方式详细示例

目录
  • beego中各类数据库连接方式
    • 1.1 orm使用方式
      • a. 注册数据库驱动程序
      • b.注册数据库
      • c. 注册模型
    • 1.2 操作示例
      • a. orm连接mysql
      • b. orm连接sqlite3
      • c. orm连接 postgresql
    • 1.3非orm连接方式
      • a. mysql
      • b. sqlite3
      • c. postgresql
      • d. mongodb
      • e.sqlserver
      • f.redis

beego中各类数据库连接方式

beego 框架是优秀得go REST API开发框架。下面针对beego中各类数据库连接操作做一个总结。

orm连接方式

beego中的orm操作支持三种数据库:mysql,sqlite3,postgersql。三种数据库的驱动如下:

import (
    _ "github.com/go-sql-driver/mysql"
    _ "github.com/lib/pq"
    _ "github.com/mattn/go-sqlite3"
)

对于以上三类数据库的使用,最好使用orm进行操作,因为简单的增删查改已经实现了通用的接口封装。无需再根据每一个模型,单独的实现一套增删查改。另外,orm也支持原生sql查询,复杂的sql操作可以直接使用orm.Raw()进行原生查询,简单快捷。

1.1 orm使用方式

a. 注册数据库驱动程序

// 参数1   driverName
// 参数2   数据库类型
// 这个用来设置 driverName 对应的数据库类型
// mysql / sqlite3 / postgres 这三种是默认已经注册过的,所以可以无需设置
orm.RegisterDriver("mysql", orm.DRMySQL)

b.注册数据库

ORM 必须注册一个别名为 default 的数据库,作为默认使用。
ORM 使用 golang 自己的连接池

// 参数1        数据库的别名,用来在 ORM 中切换数据库使用
// 参数2        driverName
// 参数3        对应的链接字符串
orm.RegisterDataBase("default", "mysql", "root:root@/orm_test?charset=utf8")
// 参数4(可选)  设置最大空闲连接
// 参数5(可选)  设置最大数据库连接 (go >= 1.2)
maxIdle := 30
maxConn := 30
orm.RegisterDataBase("default", "mysql", "root:root@/orm_test?charset=utf8", maxIdle, maxConn)

c. 注册模型

orm.RegisterModel(new(User), new(Profile), new(Post))

自此,就可以愉快的使用orm提供的接口进行数据库操作了。

type Ormer interface {
    Read(interface{}, …string) error
    ReadOrCreate(interface{}, string, …string) (bool, int64, error)
    Insert(interface{}) (int64, error)
    InsertMulti(int, interface{}) (int64, error)
    Update(interface{}, …string) (int64, error)
    Delete(interface{}) (int64, error)
    LoadRelated(interface{}, string, …interface{}) (int64, error)
    QueryM2M(interface{}, string) QueryM2Mer
    QueryTable(interface{}) QuerySeter
    Using(string) error
    Begin() error
    Commit() error
    Rollback() error
    Raw(string, …interface{}) RawSeter
    Driver() Driver
}

1.2 操作示例

a. orm连接mysql

import (
	"github.com/astaxie/beego/orm"
	_ "github.com/go-sql-driver/mysql"
)
func init() {
	orm.RegisterDriver("mysql", orm.DRMySQL)
	orm.RegisterDataBase("default", "mysql", "root:root@tcp(192.168.1.1:3306)/ming?charset=utf8")
	orm.RegisterModel(new(User))

	orm.SetMaxIdleConns("default", 10)
	orm.SetMaxOpenConns("default", 100)
}
func Create(param interface{}) (int64, error) {
	return orm.NewOrm().Insert(param)
}
func Update(param interface{}, fields ...string) (int64, error) {
	return orm.NewOrm().Update(param, fields...)
}
func Delete(param interface{}, cols ...string) (int64, error) {
	return orm.NewOrm().Delete(param, cols...)
}
func Read(md interface{}, cols ...string) error {
	return orm.NewOrm().Read(md, cols...)
}

b. orm连接sqlite3

import (
	"github.com/astaxie/beego/orm"
	_ "github.com/mattn/go-sqlite3"
)
func init() {
	orm.RegisterDriver("sqlite3", orm.DRSqlite)
	orm.RegisterDataBase("default", "sqlite3", "conf/sqlite_test.db")
	orm.SetMaxIdleConns("default", 50)
	orm.SetMaxOpenConns("default", 200)
    //设置数据库时区
    //orm.DefaultTimeLoc = time.UTC
	orm.RegisterModel(new(User))
}
func Create(param interface{}) (int64, error) {
	return orm.NewOrm().Insert(param)
}
func Update(param interface{}, fields ...string) (int64, error) {
	return orm.NewOrm().Update(param, fields...)
}
func Delete(param interface{}, cols ...string) (int64, error) {
	return orm.NewOrm().Delete(param, cols...)
}
func Read(md interface{}, cols ...string) error {
	return orm.NewOrm().Read(md, cols...)
}

c. orm连接 postgresql

golang orm可以连接postgres,但是好像不支持数据库中的schema.

import (
	"github.com/astaxie/beego/orm"
	_ "github.com/lib/pq"
)
func init() {
	orm.RegisterDriver("postgres", orm.DRPostgres)
	orm.RegisterDataBase("default", "postgres", "host=192.168.1.1 port=5432 user=root password=root dbname=test sslmode=disable")
	//orm.RegisterModelWithPrefix("schema_name", new(PmPark))
	orm.RegisterModel(new(PmPark))
	orm.SetMaxIdleConns("default", 10)
	orm.SetMaxOpenConns("default", 50)
}

1.3非orm连接方式

使用非orm连接方式,除了mysql,sqlite3,postgresql外,其他的如sqlserver,mongodb,redis等等,都有自己的连接方式。

a. mysql

import (
	"fmt"
	"database/sql"

	_ "github.com/go-sql-driver/mysql"
)
func getMysqlDB() (*sql.DB, error) {
	connectString := "root:123456@tcp(localhost:3306)/test?charset=utf8"

	db, err := sql.Open("mysql", connectString)
	if err != nil {
		return nil, err
	}

	return db, nil
}

b. sqlite3

import (
	"database/sql"
	_ "github.com/mattn/go-sqlite3"
)
func GetDBConn() (*sql.DB, error) {
	return sql.Open("sqlite3", "./data/location.db")
}

c. postgresql

import (
	"database/sql"
	"errors"
	"fmt"
	"time"
	"github.com/astaxie/beego"
	_ "github.com/lib/pq"
)
var (
	host     string = ""
	port     int
	user     string = ""
	password string = ""
	dbname   string = ""
	max_conn  int = 40
	idle_conn int = 10
	postgreConn *sql.DB //全局sql连接,已实现连接池,所以可以只创建一个实例
	DB_CONN_ERROR error
)
func init() {
	host = beego.AppConfig.String("postgres_host")
	port, _ = beego.AppConfig.Int("postgres_port")
	user = beego.AppConfig.String("postgres_user")
	password = beego.AppConfig.String("postgres_password")
	dbname = beego.AppConfig.String("postgres_dbname")
	max_conn = beego.AppConfig.DefaultInt("postgres_max_conn", 50)
	idle_conn = beego.AppConfig.DefaultInt("postgres_idle_conn", 10)
	DB_CONN_ERROR = errors.New("数据库连接失败")
}
func GetPostgresSession() *sql.DB {
	if postgreConn == nil {
		psqlInfo := fmt.Sprintf(`host=%s port=%d user=%s password=%s dbname=%s sslmode=disable`,
			host, port, user, password, dbname)
		db, err := sql.Open("postgres", psqlInfo)
		if err != nil {
			return nil
		}
		db.SetConnMaxLifetime(30 * time.Minute)
		db.SetMaxOpenConns(max_conn)
		db.SetMaxIdleConns(idle_conn)
		//		err = db.Ping()
		//		if err != nil {
		//			return nil
		//		}
		postgreConn = db
	}
	return postgreConn
}

d. mongodb

import (
	"errors"
	"time"
	"github.com/astaxie/beego"
	"gopkg.in/mgo.v2"
)
// 连接mongodb数据库
var (
	MongodbAddr   string = "" //mongodb数据库地址
	MongodbName   string = "" //mongodb数据名称
	MongodbUser   string = "" //mongodb用户名
	MongodbPasswd string = "" //mongodb密码
)
var (
	mongosession *mgo.Session
)
func init() {
	MongodbAddr = beego.AppConfig.String("mongodb_addr")
	MongodbName = beego.AppConfig.String("mongodb_name")
	MongodbUser = beego.AppConfig.String("mongodb_username")
	MongodbPasswd = beego.AppConfig.String("mongodb_passwd")
}
func GetMongoSession() *mgo.Session {
	if mongosession == nil {
		var err error
		if MongodbUser == "" || MongodbPasswd == "" {
			mongosession, err = mgo.Dial(MongodbAddr)
		} else {
			dialInfo := &mgo.DialInfo{
				Addrs:     string{MongodbAddr},
				Direct:    false,
				Timeout:   time.Second * 30,
				Database:  MongodbName,
				Source:    "admin",
				Username:  MongodbUser,
				Password:  MongodbPasswd,
				PoolLimit: 4096, // Session.SetPoolLimit
			}
			mongosession, err = mgo.DialWithInfo(dialInfo)
		}
		if err != nil {
			return nil
		}
	}
	return mongosession.Clone()
}
func WithMongoCollection(collectionName string, s func(*mgo.Collection) error) error {
	session := GetMongoSession()
	if session == nil {
		return errors.New("获取mongodb连接失败")
	}
	defer session.Close()
	c := session.DB(MongodbName).C(collectionName)
	return s(c)
}

e.sqlserver

import (
	"database/sql"
	"time"
	"fmt"
	"github.com/astaxie/beego"
	_ "github.com/denisenkom/go-mssqldb"
)
const (
	CONN_LIVE_TIME = 24 //连接使用时间 小时
)
var (
	db       *sql.DB = nil //全局数据库连接
)
func init() {
	host := beego.AppConfig.String("yr_host")
	port, err := beego.AppConfig.Int("yr_port")
	if err != nil {
		port = 1433
	}
	user := beego.AppConfig.String("user")
	password := beego.AppConfig.String("password")
	dbName := beego.AppConfig.String("name")
	connString := fmt.Sprintf("server=%s;port%d;database=%s;user id=%s;password=%s", host, port, dbName, user, password)
	db, err = sql.Open("mssql", connString)
	if err != nil {
		return
	}
	db.SetMaxOpenConns(200)
	db.SetMaxIdleConns(50)
	db.SetConnMaxLifetime(time.Duration(CONN_LIVE_TIME) * time.Hour)
}

f.redis

import (
	"time"
	"github.com/astaxie/beego"
	"github.com/gomodule/redigo/redis"
)
var (
	db_addr     string = ""
	db_password string = ""
	redisPool *redis.Pool //redis连接池
)
func init() {
	db_addr = beego.AppConfig.String("redis_addr")
	db_password = beego.AppConfig.String("redis_password")
}
//获取Redis连接池
func newRedisPool(server, password string) (*redis.Pool, error) {
	var err error
	return &redis.Pool{
		MaxIdle:     32,
		IdleTimeout: 180 * time.Second,
		Dial: func() (redis.Conn, error) {
			var c redis.Conn
			c, err = redis.Dial("tcp", server)
			if err != nil {
				return nil, err
			}
			if password != "" {
				if _, err = c.Do("AUTH", password); err != nil {
					c.Close()
					return nil, err
				}
			}
			return c, err
		},
		TestOnBorrow: func(c redis.Conn, t time.Time) error {
			_, err := c.Do("PING")
			return err
		},
	}, err
}
/*
获取redis数据库连接
*/
func GetRedisConnection() (redis.Conn, error) {
	if redisPool == nil {
		var err error
		redisPool, err = newRedisPool(db_addr, db_password)
		if err != nil {
			return nil, err
		}
	}
	return redisPool.Get(), nil
}

以上就是Beego中ORM操作各类数据库连接方式详细示例的详细内容,更多关于Beego ORM数据库连接的资料请关注我们其它相关文章!

(0)

相关推荐

  • golang beego框架环境搭建过程

    目录 环境搭建 1.开启gomod设置代理 2.安装beego和bee 3.升级bee 4.zsh: command not found: bee 5.bee相关命令 6.项目启动 7.beego项目结构分析 环境搭建 下载安装beego,bee 1.开启gomod设置代理 go env -w GO111MODULE=on go env -w GOPROXY=https://goproxy.cn 2.安装beego和bee go get -u -v github.com/astaxie/beeg

  • go语言beego框架jwt身份认证实现示例

    目录 一 引入jwt 二 框架中引入jwt 三 使用 一 引入jwt jwt用户身份验证 go get github.com/dgrijalva/jwt-go 二 框架中引入jwt import ( "fmt" "github.com/astaxie/beego" "github.com/dgrijalva/jwt-go" "time" ) 三 使用 声明jwt需要用到的结构体 const ( KEY string = &qu

  • go语言beego框架分页器操作及接口频率限制示例

    目录 获取所有文章数据 获取总条数 设置每页的条数 总页数和当前页码 获取分页数据 返回数据 beego接口频率限制 获取所有文章数据 o := orm.NewOrm() qs := o.QueryTable("Article") 12 获取总条数 count, _ := qs.Count() 1 设置每页的条数 pageSetNum := 2 1 总页数和当前页码 // 总页数 pageCount := math.Ceil((float64(count) / float64(page

  • golang beego框架路由ORM增删改查完整案例

    目录 程序运行前加载 路由设置 高级路由设置 beego-ORM初始化 安装ORM+导包 定义结构体 beego支持的数据库 连接数据库 注册数据库表 生成表 完整案例 ORM增删改查 插入 查询 更新 删除 案例 注册 案例2 程序运行前加载 1.导包前面加下划线,运行前加载 2.把要加载的写在init函数里面 路由设置 路由的作用:根据不同的请求指定不同的控制器 路由函数: beego.Router("/path",&controller.MainController{})

  • go语言beego框架web开发语法笔记示例

    目录 两个跳转语法 模型创建 获取post请求传过来的值 获取字符串 获取文件 获取文件后缀 orm查询表所有数据 前端循环语法 前端格式化时间 前端url传值方式 两个跳转语法 第一个参数是请求路径,第二个参数是http状态码. c.Redirect("/login",400) //重定向 c.TplName = "login.html" 模型创建 设置主键 `pk`设置自增 `auto` 注意:当Field类型为int,int32,int64,uint,uint

  • Go语言框架Beego项目搭建的方法步骤

    1,命令行查看 Go 开发包的环境变量配置信息 命令行说明如下: 第 1 行,执行 go env 指令,将输出当前 Go 开发包的环境变量状态. 第 2 行,GOARCH 表示目标处理器架构. 第 3 行,GOBIN 表示编译器和链接器的安装位置. 第 7 行,GOOS 表示目标操作系统. 第 8 行,GOPATH 表示当前工作目录. 第 10 行,GOROOT 表示 Go 开发包的安装目录. 从命令行输出中,可以看到 GOPATH 设定的路径为:C:\Users\Administrator\g

  • beego获取ajax数据的实例

    1. 什么是AJAX Asynchronous JavaScript And XML(异步 JavaScript 及 XML),是指一种创建交互式网页应用的网页开发技术 Ajax 是一种在无需重新加载整个网页的情况下,能够更新部分网页的技术. 2. 如何使用 AJAX XMLHttpRequest 是 AJAX 的基础. XMLHttpRequest 用于在后台与服务器交换数据.这意味着可以在不重新加载整个网页的情况下,对网页的某部分进行更新. 使用AJAX大致分四步 1. 创建XMLHttpR

  • Beego中ORM操作各类数据库连接方式详细示例

    目录 beego中各类数据库连接方式 1.1 orm使用方式 a. 注册数据库驱动程序 b.注册数据库 c. 注册模型 1.2 操作示例 a. orm连接mysql b. orm连接sqlite3 c. orm连接 postgresql 1.3非orm连接方式 a. mysql b. sqlite3 c. postgresql d. mongodb e.sqlserver f.redis beego中各类数据库连接方式 beego 框架是优秀得go REST API开发框架.下面针对beego中

  • YII2框架中操作数据库的方式实例分析

    本文实例讲述了YII2框架中操作数据库的方式.分享给大家供大家参考,具体如下: 一.以createCommand方式: // YII2中通过createCommand来处理数据库 // 查询多条记录 // {{%user}} 表示如果设置了表前缀,YII会自动帮你替换 $data1 = YII::$app->db->createCommand('select * from {{%user}}')->queryAll(); // 查询一条记录 // createCommand的第二个参数可

  • IDEA中配置操作Git的详细图文教程

    要注意这里git的安装路径不是从官网下载的路径,是在执行文件时自己设置的安装路径,一般都在C盘或D盘的Program Files文件夹中 IDEA中操作Git 创建本地仓库 2. 将文件添加到暂存区 可以看到刚刚添加的文件变成绿色,此时选中的文件被存入到暂存区,下一步需要转移到本地仓库 当提交多个文件的时候需要忽略一些不必要的文件,在项目git_1下创建一个文件 *.class.mtj.tmp/*.jar*.war*.ear*.ziphttp://www.java.com/en/download

  • 使用ORM新增数据在Mysql中的操作步骤

    [前言] 想要使用ORM在数据库中进行操作数据,前提是已经新建了ORM模型 :就是我们之前已经搭建的模型https://www.jb51.net/article/218036.htm [ORM操作步骤] 构造ORM模型对象 添加到session 提交到数据库 出现异常,回滚事务(可选) [构造ORM模型对象] user_obj = User( username="use1", password="123456", real_name = "用户1"

  • Java中几种常用数据库连接池的使用

    一.应用程序直接获取数据库连接的缺点 用户每次请求都需要向数据库获得链接,而数据库创建连接通常需要消耗相对较大的资源,创建时间也较长.假设网站一天10万访问量,数据库服务器就需要创建10万次连接,极大的浪费数据库的资源,并且极易造成数据库服务器内存溢出.拓机.如下图所示: 二.使用数据库连接池优化程序性能 2.1.数据库连接池的基本概念 数据库连接是一种关键的有限的昂贵的资源,这一点在多用户的网页应用程序中体现的尤为突出.对数据库连接的管理能显著影响到整个应用程序的伸缩性和健壮性,影响到程序的性

  • 详解Mybatis-plus(MP)中CRUD操作保姆级笔记

    目录 一.什么是mybatis-plus 1.在java中访问数据库 2.Mybatis-plus简介 3.Mybatis-plus特性 二.第一个mybatis-plus开发 1.使用MP的步骤: 前提:数据库/表创建 2.mybatis-plus日志 三.MP操作CRUD 的 基本用法 1.添加数据后,获取主键值(MP可以自动实现主键回填) 2.更新数据 3.删除数据 4.查询数据 5.mybatis-plus中CRUD的底层实现原理 一.什么是mybatis-plus 1.在java中访问

  • SpringBoot中Mybatis + Druid 数据访问的详细过程

    目录 1.简介 2.JDBC 3.CRUD操作 4.自定义数据源 DruidDataSource 1.配置 Druid 数据源监控 2.配置 Druid web 监控 filter 5.SpringBoot 整合mybatis 1. 导入mybatis所需要的依赖 2.配置数据库连接信息 3,创建实体类 4.配置Mapper接口类 6.SpringBoot 整合 1.简介 ​ 对于数据访问层,无论是SQL(关系型数据库) 还是NOSQL(非关系型数据库),SpringBoot 底层都是采用 Sp

  • Django静态文件配置request对象方法ORM操作讲解

    目录 django框架请求流程 静态文件及相关配置 请求方法 request对象方法 pycharm链接MySQL Django链接MySQL Django ORM ORM语法 ORM外键关联 django框架请求流程 静态文件及相关配置 ORM:对象关系映射 python 映射   数据库类      表 对象     记录对象.属性     字段对应的值'ORM的存在可以使不会MySQL的程序员 使用python的语法操作数据库' 1.先去model.py中编写模型类(相当于是在建表) cl

  • Go ORM的封装解决方式详解

    目录 背景 Java的orm Go的orm 解决方式 初始化sql 连接数据库 插入语句 查询语句 gplus工具 最后 背景 去年慢慢开始接触了Go语言,也在公司写了几个Go的生产项目.我是从Java转过来的.(其实也不算转,公司用啥,我用啥)在这个过程中,老是想用Java的思维写Go,在开始的一两个月,那是边写边吐槽. 丑陋的错误处理,没有流式处理,还竟然没有泛型,框架生态链不成熟,没有一家独大的类似Spring的框架.(其实现在写了快一年的Go,Go还是挺香的,哈哈) 今天,我来聊一下,我

随机推荐