Skip to content

G
goutils
Commit d7259e6f authored by liupei's avatar liupei
Browse files
Options

1

parents
Pipeline #660 failed with stages
      Hide whitespace changes
      Inline Side-by-side
      Showing with 355 additions and 0 deletions
      .idea/.gitignore 0 → 100644
      View file @ d7259e6f
      # 默认忽略的文件
      /shelf/
      /workspace.xml
      # 已忽略包含查询文件的默认文件夹
      /queries/
      # Datasource local storage ignored files
      /dataSources/
      /dataSources.local.xml
      # 基于编辑器的 HTTP 客户端请求
      /httpRequests/
      .idea/go.imports.xml 0 → 100644
      View file @ d7259e6f
      <?xml version="1.0" encoding="UTF-8"?>
      <project version="4">
      <component name="GoImports">
      <option name="excludedPackages">
      <array>
      <option value="github.com/pkg/errors" />
      <option value="golang.org/x/net/context" />
      </array>
      </option>
      </component>
      </project>
      \ No newline at end of file
      .idea/goutils.iml 0 → 100644
      View file @ d7259e6f
      <?xml version="1.0" encoding="UTF-8"?>
      <module type="WEB_MODULE" version="4">
      <component name="Go" enabled="true" />
      <component name="NewModuleRootManager">
      <content url="file://$MODULE_DIR$" />
      <orderEntry type="inheritedJdk" />
      <orderEntry type="sourceFolder" forTests="false" />
      </component>
      </module>
      \ No newline at end of file
      .idea/modules.xml 0 → 100644
      View file @ d7259e6f
      <?xml version="1.0" encoding="UTF-8"?>
      <project version="4">
      <component name="ProjectModuleManager">
      <modules>
      <module fileurl="file://$PROJECT_DIR$/.idea/goutils.iml" filepath="$PROJECT_DIR$/.idea/goutils.iml" />
      </modules>
      </component>
      </project>
      \ No newline at end of file
      .idea/vcs.xml 0 → 100644
      View file @ d7259e6f
      <?xml version="1.0" encoding="UTF-8"?>
      <project version="4">
      <component name="VcsDirectoryMappings">
      <mapping directory="" vcs="Git" />
      </component>
      </project>
      \ No newline at end of file
      go.mod 0 → 100644
      View file @ d7259e6f
      module goutils
      go 1.25.5
      require (
      github.com/gogf/gf/v2 v2.9.8
      github.com/tidwall/gjson v1.18.0
      )
      require (
      github.com/BurntSushi/toml v1.5.0 // indirect
      github.com/clbanning/mxj/v2 v2.7.0 // indirect
      github.com/emirpasic/gods/v2 v2.0.0-alpha // indirect
      github.com/fatih/color v1.18.0 // indirect
      github.com/fsnotify/fsnotify v1.9.0 // indirect
      github.com/go-logr/logr v1.4.3 // indirect
      github.com/go-logr/stdr v1.2.2 // indirect
      github.com/google/uuid v1.6.0 // indirect
      github.com/gorilla/websocket v1.5.3 // indirect
      github.com/grokify/html-strip-tags-go v0.1.0 // indirect
      github.com/magiconair/properties v1.8.10 // indirect
      github.com/mattn/go-colorable v0.1.13 // indirect
      github.com/mattn/go-isatty v0.0.20 // indirect
      github.com/mattn/go-runewidth v0.0.16 // indirect
      github.com/olekukonko/errors v1.1.0 // indirect
      github.com/olekukonko/ll v0.0.9 // indirect
      github.com/olekukonko/tablewriter v1.1.0 // indirect
      github.com/rivo/uniseg v0.2.0 // indirect
      github.com/tidwall/match v1.2.0 // indirect
      github.com/tidwall/pretty v1.2.1 // indirect
      go.opentelemetry.io/auto/sdk v1.1.0 // indirect
      go.opentelemetry.io/otel v1.38.0 // indirect
      go.opentelemetry.io/otel/metric v1.38.0 // indirect
      go.opentelemetry.io/otel/sdk v1.38.0 // indirect
      go.opentelemetry.io/otel/trace v1.38.0 // indirect
      golang.org/x/net v0.40.0 // indirect
      golang.org/x/sys v0.35.0 // indirect
      golang.org/x/text v0.25.0 // indirect
      gopkg.in/yaml.v3 v3.0.1 // indirect
      )
      go.sum 0 → 100644
      View file @ d7259e6f
      github.com/BurntSushi/toml v1.5.0 h1:W5quZX/G/csjUnuI8SUYlsHs9M38FC7znL0lIO+DvMg=
      github.com/BurntSushi/toml v1.5.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
      github.com/clbanning/mxj/v2 v2.7.0 h1:WA/La7UGCanFe5NpHF0Q3DNtnCsVoxbPKuyBNHWRyME=
      github.com/clbanning/mxj/v2 v2.7.0/go.mod h1:hNiWqW14h+kc+MdF9C6/YoRfjEJoR3ou6tn/Qo+ve2s=
      github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
      github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
      github.com/emirpasic/gods/v2 v2.0.0-alpha h1:dwFlh8pBg1VMOXWGipNMRt8v96dKAIvBehtCt6OtunU=
      github.com/emirpasic/gods/v2 v2.0.0-alpha/go.mod h1:W0y4M2dtBB9U5z3YlghmpuUhiaZT2h6yoeE+C1sCp6A=
      github.com/fatih/color v1.18.0 h1:S8gINlzdQ840/4pfAwic/ZE0djQEH3wM94VfqLTZcOM=
      github.com/fatih/color v1.18.0/go.mod h1:4FelSpRwEGDpQ12mAdzqdOukCy4u8WUtOY6lkT/6HfU=
      github.com/fsnotify/fsnotify v1.9.0 h1:2Ml+OJNzbYCTzsxtv8vKSFD9PbJjmhYF14k/jKC7S9k=
      github.com/fsnotify/fsnotify v1.9.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8TRcHyHii0=
      github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
      github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
      github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
      github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
      github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
      github.com/gogf/gf/v2 v2.9.8 h1:El0HwksTzeRk0DQV4Lh7S9DbsIwKInhHSHGcH7qJumM=
      github.com/gogf/gf/v2 v2.9.8/go.mod h1:Svl1N+E8G/QshU2DUbh/3J/AJauqCgUnxHurXWR4Qx0=
      github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
      github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
      github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
      github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
      github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
      github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
      github.com/grokify/html-strip-tags-go v0.1.0 h1:03UrQLjAny8xci+R+qjCce/MYnpNXCtgzltlQbOBae4=
      github.com/grokify/html-strip-tags-go v0.1.0/go.mod h1:ZdzgfHEzAfz9X6Xe5eBLVblWIxXfYSQ40S/VKrAOGpc=
      github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
      github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
      github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
      github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
      github.com/magiconair/properties v1.8.10 h1:s31yESBquKXCV9a/ScB3ESkOjUYYv+X0rg8SYxI99mE=
      github.com/magiconair/properties v1.8.10/go.mod h1:Dhd985XPs7jluiymwWYZ0G4Z61jb3vdS329zhj2hYo0=
      github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
      github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
      github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
      github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
      github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
      github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc=
      github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
      github.com/olekukonko/errors v1.1.0 h1:RNuGIh15QdDenh+hNvKrJkmxxjV4hcS50Db478Ou5sM=
      github.com/olekukonko/errors v1.1.0/go.mod h1:ppzxA5jBKcO1vIpCXQ9ZqgDh8iwODz6OXIGKU8r5m4Y=
      github.com/olekukonko/ll v0.0.9 h1:Y+1YqDfVkqMWuEQMclsF9HUR5+a82+dxJuL1HHSRpxI=
      github.com/olekukonko/ll v0.0.9/go.mod h1:En+sEW0JNETl26+K8eZ6/W4UQ7CYSrrgg/EdIYT2H8g=
      github.com/olekukonko/tablewriter v1.1.0 h1:N0LHrshF4T39KvI96fn6GT8HEjXRXYNDrDjKFDB7RIY=
      github.com/olekukonko/tablewriter v1.1.0/go.mod h1:5c+EBPeSqvXnLLgkm9isDdzR3wjfBkHR9Nhfp3NWrzo=
      github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
      github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
      github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY=
      github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
      github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
      github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
      github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
      github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
      github.com/tidwall/gjson v1.18.0 h1:FIDeeyB800efLX89e5a8Y0BNH+LOngJyGrIWxG2FKQY=
      github.com/tidwall/gjson v1.18.0/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
      github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
      github.com/tidwall/match v1.2.0 h1:0pt8FlkOwjN2fPt4bIl4BoNxb98gGHN2ObFEDkrfZnM=
      github.com/tidwall/match v1.2.0/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
      github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
      github.com/tidwall/pretty v1.2.1 h1:qjsOFOWWQl+N3RsoF5/ssm1pHmJJwhjlSbZ51I6wMl4=
      github.com/tidwall/pretty v1.2.1/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
      go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
      go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=
      go.opentelemetry.io/otel v1.38.0 h1:RkfdswUDRimDg0m2Az18RKOsnI8UDzppJAtj01/Ymk8=
      go.opentelemetry.io/otel v1.38.0/go.mod h1:zcmtmQ1+YmQM9wrNsTGV/q/uyusom3P8RxwExxkZhjM=
      go.opentelemetry.io/otel/metric v1.38.0 h1:Kl6lzIYGAh5M159u9NgiRkmoMKjvbsKtYRwgfrA6WpA=
      go.opentelemetry.io/otel/metric v1.38.0/go.mod h1:kB5n/QoRM8YwmUahxvI3bO34eVtQf2i4utNVLr9gEmI=
      go.opentelemetry.io/otel/sdk v1.38.0 h1:l48sr5YbNf2hpCUj/FoGhW9yDkl+Ma+LrVl8qaM5b+E=
      go.opentelemetry.io/otel/sdk v1.38.0/go.mod h1:ghmNdGlVemJI3+ZB5iDEuk4bWA3GkTpW+DOoZMYBVVg=
      go.opentelemetry.io/otel/sdk/metric v1.38.0 h1:aSH66iL0aZqo//xXzQLYozmWrXxyFkBJ6qT5wthqPoM=
      go.opentelemetry.io/otel/sdk/metric v1.38.0/go.mod h1:dg9PBnW9XdQ1Hd6ZnRz689CbtrUp0wMMs9iPcgT9EZA=
      go.opentelemetry.io/otel/trace v1.38.0 h1:Fxk5bKrDZJUH+AMyyIXGcFAPah0oRcT+LuNtJrmcNLE=
      go.opentelemetry.io/otel/trace v1.38.0/go.mod h1:j1P9ivuFsTceSWe1oY+EeW3sc+Pp42sO++GHkg4wwhs=
      go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
      go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
      golang.org/x/net v0.40.0 h1:79Xs7wF06Gbdcg4kdCCIQArK11Z1hr5POQ6+fIYHNuY=
      golang.org/x/net v0.40.0/go.mod h1:y0hY0exeL2Pku80/zKK7tpntoX23cqL3Oa6njdgRtds=
      golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
      golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
      golang.org/x/sys v0.35.0 h1:vz1N37gP5bs89s7He8XuIYXpyY0+QlsKmzipCbUtyxI=
      golang.org/x/sys v0.35.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
      golang.org/x/text v0.25.0 h1:qVyWApTSYLk/drJRO5mDlNYskwQznZmkpV2c8q9zls4=
      golang.org/x/text v0.25.0/go.mod h1:WEdwpYrmk1qmdHvhkSTNPm3app7v4rsT8F2UD6+VHIA=
      gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
      gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
      gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
      gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
      gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
      ndbclient/client.go 0 → 100644
      View file @ d7259e6f
      package ndbclient
      import (
      "context"
      "net/http"
      "net/url"
      "path"
      "github.com/gogf/gf/v2/frame/g"
      "github.com/tidwall/gjson"
      )
      var (
      client = g.Client()
      gOption Option
      )
      type Option struct {
      User string
      Pwd string
      Addr string
      // MaxIdleConnsPerHost 设置每个host最大空闲连接数，通常5个，需要根据业务情况调整
      MaxIdleConnsPerHost int
      }
      func Init(option Option) {
      gOption = option
      // 设置连接池
      if gOption.MaxIdleConnsPerHost == 0 {
      gOption.MaxIdleConnsPerHost = 5
      }
      client.Transport.(*http.Transport).MaxIdleConnsPerHost = gOption.MaxIdleConnsPerHost
      }
      func request(ctx context.Context, urlPath string, arg map[string]interface{}) Response {
      body := map[string]interface{}{
      "arg": arg,
      "auth": map[string]interface{}{
      "user": gOption.User,
      "pwd": gOption.Pwd,
      },
      }
      addr := gOption.Addr
      u, _ := url.Parse(addr)
      finalUrl := path.Join(u.Path, urlPath)
      r, err := client.ContentJson().Post(ctx, finalUrl, body)
      if err != nil {
      panic(err)
      }
      defer r.Close()
      return newResponse(r.ReadAllString())
      }
      type Response struct {
      result gjson.Result
      errMsg string
      }
      func newResponse(result string) Response {
      return Response{
      result: gjson.Parse(result),
      }
      }
      func (r *Response) IsSuccess() bool {
      if r.result.Get("code").Exists() && r.result.Get("code").Int() == 0 {
      return true
      }
      return false
      }
      func (r *Response) GetErrMsg() string {
      if !r.IsSuccess() {
      return r.result.Get("msg").String()
      }
      return ""
      }
      ndbclient/client_test.go 0 → 100644
      View file @ d7259e6f
      package ndbclient
      import (
      "context"
      "testing"
      )
      func TestInsert(t *testing.T) {
      groupId := "liupei"
      res := Insert(groupId).SetRows("test", []interface{}{
      map[string]interface{}{
      "id": 1,
      "name": "liupei",
      },
      map[string]interface{}{
      "id": 2,
      "name": "liupei",
      },
      }).Do(context.Background())
      if !res.IsSuccess() {
      t.Errorf("err:%s", res.GetErrMsg())
      }
      }
      ndbclient/insert.go 0 → 100644
      View file @ d7259e6f
      package ndbclient
      import "context"
      var (
      dataInsertPath = "/jsgo.xbind.ndb.api.data/Insert"
      )
      type DataInsert struct {
      groupId string
      rows map[string][]interface{}
      arg map[string]interface{}
      }
      func Insert(groupId string) *DataInsert {
      return &DataInsert{
      groupId: groupId,
      }
      }
      func (i *DataInsert) SetGroupId(groupId string) *DataInsert {
      i.groupId = groupId
      return i
      }
      func (i *DataInsert) SetRows(tableName string, rows []interface{}) *DataInsert {
      i.rows = nil
      for _, v := range rows {
      i.AddRow(tableName, v)
      }
      return i
      }
      func (i *DataInsert) AddRow(tableName string, row interface{}) *DataInsert {
      if i.rows == nil {
      i.rows = make(map[string][]interface{})
      }
      i.rows[tableName] = append(i.rows[tableName], row)
      return i
      }
      func (i *DataInsert) Do(ctx context.Context) Response {
      return request(ctx, dataInsertPath, map[string]interface{}{
      "groupId": i.groupId,
      "rows": i.rows,
      })
      }
      ndbclient/main_test.go 0 → 100644
      View file @ d7259e6f
      package ndbclient
      import (
      "os"
      "testing"
      )
      func TestMain(m *testing.M) {
      // 在所有测试之前进行全局设置
      setup()
      // 运行所有测试
      exitCode := m.Run()
      // 退出程序
      os.Exit(exitCode)
      }
      func setup() {
      option := Option{
      User: os.Getenv("NDB_USER"),
      Pwd: os.Getenv("NDB_PWD"),
      Addr: os.Getenv("NDB_ADDR"),
      MaxIdleConnsPerHost: 5,
      }
      Init(option)
      }
      ndbclient/result.go 0 → 100644
      View file @ d7259e6f
      package ndbclient
      type Result struct {
      }
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment