add: more examples

examples/README.md

@@ -13,5 +13,9 @@ docker run --rm -p 4000-4003:4000-4003 \
 
 ## Examples
 
-- [write table](table/README.md)
-- [write object](object/README.md)
+- [table](table/README.md)
+- [object](object/README.md)
+
+## Query
+
+Your can using [MySQL Client](https://docs.greptime.com/user-guide/clients/mysql) to query the data from GreptimeDB.

examples/object/README.md

@@ -9,40 +9,29 @@ go run main.go
 Output:
 
 ```log
-2024/02/07 11:26:26 affected rows: 2
+2024/03/23 22:36:06 affected rows: 3
+2024/03/23 22:36:06 affected rows: 3
+2024/03/23 22:36:06 affected rows: 1
+2024/03/23 22:36:06 affected rows: 3
+2024/03/23 22:36:06 affected rows: 3
+2024/03/23 22:36:06 affected rows: 1
 ```
 
 ## Query
 
-```shell
-2024/02/18 11:14:54 affected rows: 2
-2024/02/18 11:14:54 affected rows: 2
-```
+Your can using [MySQL Client](https://docs.greptime.com/user-guide/clients/mysql) to query the data from GreptimeDB.
 
 ```shell
-Reading table information for completion of table and column names
-You can turn off this feature to get a quicker startup with -A
-
-Welcome to the MySQL monitor.  Commands end with ; or \g.
-Your MySQL connection id is 8
-Server version: 5.1.10-alpha-msql-proxy Greptime
-
-Copyright (c) 2000, 2023, Oracle and/or its affiliates.
-
-Oracle is a registered trademark of Oracle Corporation and/or its
-affiliates. Other names may be trademarks of their respective
-owners.
-
-Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
+$ mysql -h 127.0.0.1 -P 4002 public
 
 mysql> select * from monitors_with_tag;
 +------+-----------+--------+------+-------------+---------+----------------------------+
 | id   | host      | memory | cpu  | temperature | running | ts                         |
 +------+-----------+--------+------+-------------+---------+----------------------------+
-|    1 | 127.0.0.1 |      1 |    1 |          -1 |       1 | 2024-02-18 03:14:54.116000 |
-|    1 | 127.0.0.1 |      1 |    1 |          -1 |       1 | 2024-02-18 03:14:54.242000 |
-|    2 | 127.0.0.2 |      2 |    2 |          -2 |       1 | 2024-02-18 03:14:54.116000 |
-|    2 | 127.0.0.2 |      2 |    2 |          -2 |       1 | 2024-02-18 03:14:54.242000 |
+|    1 | 127.0.0.1 |      1 |  1.1 |          -1 |       1 | 2024-03-23 14:36:06.591000 |
+|    1 | 127.0.0.1 |      1 |  1.1 |          -1 |       1 | 2024-03-23 14:36:06.732000 |
+|    2 | 127.0.0.2 |      2 |    2 |          -2 |       1 | 2024-03-23 14:36:06.591000 |
+|    2 | 127.0.0.2 |      2 |    2 |          -2 |       1 | 2024-03-23 14:36:06.732000 |
 +------+-----------+--------+------+-------------+---------+----------------------------+
-4 rows in set (0.01 sec)
+4 rows in set (0.12 sec)
 ```

examples/object/main.go

@@ -50,7 +50,7 @@ func (Monitor) TableName() string {
 	return "monitors_with_tag"
 }
 
-func data() []Monitor {
+func initData() []Monitor {
 	return []Monitor{
 		{
 			ID:          1,
@@ -70,25 +70,58 @@ func data() []Monitor {
 			Ts:          time.Now(),
 			Running:     true,
 		},
+		{
+			ID:          3,
+			Host:        "127.0.0.3",
+			Memory:      3,
+			Cpu:         3.0,
+			Temperature: -3,
+			Ts:          time.Now(),
+			Running:     true,
+		},
 	}
 }
+func writeObject(data []Monitor) {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
+	defer cancel()
 
-func writeObject() {
+	resp, err := client.WriteObject(ctx, data)
+	if err != nil {
+		log.Fatal(err)
+	}
+	log.Printf("affected rows: %d\n", resp.GetAffectedRows().GetValue())
+}
+
+func deleteObject(data []Monitor) {
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
 	defer cancel()
 
-	resp, err := client.WriteObject(ctx, data())
+	resp, err := client.DeleteObject(ctx, data)
 	if err != nil {
 		log.Fatal(err)
 	}
 	log.Printf("affected rows: %d\n", resp.GetAffectedRows().GetValue())
 }
 
-func streamWriteObject() {
+func streamWriteObject(data []Monitor) {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
+	defer cancel()
+
+	if err := client.StreamWriteObject(ctx, data); err != nil {
+		log.Println(err)
+	}
+	affected, err := client.CloseStream(ctx)
+	if err != nil {
+		log.Fatalln(err)
+	}
+	log.Printf("affected rows: %d\n", affected.GetValue())
+}
+
+func streamDeleteObject(data []Monitor) {
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
 	defer cancel()
 
-	if err := client.StreamWriteObject(ctx, data()); err != nil {
+	if err := client.StreamDeleteObject(ctx, data); err != nil {
 		log.Println(err)
 	}
 	affected, err := client.CloseStream(ctx)
@@ -99,7 +132,23 @@ func streamWriteObject() {
 }
 
 func main() {
-	writeObject()
+	data := initData()
+	// insert
+	writeObject(data)
+	// update
+	data[0].Cpu = 1.1
+	writeObject(data)
+	// delete
+	deleteObject(data[2:])
+
 	time.Sleep(time.Millisecond * 100)
-	streamWriteObject()
+
+	data = initData()
+	// stream insert
+	streamWriteObject(data)
+	data[0].Cpu = 1.1
+	// stream update
+	streamWriteObject(data)
+	// stream delete
+	streamDeleteObject(data[2:])
 }