网站开发项目策划书,制作书签怎么做,虚拟主机网站建设步骤,网页搜索一个网站全包【REST2SQL】01RDB关系型数据库REST初设计 【REST2SQL】02 GO连接Oracle数据库 【REST2SQL】03 GO读取JSON文件
REST2SQL的第一个版本#xff0c;只支持Oracle数据库#xff0c;以后会逐步加入其它数据看的支持。
项目文件组织如下#xff1a;
1 REST2SQL为项目主目录
…【REST2SQL】01RDB关系型数据库REST初设计 【REST2SQL】02 GO连接Oracle数据库 【REST2SQL】03 GO读取JSON文件
REST2SQL的第一个版本只支持Oracle数据库以后会逐步加入其它数据看的支持。
项目文件组织如下
1 REST2SQL为项目主目录
主控main()函数、请求日志函数、请求响应函数、请求参数返回函数在此目录。
1.1 import引用包
import (encoding/jsonfmtiolognet/httprest2sql/config //配置信息在config.json文件do rest2sql/dothingstringstime
)
1.2 请求信息放在Map里
// 请求信息map
var (req map[string]interface{} make(map[string]interface{}) //请求参数count int 0 //请求计数器
)
1.3 main() 主控函数
// main()
func main() {// 打印配置信息fmt.Println(config:, config.Conf)//响应所有的请求http.HandleFunc(/, handler)// http.HandleFunc(/REST, restHandler)// http.HandleFunc(/SQL, sqlHandler)println(Starting Http Server at, config.Conf.HostPort, \n)//启动监听和服务//log.Println(http.ListenAndServe(Conf.HostPort, RequestLogger(http.DefaultServeMux)))http.ListenAndServe(config.Conf.HostPort, RequestLogger(http.DefaultServeMux))//log.Println(err)//测试可以用这个//curl -X POST -d {\gpdm\:600800} -H Content-Type:application/json http://localhost:8080/rest/blma}1.4 请求日志函数
// 请求日志
func RequestLogger(targetMux http.Handler) http.Handler {return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {countstart : time.Now()targetMux.ServeHTTP(w, r)log.Printf((%v)\t%s\t\t%s\t\t%s\t\t%v,count,r.Method,r.RemoteAddr,r.RequestURI,time.Since(start),)})
}1.5 请求响应函数
// handler
func handler(w http.ResponseWriter, r *http.Request) {// 1请求主机Hostreq[Host] r.Host// 2请求路径Pathreq[Path] r.URL.Pathpath : strings.Split(r.URL.Path, /)if len(path) 3 {w.Write([]byte(400 Bad Request错误请求。请尝试/rest/xxx or /sql/xxx))return}//fmt.Println(path)// 3 请求类型REST or SQLrors : strings.ToUpper(fmt.Sprint(path[1]))// 支持的请求类型if !(rors REST || rors SQL) {w.Write([]byte(400 Bad Request错误请求。请尝试/REST/xxx or /SQL/xxx))return}req[RESTorSQL] rors //请求类型SQL or REST// 4 资源名 ResNamereq[ResName] path[2] //资源名表名ResName// 5请求方法Methodreq[Method] r.Method// 6请求头Content-Typereq[Content-Type] r.Header.Get(Content-Type)// 7请求数据Datadata, err : io.ReadAll(r.Body)if err ! nil {w.Write([]byte(err.Error()))return}defer r.Body.Close()//反序列化if len(data) 0 {var idata interface{}//fmt.Println(data:, data)err json.Unmarshal(data, idata)if err ! nil {w.Write([]byte(err.Error()))return}//fmt.Println(idata:, idata)req[Data] idata} else {req[Data] }// 8 请求参数query : r.URL.Query()req[Where] query.Get(where)req[OrderBy] query.Get(orderby)//返回http请求参数resReturn(w, req)//根据请求参数执行不同的操作do.DoThing(w, req)
}
1.6 请求参数返回函数
// http请求主要参数直接返回
func resReturn(w http.ResponseWriter, req map[string]interface{}) {w.Write([]byte({\Request\:))str, err : json.MarshalIndent(req, , )if err ! nil {w.Write([]byte(err.Error()))}//fmt.Println(str)w.Write(str)w.Write([]byte(,))
}2 config配置文件读取子目录
2.1 包名改为 config
//全局变量包package configimport (encoding/jsonio/ioutillogstrings
)var Conf config //全局变量func init() {Conf getConfig()
}// 配置结构体
type config struct {DBType string //数据库类型 oracle、mysql等ConnString string json:connStringHostPort string json:hostPortREST string json:RESTSQL string json:SQL
}// 取配置信息
func getConfig() config {bytes, err : ioutil.ReadFile(config.json)if err ! nil {log.Println(读取json文件失败:, err)panic(nil)}conf : config{}err json.Unmarshal(bytes, conf)if err ! nil {log.Println(json解析失败, err)panic(nil)}//数据库类型为数据库的第一部分end : strings.Index(conf.ConnString, :/)if end 0 {log.Println(连接字符串设置有误。)panic(nil)}conf.DBType conf.ConnString[0:end]// fmt.Println(conf)// fmt.Println(connString:, conf.ConnString)// fmt.Println(hostPort:, conf.HostPort)return *conf
}
2.2 doc.go 文件设置
// config project doc.go/*
config document
*/
package config
3 dboracle子目录Oracle数据库操作
3.1 包名dboracle
// gooracle project main.go
package dboracleimport (database/sql/driverencoding/jsoniologrest2sql/configgo_ora github.com/sijms/go-ora/v2 // 1 go get github.com/sijms/go-ora/v2
)// Oracle连接字符串
//var ConnStr string oracle://blma:5217127.0.0.1:1521/CQYHvar ConnString string config.Conf.ConnString/*
func main() {var (sqls string //sql语句result string //sql执行后返回的结果)// select查询数据sqls select sysdate from dualresult selectData(sqls)fmt.Println(result)// delete 删除数据sqls delete from atop where p_id -5result deleteData(sqls)fmt.Println(result)// update 更新数据sqls update atop set f_dm 005217 where p_id -5217result updateData(sqls)fmt.Println(result)// insert 插入一行数据sqls insert into atop (p_id) values (FLOOR(DBMS_RANDOM.value(0, 100)))result insertData(sqls)fmt.Println(result)
}
*/// 连接Oracle数据库
func connDB(connStr string) *go_ora.Connection {//创建连接DB, err : go_ora.NewConnection(connStr)dieOnError(Cant open the driver:, err)//打开连接err DB.Open()dieOnError(Cant open the connection:, err)return DB
}// delete
func DeleteData(deleteSql string) string {result, _ : execSQL(deleteSql)rows, err : result.RowsAffected()dieOnError(Cant delete, err)ret : map[string]int{Delete rowsAffected: int(rows),}jsonBytes, err : json.MarshalIndent(ret, , )dieOnError(map 转 json失败, err)return string(jsonBytes)
}// update
func UpdateData(updateSql string) string {result, _ : execSQL(updateSql)rows, err : result.RowsAffected()dieOnError(Cant update, err)ret : map[string]int{Update rowsAffected: int(rows),}jsonBytes, err : json.Marshal(ret)dieOnError(map 转 json失败, err)return string(jsonBytes)
}// insert
func InsertData(insertSql string) string {result, _ : execSQL(insertSql)rows, err : result.RowsAffected()dieOnError(Cant insert, err)ret : map[string]int{Insert rowsAffected: int(rows),}jsonBytes, err : json.MarshalIndent(ret, , )dieOnError(map 转 json失败, err)return string(jsonBytes)
}// 执行SQL execute stmt (INSERT, UPDATE, DELETE, DML, PLSQL) and return driver.Result object
func execSQL(sqls string) (result driver.Result, err error) {//连接数据库DB : connDB(ConnString)//延迟关闭连接defer DB.Close()//准备sql语句stmt : go_ora.NewStmt(sqls, DB)//延迟关闭SQLdefer stmt.Close()//执行SQL execute stmt (INSERT, UPDATE, DELETE, DML, PLSQL) and return driver.Result objectresult, err stmt.Exec(nil)dieOnError(Cant execSql() , err)return result, err
}// select查询结果为json
func SelectData(sqls string) string {//连接数据库DB : connDB(ConnString)//延迟关闭连接defer DB.Close()//准备sql语句stmt : go_ora.NewStmt(sqls, DB)//延迟关闭SQLdefer stmt.Close()rows, err : stmt.Query(nil)dieOnError(Cant query, err)defer rows.Close()//fmt.Println(rows)columns : rows.Columns()//fmt.Println(columns:, columns)values : make([]driver.Value, len(columns))var dataset []map[string]interface{} //元素为map的切片//Header(columns)for {err rows.Next(values)if err ! nil {break}//fmt.Println(values:, values)row1 : record(columns, values)dataset append(dataset, row1)}if err ! io.EOF {dieOnError(Cant Next, err)}//切片转jsonjsonBytes, err : json.MarshalIndent(dataset, , )dieOnError(slice 转 json失败, err)//fmt.Println(string(jsonBytes))return string(jsonBytes)
}// 发生错误退出1
func dieOnError(msg string, err error) {if err ! nil {log.Println(msg, err)//os.Exit(1)}
}// func Header(columns []string) {// }// 一行记录加入 map
func record(columns []string, values []driver.Value) map[string]interface{} {mc : make(map[string]interface{}) //一行记录信息放入 mapfor i, c : range values {//fmt.Printf(\%s\:%v,, columns[i], c)mc[columns[i]] c}//fmt.Println(mc)return mc //返回一行记录的信息map
}/* 查询表的主键方法
select * from user_cons_columns where table_name ATOP
and constraint_name (
select constraint_name from user_constraints
where table_name ATOP and constraint_type P)
order by position
*/// func returnErr(err error) error {
// if err ! nil {
// return err
// }
// return nil
// }// // 7调用存储过程
// func callStoredProcedure() error {
// var (
// id int
// msg string strings.Repeat( , 2000) //先赋值内容
// )
// //执行存储过程
// _, err : db.Exec(BEGIN ora_test2_pro(:1, :2 ); END;,
// id,
// sql.Out{Dest: msg},
// )
// if err ! nil {
// return err
// }
// //输出结果
// fmt.Println(msg)
// return nil
// }// // 8.调用函数
// func callFunction() error {
// var (
// id int
// msg string strings.Repeat( , 2000) //先赋值内容
// )
// //执行存储过程
// _, err : db.Exec(BEGIN :1 : ora_test2_func(:2 ); END;,
// sql.Out{Dest: msg},
// id,
// )
// if err ! nil {
// return err
// }
// //输出结果
// fmt.Println(msg)
// return nil
// }
3.2 doc.go
// gooracle project doc.go/*
gooracle document
*/
package dboracle
4 dothing主要逻辑处理
4.1 包名dothing
// dothing project dothing.go
package dothingimport (encoding/jsonfmtnet/httprest2sql/configrest2sql/dboraclestrings
)// 当前连接的数据库类型oracle
var (DBType string config.Conf.DBType //数据库类型REST string config.Conf.REST //支持的RESTGET,POST,PUT,DELETESQL string config.Conf.SQL //支持的SQL:SELECT,INSERT,UPDATE,DELETE
)// 根据请求类型参数执行不同的操作
func DoThing(w http.ResponseWriter, req map[string]interface{}) {w.Write([]byte(\n))//请求类型 REST or SQLswitch req[RESTorSQL] {case REST://REST请求方法过滤sMethod : strings.ToUpper(req[Method].(string))if !strings.Contains(REST, sMethod) {w.Write([]byte(不准许的REST请求检查配置文件config.json的REST项。))return}//执行REST请求doREST(w, req)case SQL://SQL过滤resSQL : req[ResName].(string)sqlToUpper : strings.ToUpper(resSQL)sql6 : sqlToUpper[:6]if !strings.Contains(SQL, sql6) {w.Write([]byte(不准许的SQL请求检查配置文件config.json的SQL项。))return}//执行SQLdoSQL(w, req)}
}// 根据请求参数执行不同的操作
func doREST(w http.ResponseWriter, req map[string]interface{}) {//w.Write([]byte(\ndoREST()))//资源名resName : req[ResName].(string)// 检查是否有效资源if !isRes(resName) {w.Write([]byte(\nerror:无效资源 resName))return} else {//w.Write([]byte(\nresName: resName))}// 查询条件检查var qry map[string]string make(map[string]string)qry[ResName] resNameqry[Where] req[Where].(string)qry[OrderBy] req[OrderBy].(string)// 有效资源再看请求方法Get、Post、Put、DeletesMethod : strings.ToUpper(req[Method].(string))switch sMethod {case GET:getAll(w, qry)case POST:var iData interface{}iData req[Data]postAdd(w, resName, iData)case PUT:var iData interface{}iData req[Data]putUpdate(w, qry, iData)case DELETE:deleteDel(w, qry)}
}// 根据请求参数执行不同的操作
func doSQL(w http.ResponseWriter, req map[string]interface{}) {//w.Write([]byte(\ndoSQL()\n))w.Write([]byte(\Response\:))//资源名sql语句resSQL : req[ResName].(string)fmt.Println(SQL://, resSQL)sqlToUpper : strings.ToUpper(resSQL)sql6 : sqlToUpper[:6]var result stringswitch sql6 {case SELECT:result dboracle.SelectData(resSQL)case INSERT:result dboracle.InsertData(resSQL)case UPDATE:result dboracle.UpdateData(resSQL)case DELETE:result dboracle.DeleteData(resSQL)default:// 过滤sql 只能执行 SELECT INSERT UPDATE DELETEresult \只能执行 SELECT INSERT UPDATE DELETE\}fmt.Println(SQL://, resSQL)w.Write([]byte(result))w.Write([]byte(}))
}// 检查资源是否存在 /
func isRes(resName string) bool {resname : strings.ToUpper(resName)var selectSQL stringswitch DBType {case oracle:{//表和视图selectSQL select object_name from user_objects where object_type in (TABLE,VIEW) and object_name resname }case :{}}//执行数据库查询result : dboracle.SelectData(selectSQL)//检查数据库是否有此表if strings.Contains(result, resname) {return true} else {return false}
}// GET all //
func getAll(w http.ResponseWriter, qry map[string]string) {//w.Write([]byte(\nGET ALL))w.Write([]byte(\Response\:))selectSQL : select * from qry[ResName]if len(qry[Where]) 0 {//fmt.Println(where , qry[Where])selectSQL where qry[Where] and rownum 52}if len(qry[OrderBy]) 0 {//fmt.Println(OrderBy , qry[OrderBy])selectSQL order by qry[OrderBy]}//执行 sql并返回 json 结果fmt.Println(REST://, selectSQL)result : dboracle.SelectData(selectSQL)w.Write([]byte(result))w.Write([]byte(}))
}// GET 1
func get1(w http.ResponseWriter) {w.Write([]byte(\nGET ONE))
}// POST /
func postAdd(w http.ResponseWriter, resName string, iData interface{}) {//curl http://localhost:5217/rest/atop --data {\p_id\:190,\s_mc\:\龙\} -X POST//w.Write([]byte(\nPOST ADD))w.Write([]byte(\Response\:{\Data\:))//fmt.Println(iData:, iData)str, err : json.MarshalIndent(iData, , )if err ! nil {w.Write([]byte(err.Error()))}//fmt.Println(str, str)w.Write(str)w.Write([]byte(,\Row\:))var mapData map[string]interface{}err json.Unmarshal(str, mapData)if err ! nil {w.Write([]byte(err.Error()))}//fmt.Println(mapData)var keys, values stringfor k, v : range mapData {//fmt.Printf(%s %v %T\n, k, v, v)keys k ,if typeofVar(v) string {values v.(string) ,}if typeofVar(v) float64 || typeofVar(v) int {values fmt.Sprintf(%f, v) ,}}keys strings.Trim(keys, ,)values strings.Trim(values, ,)//fmt.Println(keys, values)insertSQL : insert into resName ( keys ) values( values )//执行 insertSQL 并返回 json 结果fmt.Println(REST://:, insertSQL)result : dboracle.InsertData(insertSQL)w.Write([]byte(result))w.Write([]byte(}}))}// 数据类型断言
func typeofVar(variable interface{}) string {switch variable.(type) {case string:return stringcase int:return intcase float32:return float32case float64:return float64case bool:return booleancase []string:return []stringdefault:return unknown}
}// PUT
func putUpdate(w http.ResponseWriter, qry map[string]string, iData interface{}) {//w.Write([]byte(\nPUT UPDATE))w.Write([]byte(\Response\:{\Data\:))str, err : json.MarshalIndent(iData, , )if err ! nil {w.Write([]byte(err.Error()))}//fmt.Println(str, str)w.Write(str)w.Write([]byte(,\Row\:))var mapData map[string]interface{}err json.Unmarshal(str, mapData)if err ! nil {w.Write([]byte(err.Error()))}//fmt.Println(mapData)var sets stringfor k, v : range mapData {//fmt.Printf(%s %v %T\n, k, v, v)sets k if typeofVar(v) string {sets v.(string) ,}if typeofVar(v) float64 || typeofVar(v) int {sets fmt.Sprintf(%f, v) ,}}sets strings.Trim(sets, ,)updateSQL : update qry[ResName] set sets where qry[Where]//执行 insertSQL 并返回 json 结果fmt.Println(REST://, updateSQL)result : dboracle.UpdateData(updateSQL)w.Write([]byte(result))w.Write([]byte(}}))
}// DELETE
func deleteDel(w http.ResponseWriter, qry map[string]string) {// 查询条件在URL/后面//w.Write([]byte(\nDELETE DEL))w.Write([]byte(\Response\:))deleteSQL : delete from qry[ResName]if len(qry[Where]) 0 {//fmt.Println(where , qry[Where])deleteSQL where qry[Where] and rownum 52}//执行 sql并返回 json 结果fmt.Println(REST://, deleteSQL)result : dboracle.DeleteData(deleteSQL)w.Write([]byte(result))w.Write([]byte(}))
}
4.2 doc.go
// Dothing project doc.go/*
dothing document
*/
package dothing
5 部分运行效果图
5.1 启动REST2SQL.exe服务
编译后的rest2sql.exe为14M启动后的窗口为
5.2 浏览器操作演示效果
5.2.1 浏览器REST之GET请求 5.2.2 浏览器SQL之Select 5.2.3 执行RESR或SQL请求后服务窗口返回操作日志 5.3 详细的操作说明参阅
【REST2SQL】01RDB关系型数据库REST初设计
需要运行程序的可以在评论区留言。
