File tree Expand file tree Collapse file tree 2 files changed +19
-0
lines changed Expand file tree Collapse file tree 2 files changed +19
-0
lines changed Original file line number Diff line number Diff line change @@ -103,4 +103,13 @@ spark-sql> select * from test_db.tbl_sql;
1031032022-02-02 10:10:10 2 2 2
1041042022-02-02 10:10:10 2 2 2
105105Time taken: 0.123 seconds, Fetched 6 row(s)
106+
107+ spark-sql> delete from test_db.tbl_sql where id = 1;
108+ Time taken: 0.129 seconds
109+
110+ spark-sql> select * from test_db.tbl_sql;
111+ 2022-02-02 10:10:10 2 2 2
112+ 2022-02-02 10:10:10 2 2 2
113+ 2022-02-02 10:10:10 2 2 2
114+ Time taken: 0.101 seconds, Fetched 3 row(s)
106115```
Original file line number Diff line number Diff line change @@ -98,6 +98,16 @@ scala> spark.table("test_db.tbl").show
9898|2021-01-01 10:10:10| 1| 1| 1|
9999|2022-02-02 10:10:10| 2| 2| 2|
100100+-------------------+---+---+-----+
101+
102+ scala> spark.sql("DELETE FROM test_db.tbl WHERE id=1")
103+ res3: org.apache.spark.sql.DataFrame = []
104+
105+ scala> spark.table("test_db.tbl").show
106+ +-------------------+---+---+-----+
107+ | create_time| m| id|value|
108+ +-------------------+---+---+-----+
109+ |2022-02-02 10:10:10| 2| 2| 2|
110+ +-------------------+---+---+-----+
101111```
102112
103113Execute ClickHouse native SQL.
You can’t perform that action at this time.
0 commit comments