新增测试示例

Author: zhanghe06

README.md

@@ -26,3 +26,39 @@ gitbook serve
 ```
 
 [http://localhost:4000/](http://localhost:4000/)
+
+
+## 语言哲学
+
+换一种语言，意味着换一种信仰
+
+语言不同，哲学不同，思维不同，最佳实践自然不同
+
+[我为什么放弃Go语言](https://www.cnblogs.com/findumars/p/4097888.html)
+
+[驳狗屎文 "我为什么放弃Go语言"](https://blog.csdn.net/cxlzxi/article/details/50284975)
+
+
+## 常用语法特性
+
+map 通过双赋值检测某个键存在
+```
+elem, ok = m[key]
+```
+
+指针操作符
+```
+& 变量取地址
+* 指针取值
+```
+
+struct 定义json时，omitempty忽略零值和空值
+```
+Field int `json:"myName"`               // 以原始"myName"作为键名
+Field int `json:"myName,omitempty"`     // 以原始"myName"作为键名，如果为空则忽略字段序列化
+Field int `json:",omitempty"`           // 以原始"Field"作为键名，
+Field int `json:"-"`                    // 忽略字段序列化
+Field int `json:"-,"`                   // 以"-"作为键名
+```
+
+只有发送者才能关闭 channel，而不是接收者。向一个已经关闭的 channel 发送数据会引起 panic

apis/daily_sentence.go

@@ -1 +1,31 @@
 package apis
+
+import (
+	"fmt"
+	"github.com/zhanghe06/gin_project/dbs"
+	"github.com/zhanghe06/gin_project/models"
+)
+
+func UpdateDailySentenceTransaction(condition map[string]interface{}, updateData map[string]interface{}) (rows int64, err error) {
+	tx := dbs.DbClient.Begin()
+	defer func() {
+		if rec := recover(); rec != nil {
+			err = fmt.Errorf("%v", rec)
+			fmt.Println(err.Error())
+			tx.Rollback()
+		}
+	}()
+	var dailySentences []*models.DailySentence
+
+	resultFind := tx.Set("gorm:query_option", "FOR UPDATE").Where(condition).Find(&dailySentences)
+	if resultFind.Error  != nil {
+		panic(resultFind.Error)
+	}
+
+	resultUpdate := tx.Model(&dailySentences).Updates(updateData)
+	if resultUpdate.Error  != nil {
+		panic(resultUpdate.Error)
+	}
+	tx.Commit()
+	return resultUpdate.RowsAffected, nil
+}

controllers/daily_sentence.go

@@ -2,15 +2,18 @@ package controllers
 
 import (
 	"fmt"
+	"net/http"
+	"time"
+
 	"github.com/gin-gonic/gin"
 	"github.com/go-sql-driver/mysql"
 	"github.com/jinzhu/gorm"
+
+	"github.com/zhanghe06/gin_project/apis"
 	"github.com/zhanghe06/gin_project/dbs"
 	"github.com/zhanghe06/gin_project/models"
 	"github.com/zhanghe06/gin_project/requests"
 	"github.com/zhanghe06/gin_project/utils"
-	"net/http"
-	"time"
 )
 
 // 获取列表
@@ -313,3 +316,44 @@ func ScoreDailySentenceHandler(c *gin.Context) {
 	// 注意: 这里的res.Value和dailySentence一样, 更新的字段仅为updates传入的参数, 其余数据库自动修改的字段不会更新到这里
 	c.JSON(http.StatusOK, dailySentence)
 }
+
+
+
+// 更新记录
+//curl -X POST \
+// http://0.0.0.0:8080/v1/daily_sentence/transaction \
+// -H 'Content-Type: application/json' \
+// -d '{
+//   "id": "1",
+//   "Title": "this is a test",
+//   "Classification": "news"
+//}'
+func UpdateDailySentenceTransactionHandler(c *gin.Context) {
+	// 意外异常
+	defer func(c *gin.Context) {
+		if rec := recover(); rec != nil {
+			err := fmt.Errorf("%v", rec)
+			c.AbortWithError(http.StatusInternalServerError, err)
+		}
+	}(c)
+
+	var dailySentenceRequest requests.UpdateDailySentenceTransactionRequests
+
+	// 参数校验
+	if err := c.ShouldBindJSON(&dailySentenceRequest); err != nil {
+		c.AbortWithError(http.StatusBadRequest, err)
+		return
+	}
+
+	condition := map[string]interface{}{"id": dailySentenceRequest.ID}
+	updateData := map[string]interface{}{}
+	if dailySentenceRequest.Title != "" {
+		updateData["title"] = dailySentenceRequest.Title
+	}
+	rows, err := apis.UpdateDailySentenceTransaction(condition, updateData)
+	if err != nil {
+		c.AbortWithError(http.StatusBadRequest, err)
+		return
+	}
+	c.JSON(http.StatusOK, gin.H{"rows": rows})
+}

controllers/stream.go

@@ -0,0 +1,50 @@
+package controllers
+
+import (
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"io"
+	"net/http"
+	"time"
+)
+
+// 流式请求（利用 H5 的新特性 SSE）
+// curl -i -X GET http://0.0.0.0:8080/v1/stream/sse
+func StreamSSEHandler(c *gin.Context) {
+	chanStream := make(chan int, 10)
+	go func() {
+		defer close(chanStream)
+		for i := 0; i < 5; i++ {
+			chanStream <- i
+			time.Sleep(time.Second * 1)
+		}
+	}()
+	c.Stream(func(w io.Writer) bool {
+		if msg, ok := <-chanStream; ok {
+			c.SSEvent("message", msg)
+			return true
+		}
+		return false
+	})
+}
+
+// 流式请求
+// curl -i -X GET http://0.0.0.0:8080/v1/stream/crd
+func StreamCRDHandler(c *gin.Context) {
+	chanStream := make(chan int, 10)
+	go func() {
+		defer close(chanStream)
+		for i := 0; i < 5; i++ {
+			chanStream <- i
+			time.Sleep(time.Second * 1)
+		}
+	}()
+	c.Stream(func(w io.Writer) bool {
+		if msg, ok := <-chanStream; ok {
+			data := fmt.Sprintf("%d\n", msg)
+			c.Data(http.StatusOK, "text/event-stream", []byte(data))
+			return true
+		}
+		return false
+	})
+}

docs/deploy/govendor.md

@@ -29,9 +29,10 @@ govendor sync
 govendor add +e
 ```
 
