araddon/qlbridge 是一个golang 表达式执行器可以用来方便的构建基于sql 的查询引擎 同时已经内置了几种sql 的实现，同时也有一个dataux/dataux （但是不 维护了）的实现， 类似presto，以下是关于araddon/qlbridge 的简单学习代码来自官方文档核心代码?package main?import ( "bytes" "database/sql" "flag" "fmt" "net/mail" "strings"? // Side-Effect Import the qlbridge sql driver _ "github.com...
下列代码中较为特别的转换就是将字节数组写入到数据库中 fmt.Sprintf("X%x", t) 注意插入的时候使用占位符x, 再有一个标志X func toInsertSQL(dat map[string]interface{}) string {if nil == dat { return "" }var sql = "INSERT INTO " + tableNamevar keyStr, valueStr = "(", "("var index = 0var count = len(dat)for k, v := range dat {keyStr += "\""+ k + "\""index += 1valueStr += toString(v)if index < count { valu...
本文是使用 golang 实现 redis 系列的第八篇， 将介绍如何在分布式缓存中使用 Try-Commit-Catch 方式来解决分布式一致性问题。 godis 集群的源码在Github:Godis/cluster 在上一篇文章中我们使用一致性 hash 算法将缓存中的 key 分散到不同的服务器节点中，从而实现了分布式缓存。随之而来的问题是：一条指令(比如 MSET)可能需要多个节点同时执行，可能有些节点成功而另一部分节点失败。 对于使用者而言这种部分成功部分失败的情况非...
目录1.驱动注册2.打开一个database3.查询4.参考 上篇文章关于golang database_sql 包讲述了 database/sql 的整体设计框架。 本文简要介绍go-sql-driver的调用关系，是如何与database/sql关联起来的，包括从驱动注册到具体查询，每个步骤的底层调用。 我们查询MySQL的大体代码demo如下： package main import ("database/sql""log"_ "github.com/go-sql-driver/mysql" )var DB *sql.DB var dataBase = "root:Aa123456@tcp(127.0.0.1...
SetMaxOpenConns(maxOpenConns) 连接池最多同时打开的连接数。 这个maxOpenConns理应要设置得比mysql服务器的max_connections值要小。 一般设置为： 服务器cpu核心数 * 2 + 服务器有效磁盘数。参考这里 可用show variables like max_connections; 查看服务器当前设置的最大连接数。 SetMaxIdleConns(maxIdleConns) 连接池里最大空闲连接数。必须要比maxOpenConns小； SetConnMaxIdleTime(maxIdleTime) 连接池里面的连接最大空闲时长...
golang中的标准库database/sql 包为SQL和类SQL数据库的操作提供了通用的接口。 database/sql 包 必须与数据库driver 配套使用。 目前已有的SQL database drivers 见链接。 这里面就包括比较常用的MySQL driver go-sql-driver/mysql 。 database/sql 包的设计可以说是很巧妙。 它对于上层应用提供了标准的API接口，对下层驱动driver暴露了简单的驱动接口。 并且实现了连接池的管理。这意味着，不同数据库的驱动只需要实现驱动接口，...
0 redis安装请参考Redis备忘录 1. golang操作redis 切换到golang工作目录，新建项目redis，然后建立连接redis的文件[root@master src]# pwd /dongguangming/goworkspace/src [root@master src]# mkdir redis [root@master src]# cd redis/ [root@master redis]# touch redis-conn.go编辑redis-conn.go文件 ，即[root@master redis]# vi redis-conn.go 键入以下代码package mainimport ("fmt""github.com/go-redis/redis" )func...
本文章介绍一下golang的sqlite 数据使用，废话少说直接上代码：package mainimport ("database/sql""fmt""time"_"github.com/mattn/go-sqlite3" )func main() {//打开数据库，如果不存在，则创建db, err := sql.Open("sqlite3", "./foo.db")checkErr(err)//创建表sql_table := `CREATE TABLE IF NOT EXISTS userinfo(uid INTEGER PRIMARY KEY AUTOINCREMENT,username VARCHAR(64) NULL,departname VARCHAR(64) NULL,created DATE N...
很多系统都是将密码进行一次 MD5 或 SHA1 Hash后存入数据库中。这样的密码抵挡不住字典攻击。所谓字典攻击，就是将常用密码进行Hash后做成一个字典，破解的时候，只需要查字典就能知道对应的明文密码。 为了抵御字典攻击，推荐的做法是使用 密码 + 盐（一串随机数） 再Hash的方式。每个密码对应一个不同的随机数。这个方法，实际上是将密码人为地拓展了N位，导致密码长度大增，使得攻击者无法构造这么大的一个字典。 Go语言提供了一...
query := fmt.Sprintf("SELECT .... infos = make([]*struct, 0, 10) err = s.db.GetContext(ctx, &infos, query)返回错误：scannable dest type slice with >1 columns (4) in result解决办法： 替换 GetContext为：SelectContext
Golang redis学习指南 安装 我使用的是 (https://github.com/go-redis/redis) 这个 golang 客户端, 因此安装方式如下: go get gopkg.in/redis.v4接着在代码中导入此包即可: import "gopkg.in/redis.v4"基本操作 创建客户端 ? 通过 redis.NewClient 函数即可创建一个 redis 客户端, 这个方法接收一个 redis.Options 对象参数, 通过这个参数, 我们可以配置 redis 相关的属性, 例如 redis 服务器地址, 数据库名, 数据库密码等. 下面是...
package mainimport ("fmt""time""github.com/garyburd/redigo/redis" )const (RedisURL = "redis://127.0.0.1:6379"redisMaxIdle = 3 //最大空闲连接数redisIdleTimeoutSec = 240 //最大空闲连接时间RedisPassword = "123456" )// NewRedisPool 返回redis连接池 func NewRedisPool(redisURL string) *redis.Pool {return &redis.Pool{MaxIdle: redisMaxIdle,IdleTimeout: redisIdleTimeoutSec * ti...
1.golang sql2struct 1.1 go代码实现 package mainimport ( "fmt" "github.com/gohouse/converter" ) func main() {err := converter.NewTable2Struct().SavePath("/home/xxx/Desktop/model.go").Dsn("root:123456@tcp(localhost:3306)/test?charset=utf8").Run()fmt.Println(err) }1.2 命令行模式 //1.下载二进制文件 https://github.com/gohouse/converter/releases//2.执行命令 ./table2struct-linux.v0.0.3.bin -file /home/xx...
本文是使用 golang 实现 redis 系列的第四篇文章，将介绍如何使用 golang 实现 Append Only File 持久化及 AOF 文件重写。 本文完整源代码在作者GithubHDT3213/godis AOF 文件 AOF 持久化是典型的异步任务，主协程(goroutine) 可以使用 channel 将数据发送到异步协程由异步协程执行持久化操作。 在 DB 中定义相关字段: type DB struct {// 主线程使用此channel将要持久化的命令发送到异步协程aofChan chan *reply.MultiBulkRep...
redis知识准备 redis SETNX命令 SETNX 如果key不存在则创建，并返回true 如果key存在则不操作，并返回false redis TTL命令 如果对key设置了过期时间，则TTL命令返回key到过期时所剩余的时间 如果key没有设置过期时间，则TTL命令返回-1 代码 package mainimport ("fmt""github.com/go-redis/redis""time" )type redisClient redis.Clientfunc connRedisCluster(address []string, password string) *redis.ClusterClient {conf := r...