|
|
@@ -2,10 +2,10 @@ package dpsapi
|
|
|
|
|
|
import (
|
|
|
"errors"
|
|
|
- "fmt"
|
|
|
"git.sxidc.com/go-tools/api_binding/http_binding"
|
|
|
"git.sxidc.com/go-tools/api_binding/http_binding/binding_context"
|
|
|
"git.sxidc.com/go-tools/api_binding/http_binding/response"
|
|
|
+ "git.sxidc.com/go-tools/api_binding/utils"
|
|
|
"git.sxidc.com/service-supports/dps-sdk"
|
|
|
"git.sxidc.com/service-supports/dps-sdk/client"
|
|
|
)
|
|
|
@@ -29,13 +29,13 @@ func ApiV1(binding *http_binding.Binding, dpsAddress string) {
|
|
|
for _, parsedClause := range parsedClauses {
|
|
|
switch clause := parsedClause.(type) {
|
|
|
case *insertClause:
|
|
|
- fmt.Printf("%+#v\n", clause)
|
|
|
+ return doInsert(inputModel, clause)
|
|
|
case *deleteClause:
|
|
|
- fmt.Printf("%+#v\n", clause)
|
|
|
+ return doDelete(inputModel, clause)
|
|
|
case *updateClause:
|
|
|
- fmt.Printf("%+#v\n", clause)
|
|
|
+ return doUpdate(inputModel, clause)
|
|
|
case *selectClause:
|
|
|
- fmt.Printf("%+#v\n", clause)
|
|
|
+ return doSelect(inputModel, clause)
|
|
|
default:
|
|
|
return errors.New("不支持的SQL语句")
|
|
|
}
|
|
|
@@ -51,3 +51,39 @@ func ApiV1(binding *http_binding.Binding, dpsAddress string) {
|
|
|
},
|
|
|
})
|
|
|
}
|
|
|
+
|
|
|
+func doInsert(inputModel OperateFromRequest, clause *insertClause) error {
|
|
|
+ version := inputModel.Version
|
|
|
+ if utils.IsStringEmpty(version) {
|
|
|
+ version = "v1"
|
|
|
+ }
|
|
|
+
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
+func doDelete(inputModel OperateFromRequest, clause *deleteClause) error {
|
|
|
+ version := inputModel.Version
|
|
|
+ if utils.IsStringEmpty(version) {
|
|
|
+ version = "v1"
|
|
|
+ }
|
|
|
+
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
+func doUpdate(inputModel OperateFromRequest, clause *updateClause) error {
|
|
|
+ version := inputModel.Version
|
|
|
+ if utils.IsStringEmpty(version) {
|
|
|
+ version = "v1"
|
|
|
+ }
|
|
|
+
|
|
|
+ return nil
|
|
|
+}
|
|
|
+
|
|
|
+func doSelect(inputModel OperateFromRequest, clause *selectClause) error {
|
|
|
+ version := inputModel.Version
|
|
|
+ if utils.IsStringEmpty(version) {
|
|
|
+ version = "v1"
|
|
|
+ }
|
|
|
+
|
|
|
+ return nil
|
|
|
+}
|