-更新项目依赖
+更新项目依赖（新增依赖 + 更新已有依赖）
 ```
-govendor update github.com/gin-gonic/gin
+govendor add +e
+govendor update +v
 ```
 
 中国特色依赖

docs/framework/gin.md

@@ -1,6 +1,6 @@
 # Gin
 
-https://github.com/gin-gonic/gin
+[https://github.com/gin-gonic/gin](https://github.com/gin-gonic/gin)
 
 ```
 go get -u github.com/gin-gonic/gin
@@ -35,21 +35,86 @@ go test tests/*
 
 ## 中间件
 
-在 Middleware02 中Abort, 执行结果
+测试示例
+```go
+package middlewares
+
+import (
+	"fmt"
+	"github.com/gin-gonic/gin"
+)
+
+func Middleware01() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		defer func() {
+			fmt.Println("Middleware01 Defer")
+		}()
+		fmt.Println("Middleware01 Before")
+		c.Next()
+		fmt.Println("Middleware01 After")
+	}
+}
+```
+
+执行结果
 ```
 Middleware01 Before
 Middleware02 Before
 Middleware03 Before
 
+...
+
+Middleware03 After
+Middleware03 Defer
+Middleware02 After
+Middleware02 Defer
+Middleware01 After
+Middleware01 Defer
+```
+
+### Abort without return
+
+1、在 Middleware02 中 c.Next() 前 Abort, 执行结果
+```
+Middleware01 Before
+Middleware02 Before
+Middleware02 After
+Middleware02 Defer
+Middleware01 After
+Middleware01 Defer
+```
+
+2、在 Middleware02 中 c.Next() 后 Abort, 不会产生影响，正常执行
+
+3、在 Middleware02 中 defer 里 Abort, 不会产生影响，正常执行
+
+
+### Abort with return
+
+1、在 Middleware02 中 c.Next() 前 Abort, 执行结果
+```
+Middleware01 Before
+Middleware02 Before
+Middleware02 Defer
 Middleware01 After
+Middleware01 Defer
 ```
 
+2、在 Middleware02 中 c.Next() 后 Abort, 不会产生影响，正常执行
+
+3、在 Middleware02 中 defer 里 Abort, 不会产生影响，正常执行
+
+
 中间件使用`goroutines`注意:
 
 https://github.com/gin-gonic/gin#goroutines-inside-a-middleware
 
 
-## binding
+## struct binding tag for Bind/ShouldBind
+
+[go-playground/validator.v8](https://github.com/go-playground/validator)
+[hdr-Baked_In_Validators_and_Tags](http://godoc.org/gopkg.in/go-playground/validator.v8#hdr-Baked_In_Validators_and_Tags)
+[gin_validator_v8_to_v9](https://github.com/go-playground/validator/tree/v9/_examples/gin-upgrading-overriding)
 
 - required
 - omitempty

docs/framework/gorm.md

@@ -100,3 +100,24 @@ http://gorm.io/docs/update.html
 ## autocommit
 
 设置`&autocommit=false`貌似没有影响，源码没有查到此参数设置，待查
+
+
+## Sql 注入
+
+错误方式
+```
+db = db.Where("name LIKE '%"+args.Name+"%'")
+```
+
+正确方式
+```
+name := fmt.Sprintf("%%%s%%", args.Name)
+db = db.Where("name LIKE ?", name)
+```
+
+拼接sql，应该使用占位符`?`，避免直接解析
+
+POC
+```
+%') and sleep(1);-- -
+```

docs/framework/gotpl.md

@@ -0,0 +1,3 @@
+# gotpl
+
+https://github.com/tsg/gotpl

docs/framework/grequests.md

@@ -0,0 +1,5 @@
+# GRequests
+
+```
+go get -u github.com/levigross/grequests
+```