调用示例

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

    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.         log.Fatalf("did not connect: %v", err)
    26.     defer conn.Close()
    27.     c := pb.NewJunoClient(conn)
    29.     ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    30.     defer cancel()
    31.     r, err := c.OrderDMLExec(ctx, order)
    32.     if err != nil {
    33.         log.Fatalf("could not connect: %v", err)
    34.     }
    35.     fmt.Println(r.Message)
    36. }
    38. func TestExDDLClient(t *testing.T) {
    40.     s := pb.YearningAuditOrder{
    41.         SQL:      "CREATE TABLE `core_grai32ned` (`id` int unsigned AUTO_INCREMENT PRIMARY KEY COMMENT 'id',`username` varchar(50) NOT NULL COMMENT 'xxx')",
    42.         DataBase: "test01",
    43.         Source: &pb.Source{
    44.             Addr:     "127.0.0.1",
    45.             User:     "root",
    46.             Password: "xxxxxxxx",
    47.             Port:     3306,
    48.         },
    50.         Execute: true,
    51.         WorkId:  "201907292801",
    52.     }
    53.     ExDDLClient(&s)
    54. }
    56. func TestExDMLClient(t *testing.T) {
    58.     s := pb.YearningAuditOrder{
    59.         SQL:      "INSERT INTO `Yearning`.`b_test`(`id`,`idx`,`dateux`) VALUES(66732326,'321',NULL);",
    60.         DataBase: "test01",
    61.         Table:    "b_test",
    62.         Source: &pb.Source{
    63.             Addr:     "127.0.0.1",
    64.             User:     "root",
    65.             Password: "xxxxxxx",
    66.             Port:     3306,
    67.         },
    68.         IsDML:   true,
    69.         Backup:  true,
    70.         Execute: true,
    71.         WorkId:  "201907292801",
    72.     }
    73.     ExDMLClient(&s)