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

2024-01-08 17:36
文章标签 oracle 实现 04 第一版 rest2sql

本文主要是介绍【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。

相关文章

Spring Boot 实现 IP 限流的原理、实践与利弊解析

Spring Boot 实现 IP 限流的原理、实践与利弊解析

《SpringBoot实现IP限流的原理、实践与利弊解析》在SpringBoot中实现IP限流是一种简单而有效的方式来保障系统的稳定性和可用性,本文给大家介绍SpringBoot实现IP限... 目录一、引言二、IP 限流原理2.1 令牌桶算法2.2 漏桶算法三、使用场景3.1 防止恶意攻击3.2 控制资源
阅读更多...
springboot下载接口限速功能实现

springboot下载接口限速功能实现

《springboot下载接口限速功能实现》通过Redis统计并发数动态调整每个用户带宽,核心逻辑为每秒读取并发送限定数据量,防止单用户占用过多资源,确保整体下载均衡且高效,本文给大家介绍spring... 目录 一、整体目标 二、涉及的主要类/方法✅ 三、核心流程图解（简化） 四、关键代码详解1️⃣ 设置
阅读更多...
Nginx 配置跨域的实现及常见问题解决

Nginx 配置跨域的实现及常见问题解决

《Nginx配置跨域的实现及常见问题解决》本文主要介绍了Nginx配置跨域的实现及常见问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来... 目录1. 跨域1.1 同源策略1.2 跨域资源共享（CORS）2. Nginx 配置跨域的场景2.1
阅读更多...
Python中提取文件名扩展名的多种方法实现

Python中提取文件名扩展名的多种方法实现

《Python中提取文件名扩展名的多种方法实现》在Python编程中,经常会遇到需要从文件名中提取扩展名的场景,Python提供了多种方法来实现这一功能,不同方法适用于不同的场景和需求,包括os.pa... 目录技术背景实现步骤方法一：使用os.path.splitext方法二：使用pathlib模块方法三
阅读更多...
CSS实现元素撑满剩余空间的五种方法

CSS实现元素撑满剩余空间的五种方法

《CSS实现元素撑满剩余空间的五种方法》在日常开发中，我们经常需要让某个元素占据容器的剩余空间，本文将介绍5种不同的方法来实现这个需求，并分析各种方法的优缺点，感兴趣的朋友一起看看吧... css实现元素撑满剩余空间的5种方法 在日常开发中，我们经常需要让某个元素占据容器的剩余空间。这是一个常见的布局需求
阅读更多...
HTML5 getUserMedia API网页录音实现指南示例小结

HTML5 getUserMedia API网页录音实现指南示例小结

《HTML5getUserMediaAPI网页录音实现指南示例小结》本教程将指导你如何利用这一API，结合WebAudioAPI，实现网页录音功能,从获取音频流到处理和保存录音，整个过程将逐步... 目录1. html5 getUserMedia API简介1.1 API概念与历史1.2 功能与优势1.3
阅读更多...
Java实现删除文件中的指定内容

Java实现删除文件中的指定内容

《Java实现删除文件中的指定内容》在日常开发中,经常需要对文本文件进行批量处理,其中,删除文件中指定内容是最常见的需求之一,下面我们就来看看如何使用java实现删除文件中的指定内容吧... 目录1. 项目背景详细介绍2. 项目需求详细介绍2.1 功能需求2.2 非功能需求3. 相关技术详细介绍3.1 Ja
阅读更多...
使用Python和OpenCV库实现实时颜色识别系统

使用Python和OpenCV库实现实时颜色识别系统

《使用Python和OpenCV库实现实时颜色识别系统》：本文主要介绍使用Python和OpenCV库实现的实时颜色识别系统,这个系统能够通过摄像头捕捉视频流,并在视频中指定区域内识别主要颜色（红... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间详解
阅读更多...
PostgreSQL中MVCC 机制的实现

PostgreSQL中MVCC 机制的实现

《PostgreSQL中MVCC机制的实现》本文主要介绍了PostgreSQL中MVCC机制的实现,通过多版本数据存储、快照隔离和事务ID管理实现高并发读写,具有一定的参考价值,感兴趣的可以了解一下... 目录一 MVCC 基本原理python1.1 MVCC 核心概念1.2 与传统锁机制对比二 Postg
阅读更多...
SpringBoot整合Flowable实现工作流的详细流程

SpringBoot整合Flowable实现工作流的详细流程

《SpringBoot整合Flowable实现工作流的详细流程》Flowable是一个使用Java编写的轻量级业务流程引擎,Flowable流程引擎可用于部署BPMN2.0流程定义,创建这些流程定义的... 目录1、流程引擎介绍2、创建项目3、画流程图4、开发接口4.1 Java 类梳理4.2 查看流程图4
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2