代码拉取完成,页面将自动刷新
同步操作将从 konyshe/gogo 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
Go语言轻量web开发框架,特点是一行代码搞定RESTFul,不依赖第三方ORM,也不需要生成一堆的controllers和models文件,快速使用。
公司数据库有100多张表,用BeeGo等框架,需要生成controllers和models等文件共200多个,鼠标滑都滑不过来。每次表字段一有修改,代码就要统统跟着修改,想想都恐怖,于是就有了这个项目。目前只支持查询请求,同时集成了轻量的web开发框架。
package main
import (
"net/http"
"gitee.com/konyshe/gogo"
)
func main() {
dataSourceName := "数据库用户名:数据库密码@tcp(数据库地址:数据库端口)/表名?charset=utf8"
if err := gogo.SQLInit("mysql", dataSourceName, 100, 5); err != nil {
gogo.Log().Error(err.Error())
return
}
gogo.GET("/restful/:tablename/:columnname", func(ctx *gogo.HTTPContext) {
queryData, err := gogo.SQLQueryByMap(
ctx.GetPathParam(":columnname"),
ctx.GetString("feilds"),
ctx.GetPathParam(":tablename"),
ctx.GetString("where"),
ctx.GetString("order"),
ctx.GetInt("offset", 0),
ctx.GetInt("count", 10))
if err != nil {
gogo.Log().Error(err.Error())
ctx.WriteString(err.Error())
} else {
ctx.WriteJSON(queryData)
}
})
gogo.GET("/ping", func(ctx *gogo.HTTPContext) {
l, err := gogo.SQLQueryByMap("aid", "*", "dede_sysconfig", "", "", 0, 100)
if err == nil {
ctx.WriteExecute(l,
"views/ping.tmpl",
"views/include/foot.tmpl",
"views/include/head.tmpl")
return
}
gogo.Log().Error(err.Error())
})
gogo.POST("/api", func(ctx *gogo.HTTPContext) {
//w := ctx.GetResponseWriter()
//r := ctx.GetRequest()
ctx.WriteByte(ctx.GetPostBody())
})
gogo.STATUS(http.StatusNotFound, func(ctx *gogo.HTTPContext) {
ctx.WriteHeader(http.StatusNotFound)
ctx.WriteString("Not Found")
})
gogo.Run(":3001")
}
mysql> desc dede_sysconfig;
+---------+----------------------+------+-----+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+---------+----------------------+------+-----+---------+-------+
| aid | smallint(8) unsigned | NO | | 0 | |
| varname | varchar(20) | NO | PRI | | |
| info | varchar(100) | NO | | | |
| groupid | smallint(6) | NO | | 1 | |
| type | varchar(10) | NO | | string | |
| value | text | YES | | NULL | |
+---------+----------------------+------+-----+---------+-------+
6 rows in set
go build -o app.exe
app.exe
go build -o app
./app
http://localhost:3001/ping
http://localhost:3001/restful/dede_sysconfig/aid
http://localhost:3001/restful/dede_sysconfig/aid?order=-aid&&offset=10&&count=100
http://localhost:3001/restful/dede_sysconfig/varname
http://localhost:3001/notfound
$ go get github.com/go-sql-driver/mysql
$ go get github.com/phachon/go-logger
$ go get gitee.com/konyshe/gogo
import "gitee.com/konyshe/gogo"
net/http
. This is required for example if using constants such as http.StatusOK
.import "net/http"
// 系统会优先判断是否命中固定URL,当固定URL无法命中的情况下,才会去判断是否命中正则URL(开发中部分支持)
gogo.GET("/restful/:tablename/:columnname", func(ctx *gogo.HTTPContext)
// 注册没有命中任何URL规则时进入的函数
gogo.STATUS(http.StatusNotFound, func(ctx *gogo.HTTPContext)
// SQLInit 初始化数据库操作句柄,这里要提供:
// driverName string: 数据库类型,例如mysql、sqlite等,参考github.com/go-sql-driver/mysql官方介绍
// dataSourceName string: 数据库地址,参考github.com/go-sql-driver/mysql官方介绍
// MaxOpenConns int: 最大缓存连接数,这个数值包含了MaxIdleConns
// MaxIdleConns int:预备的最大空闲连接数
gogo.SQLInit(driverName string, dataSourceName string, maxOpenConns int, maxIdleConns int) error
// SQLQueryByMap 将查询到的数据,按照指定字段的值做为索引构建map并返回
// columnName string: 作为索引的字段名称
// feilds string: 查询需要获取哪些字段的值,就是select后面跟着的部分,一般用"*"
// tableName string: 查询的表名
// where string: 过滤条件,就是where后面跟着的部分
// order string: 排序条件,就是order by后面跟着的部分。默认是ASC排序,除非"-"开头则DESC排序
// offset string: limit后面逗号相隔的两个数值,前者就是offset,后者就是count
// count string: limit后面逗号相隔的两个数值,前者就是offset,后者就是count
gogo.SQLQueryByMap(columname, feilds, tableName, where, order string, offset, count int) (interface{}, error)
// 输出日志到运行目录下的log目录下,同时控制台输出,还会根据日志级别显示不同颜色
// gogo.Log()返回的是go-logger的指针,后面的.Error()是go-logger的方法,具体使用参考github.com/phachon/go-logger
// content string: 需要输出的日志内容
// 如果你不喜欢,可以直接删掉LOGUtils.go文件
gogo.Log().Error(content string)
// 3001就是端口号了,这里和官方HTTP接口方法一致
gogo.Run(":3001")
// GetResponseWriter 获取原始的http.ResponseWriter指针
(ctx *HTTPContext) GetResponseWriter() http.ResponseWriter
// GetRequest 获取原始的http.Request指针
(ctx *HTTPContext) GetRequest() *http.Request
// GetPathParam 获取GET请求路径中的String格式参数值,例如/restful/:table_name/:id
// key string: 参数名称
(ctx *HTTPContext) GetPathParam(key string) string
// GetPostBody 获取POST请求的内容
(ctx *HTTPContext) GetPostBody() []byte
// WriteExecute 将官方原始的ParseFiles和Execute接口做了合并
// data interface{}: 渲染模板需要的数据
// filenames ...string: 模板文件路径
(ctx *HTTPContext) WriteExecute(data interface{}, filenames ...string) error
// WriteByte 将[]byte格式的数据输出给HTTP客户端
// content []byte: 需要输出HTTP客户端的[]byte格式数据
(ctx *HTTPContext) WriteByte(content []byte)
// WriteString 将String格式的数据输出给HTTP客户端
// content string: 需要输出HTTP客户端的String格式数据
(ctx *HTTPContext) WriteString(content string)
// WriteJSON 将Struct结构体的数据转换成Json输出给HTTP客户端
// v interface{}: 需要输出HTTP客户端的Struct结构体数据
(ctx *HTTPContext) WriteJSON(v interface{}) error
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。