调用示例

SQL检测调用示例

  1. func TsClient(order *pb.YearningAuditOrder) {
  3.     conn, err := grpc.Dial(address, grpc.WithInsecure())
  4.     if err != nil {
  5.         log.Fatalf("did not connect: %v", err)
  6.     }
  7.     defer conn.Close()
  8.     c := pb.NewJunoClient(conn)
  10.     ctx, cancel := context.WithTimeout(context.Background(), time.Second)
  11.     defer cancel()
  12.     r, err := c.OrderDeal(ctx, order)
  13.     if err != nil {
  14.         log.Fatalf("could not connect: %v", err)
  15.     }
  16.     for _, i := range r.Record {
  17.         fmt.Println(i.SQL)   // SQL语句
  18.         fmt.Println(i.Status) //审核状态
  19.         fmt.Println(i.Level)  // 错误等级
  20.         fmt.Println(i.Error) // 错误信息
  21.         fmt.Println(i.AffectRows) //影响行数
  22.     }
  23. }
  25. func TestTsClient(t *testing.T) {
  27.     s := pb.YearningAuditOrder{
  28.         SQL:      "CREATE TABLE `core_test` (`id` int unsigned AUTO_INCREMENT PRIMARY KEY COMMENT 'id',`username` varchar(50) NOT NULL COMMENT 'xxx')",
  29.         DataBase: "test01",
  30.         Source: &pb.Source{
  31.             Addr:     "127.0.0.1",
  32.             User:     "root",
  33.             Password: "xxxxxxx",
  34.             Port:     3306,
  35.         },
  36.         Check:  true,
  37.         WorkId: "201907292801",
  38.     }
  39.     TsClient(&s)
  40. }

DML/DDL 语句执行并备份示例

  1. func ExDDLClient(order *pb.YearningAuditOrder) {
  3.     // Set up a connection to the server.
  4.     conn, err := grpc.Dial(address, grpc.WithInsecure())
  5.     if err != nil {
  6.         log.Fatalf("did not connect: %v", err)
  7.     }
  8.     defer conn.Close()
  9.     c := pb.NewJunoClient(conn)
  11.     ctx, cancel := context.WithTimeout(context.Background(), time.Second)
  12.     defer cancel()
  13.     r, err := c.OrderDDLExec(ctx, order)
  14.     if err != nil {
  15.         log.Fatalf("could not connect: %v", err)
  16.     }
  17.     fmt.Println(r.Message)
  18. }
  20. func ExDMLClient(order *pb.YearningAuditOrder) {
  22.     // Set up a connection to the server.
  23.     conn, err := grpc.Dial(address, grpc.WithInsecure())
  24.     if err != nil {
  25.         log.Fatalf("did not connect: %v", err)
  26.     }
  27.     defer conn.Close()
  28.     c := pb.NewJunoClient(conn)
  30.     ctx, cancel := context.WithTimeout(context.Background(), time.Second)
  31.     defer cancel()
  32.     r, err := c.OrderDMLExec(ctx, order)
  33.     if err != nil {
  34.         log.Fatalf("could not connect: %v", err)
  35.     }
  36.     fmt.Println(r.Message)
  37. }
  39. func TestExDDLClient(t *testing.T) {
  41.     s := pb.YearningAuditOrder{
  42.         SQL:      "CREATE TABLE `core_grai32ned` (`id` int unsigned AUTO_INCREMENT PRIMARY KEY COMMENT 'id',`username` varchar(50) NOT NULL COMMENT 'xxx')",
  43.         DataBase: "test01",
  44.         Source: &pb.Source{
  45.             Addr:     "127.0.0.1",
  46.             User:     "root",
  47.             Password: "xxxxxxxx",
  48.             Port:     3306,
  49.         },
  50.         IsDML:   false,
  51.         Backup:  true,
  52.         Execute: true,
  53.         WorkId:  "201907292801",
  54.     }
  55.     ExDDLClient(&s)
  56. }
  58. func TestExDMLClient(t *testing.T) {
  60.     s := pb.YearningAuditOrder{
  61.         SQL:      "INSERT INTO `Yearning`.`b_test`(`id`,`idx`,`dateux`) VALUES(66732326,'321',NULL);",
  62.         DataBase: "test01",
  63.         Table:    "b_test",
  64.         Source: &pb.Source{
  65.             Addr:     "127.0.0.1",
  66.             User:     "root",
  67.             Password: "xxxxxxx",
  68.             Port:     3306,
  69.         },
  70.         IsDML:   true,
  71.         Backup:  true,
  72.         Execute: true,
  73.         WorkId:  "201907292801",
  74.     }
  75.     ExDMLClient(&s)
  76. }