【REST2SQL】04 REST2SQL第一版Oracle版实现

2024-01-08 17:36

本文主要是介绍【REST2SQL】04 REST2SQL第一版Oracle版实现,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

【REST2SQL】01RDB关系型数据库REST初设计
【REST2SQL】02 GO连接Oracle数据库
【REST2SQL】03 GO读取JSON文件

REST2SQL的第一个版本,只支持Oracle数据库,以后会逐步加入其它数据看的支持。

项目文件组织如下:
在这里插入图片描述

1 REST2SQL为项目主目录

主控main()函数、请求日志函数、请求响应函数、请求参数返回函数在此目录。

1.1 import引用包

import ("encoding/json""fmt""io""log""net/http""rest2sql/config" //配置信息在config.json文件do "rest2sql/dothing""strings""time"
)

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) {count++start := 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/json""io/ioutil""log""strings"
)var Conf config //全局变量func init() {Conf = getConfig()
}// 配置结构体
type config struct {DBType     string //数据库类型 :oracle、mysql等ConnString string `json:"connString"`HostPort   string `json:"hostPort"`REST       string `json:"REST"`SQL        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/driver""encoding/json""io""log""rest2sql/config"go_ora "github.com/sijms/go-ora/v2" // 1 go get github.com/sijms/go-ora/v2
)// Oracle连接字符串
//var ConnStr string = "oracle://blma:5217@127.0.0.1:1521/CQYH"var ConnString string = config.Conf.ConnString/*
func main() {var (sqls   string //sql语句result string //sql执行后返回的结果)// select查询数据sqls = "select sysdate from dual"result = selectData(sqls)fmt.Println(result)// delete 删除数据sqls = "delete from atop where p_id = -5"result = deleteData(sqls)fmt.Println(result)// update 更新数据sqls = "update atop set f_dm = '005217' where p_id = -5217"result = 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("Can't open the driver:", err)//打开连接err = DB.Open()dieOnError("Can't open the connection:", err)return DB
}// delete
func DeleteData(deleteSql string) string {result, _ := execSQL(deleteSql)rows, err := result.RowsAffected()dieOnError("Can't 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("Can't 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("Can't 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("Can't 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("Can't 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("Can't 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/json""fmt""net/http""rest2sql/config""rest2sql/dboracle""strings"
)// 当前连接的数据库类型oracle
var (DBType string = config.Conf.DBType //数据库类型REST   string = config.Conf.REST   //支持的REST:GET,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 "string"case int:return "int"case float32:return "float32"case float64:return "float64"case bool:return "boolean"case []string:return "[]string"default: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初设计

需要运行程序的可以在评论区留言。

这篇关于【REST2SQL】04 REST2SQL第一版Oracle版实现的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/584268

相关文章

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注,收藏不迷路💖 Kubernetes的PodSecurityPolicy(PSP)是一个关键的安全特性,它在Pod创建之前实施安全策略,确保P

工厂ERP管理系统实现源码(JAVA)

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本,并实时掌握各环节的运营状况。 在采购管理方面,系统能够处理采购订单、供应商管理和采购入库等流程,确保采购过程的透明和高效。仓库管理方面,实现库存的精准管理,包括入库、出库、盘点等操作,确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现

基于51单片机的自动转向修复系统的设计与实现

文章目录 前言资料获取设计介绍功能介绍设计清单具体实现截图参考文献设计获取 前言 💗博主介绍:✌全网粉丝10W+,CSDN特邀作者、博客专家、CSDN新星计划导师,一名热衷于单片机技术探索与分享的博主、专注于 精通51/STM32/MSP430/AVR等单片机设计 主要对象是咱们电子相关专业的大学生,希望您们都共创辉煌!✌💗 👇🏻 精彩专栏 推荐订阅👇🏻 单片机