zgo/zgo_test.go at master · gitcpu-io/zgo · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
package zgo

import (
  "fmt"
  "testing"
  "time"
)

//mysql struct
type MysqlUser struct {
  Host int    `json:"host"`
  User string `json:"user"`
}

func TestEngine(t *testing.T) {

  err := Engine(&Options{
    Env:     "local",
    Project: "origin",
    //Project: "1552641690",

    //如果是在本地开发可以对下面的组件开启使用(local.json)，如果是线上，不需要填写，走的配置是etcd
    Kafka: []string{
      //"kafka_label_bj",
      //"kafka_label_sh",
    },
    Nsq: []string{
      //"nsq_label_bj",
      //"nsq_label_sh",
    },
    Pika: []string{
      //"pika_label_rw",
      //"pika_label_r",
    },
    Postgres: []string{
      "postgres_label_sh",
    },
    Neo4j: []string{
      "neo4j_label",
    },
    Etcd: []string{
      "etcd_label",
    },
    //Redis: []string{
    //	"redis_label_bj",
    //"redis_label_sh",
    //},
    //Es: []string{
    //	"label_new",
    //	"label_rent",
    //	"label_sell",
    //},
    //Mysql: []string{
    //	"mysql_sell_1",
    //	"mysql_sell_2",
    //},
    //Mongo: []string{
    //	"mongo_label_bj",
    //	"mongo_label_sh",
    //},
  })

  if err != nil {
    panic(err)
  }

  for val := range time.Tick(time.Duration(3) * time.Second) {
    //****************************************test log
    Log.Error("start engine for test", val)

    //****************************************test mysql default user table
    //n, err := Mysql.New("mysql_sell_1")
    //if err != nil {
    //	fmt.Println("======error=====",err)
    //}
    //args := make(map[string]interface{})
    //args["table"] = "user"
    //args["query"] = " user = ? "
    //args["args"] = []interface{}{string("root")}
    //args["limit"] = 30
    //args["offset"] = 0
    //args["order"] = " host desc "
    //obj := make([]MysqlUser,100)
    //args["obj"] = &obj
    //n.List(context.TODO(), args)
    //fmt.Println(obj)

    //****************************************test postgres
    pgch, err := Postgres.GetConnChan()
    if err != nil {
      fmt.Println("---error", err)
    }
    if db, ok := <-pgch; ok {
      fmt.Println("zgo engine is niubility from postgres", db)
    }

    //****************************************test neo4j
    //neo4jch, err := Neo4j.GetConnChan()
    //if err != nil {
    //	fmt.Println("---error", err)
    //}
    //if neo, ok := <-neo4jch; ok {
    //	fmt.Println("zgo engine is niubility from neo4j", neo)
    //}

    //****************************************test etcd
    etcdch, err := Etcd.GetConnChan()
    if err != nil {
      fmt.Println("---error", err)
    }
    if etc, ok := <-etcdch; ok {
      fmt.Println("zgo engine is niubility from etcd", etc)
    }

    //****************************************test nsq
    //nq, err := Nsq.New()
    //if err != nil {
    //	fmt.Println("---error", err)
    //}
    //nq.Producer(context.TODO(), "origin", []byte("zgo engine is niubility from nsq"))

    //****************************************test kafka
    //kq, err := Kafka.New("kafka_label_bj")
    //if err != nil {
    //	fmt.Println("---error", err)
    //}
    //kq.Producer(context.TODO(), "origin", []byte("zgo engine is niubility from kafka"))

  }
}