查询方法增加查询字段

client.info.go

@@ -5,7 +5,7 @@ import (
 	"errors"
 )
 
-func Get(site_id, dbname, id string, url ...string) (map[string]string, error) {
+func Get(site_id, dbname, id string, field string, url ...string) (map[string]string, error) {
 
 	if dbname == "" || id == "" {
 		return nil, errors.New("参数错误")
@@ -17,7 +17,7 @@ func Get(site_id, dbname, id string, url ...string) (map[string]string, error) {
 	}
 	defer conn.Close()
 
-	arg := GetParam{site_id, dbname, id}
+	arg := ReqParam{site_id, dbname, id, field}
 
 	req, err := SetReqData(arg)
 	if err != nil {
@@ -48,3 +48,47 @@ func Get(site_id, dbname, id string, url ...string) (map[string]string, error) {
 	return res_arr, nil
 
 }
+
+func Get380Star(site_id, dbname string, field string, url ...string) (map[string]string, error) {
+
+	if dbname == "" {
+		return nil, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	arg := ReqParam{site_id, dbname, "", field}
+
+	req, err := SetReqData(arg)
+	if err != nil {
+		return nil, err
+	}
+	res := &Response{}
+
+	err = conn.Get380Star(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return res_arr, nil
+
+}

client.info_test.go

@@ -7,9 +7,9 @@ import (
 func Test_Get(t *testing.T) {
 	siteid := "1056475"
 	dbname := "shop_v2"
-	key := "2"
+	key := "*"
 
-	res, err := Get(siteid, dbname, key)
+	res, err := Get380Star(siteid, dbname, key)
 	t.Log(res)
 	t.Log(err)
 

variable.go

@@ -17,3 +17,10 @@ type BoolRet struct {
 	Value bool   `json:"value"`
 	Msg   string `json:"msg"`
 }
+
+type ReqParam struct {
+	SiteId string `json:"site_id"`
+	Dbname string `json:"database"`
+	Id     string `json:"id"`
+	Field  string `json:"field"`
+}