Commit graph

114 commits

Author SHA1 Message Date
facetosea
0fc2091ca3 fix: crash 2025-06-27 09:55:48 +08:00
facetosea
8462a1055f feat: get vginfo for exec 2025-06-26 18:34:18 +08:00
facetosea
954b7dea12 fix: get dbvg info 2025-06-26 10:55:45 +08:00
facetosea
7c068ee472 fix: set datainsert msg to vnode 2025-06-24 17:17:29 +08:00
facetosea
1c5fd414d5 log: add log 2025-06-24 14:10:38 +08:00
Jinqing Kuang
85fad8e178 Merge branch '3.0' into temp 2025-06-23 18:08:09 +08:00
facetosea
07a6a7a1eb fix: data insert using null tag 2025-06-23 09:13:19 +08:00
Mario Peng
c65e1592fa
feat:insert into subquery (#31401) 2025-06-21 15:11:09 +08:00
facetosea
1dd505b570 enh: put data log 2025-06-19 18:08:16 +08:00
facetosea
2aed4fca48 fix: data inserter cache key 2025-06-19 10:52:55 +08:00
facetosea
ee5da7d522 fix: log 2025-06-19 10:03:01 +08:00
facetosea
061137c11a fix: data insert suid error 2025-06-18 17:05:06 +08:00
facetosea
b15d94fd90 fix: datainserter cache 2025-06-18 13:56:27 +08:00
facetosea
08ba1864a3 fix: spell error 2025-06-07 17:57:07 +08:00
facetosea
34c85401a1 feat: data insert vgid changed 2025-06-05 16:23:07 +08:00
facetosea
734e09a22f fix: table uid hash cache 2025-05-29 11:30:28 +08:00
facetosea
cdd445513e feat: data cache 2025-05-28 18:08:15 +08:00
factosea
6234b3a48b fix: build tschema 2025-05-28 16:31:09 +08:00
factosea
efc8187f28 fix: return submit res code 2025-05-27 18:25:56 +08:00
wangmm0220
9772e9846c fix(stream): error if %%n with varchar tag 2025-05-26 19:56:41 +08:00
facetosea
20902279d3 fix: sversion when create subtable 2025-05-20 18:35:59 +08:00
facetosea
585a3a7960 fix: create table 2025-05-20 17:20:42 +08:00
facetosea
403b35a049 fix: create subtable 2025-05-20 16:19:38 +08:00
facetosea
3c27b2c14c feat: datainsert, super table 2025-05-20 14:27:17 +08:00
facetosea
1942ae210c feat: data sink 2025-05-17 18:25:41 +08:00
factosea
2860309b6c fix: crate subtable tags 2025-05-17 14:13:08 +08:00
wangjiaming0909
5300a66f5e new-stream: runner impl 2025-05-16 01:41:31 +00:00
factosea
d37770936c fix: tag name 2025-05-15 16:02:40 +08:00
facetosea
a93c63053c feat: build insert data 2025-05-14 19:38:26 +08:00
facetosea
0a7ac81aeb fix: table schema version start from 1 2025-05-14 17:41:51 +08:00
facetosea
11760abea2 fix: subtable schema check when table has exist 2025-05-14 11:12:14 +08:00
facetosea
c913791ffb fix: clear decoder 2025-05-12 11:16:09 +08:00
facetosea
b0a9169dd7 fix: insertcallback, tdecoder clear 2025-05-12 11:06:52 +08:00
facetosea
b0e0d0e565 fix: data insert, table version changed 2025-05-12 10:22:28 +08:00
facetosea
1946123ac1 fix: tbname 2025-05-10 14:32:01 +08:00
facetosea
a4e2e1a0b8 feat: normal table version 2025-05-09 17:17:51 +08:00
facetosea
a11fc0d7cd fix: data insert, build STSchema 2025-05-09 17:05:56 +08:00
factosea
9ab3fcd062 fix: datainsert 2025-05-09 14:34:45 +08:00
factosea
1fafaae137 fix: save table uid 2025-05-09 10:03:35 +08:00
factosea
e4dd28df92 feat inserter param check 2025-05-08 23:00:37 +08:00
factosea
cd9a532064 feat: data inserter 2025-05-08 15:07:04 +08:00
factosea
f3027e938e feat: stream data insert 2025-05-08 09:48:53 +08:00
factosea
b88406554c enh: auto create table mode 2025-05-07 11:16:07 +08:00
pengrongkun94@qq.com
820a0101ae feat:add auto create table 2025-05-07 11:06:12 +08:00
pengrongkun94@qq.com
245dc41644 feat:fetch pVgInfo from server 2025-05-07 11:06:02 +08:00
pengrongkun94@qq.com
d0eb0c5962 fix:invalid but no error output 2025-05-07 11:05:52 +08:00
wangjiaming
f50fcb85b8
feat(decimal): support decimal data type (#30060)
* decimal: create table

* decimal: add test case decimal.py

* decimal: add decimal.c

* support input decimal

* decimal test

* refactor svalue

* fix test cases

* add decimal unit test

* add decimal test cmake

* support insert and query decimal type

* define wide integer, support decimal128

* support decimal128 divide

* set decimal type expr res types

* scalar decimal

* convert to decimal

* fix decimal64/128 from str and to str

* fix decimal from str and decimal to str

* decimal simple conversion

* unit test for decimal

* decimal conversion and unit tests

* decimal + - * /

* decimal scalar ops and comparision

* start to refactor GET_TYPED_DATA

* support decimal max func, cast func

* refactor GET_TYPED_DATA interface

* decimal scalar comparision

* start to implement sum for decimal

* support sum and avg for decimal type

* decimal tests

* add decimal test

* decimal add test cases

* decimal use int256/int128

* decimal testing

* fix decimal table meta and add tests for decimal col streams

* fix create stream and create tsma

* test insert decimal values

* decimal from str

* test decimal input

* test parse decimal from string

* add taos_fetch_field_e api

* decimal insert tests

* test decimal operators

* decimal operator test

* feat:support decimal in raw block

* decimal operator tests

* decimal test

* feat:support decimal in raw block

* feat:support decimal in raw block

* feat:add schemaExt to SMqDataRsp

* feat:remove add schemaExt to SMqDataRsp

* feat:remove add schemaExt to SMqDataRsp

* feat:remove add schemaExt to SMqDataRsp

* decimal test operators

* decimal operator test

* test decimal operators

* test decimal compare operators

* decimal unary operator test

* decimal col with decimal col oper test

* test decimal col filtering

* fix decimal float operator test

* decimal test where filtering

* fix decimal filtering

* fix decimal order by

* fix decimal op test

* test decimal agg funcs

* test decimal functions

* remove assert

* fix ci build for ret check

* fix decimal windows build

* fix ci ret check

* skip decimal ret check

* skip decimal ret check

* fix decimal tests

* fix decimal ci test

* decimal test

* fix(tmq): heap user after free

* fix(tmq): double free

* fix(tmq): double free

* fix decimal tests

* fix(decimal): decimal test ci build

* fix(decimal): windows build

* fix(decimal): decimal test build

* fix(decimal): fix decimal build and tests

* fix(decimal): fix decimal tests

* fix(decimal): fix taos_fetch_fields_e api

* fix(decimal): fix decimal taos_fetch_fields_e api

* fix(decimal): rebase 3.0

* fix(decimal): fix decimal functions

* fix(decimal): fix decimal test case memory leak

* fix(decimal): fix decimal tests

* fix(decimal): fix decimal test case

* fix(decimal): fix decimal tests

* feat(decimal): fix unit tests

* feat(decimal): fix deicmal unit test

---------

Co-authored-by: wangmm0220 <wangmm0220@gmail.com>
Co-authored-by: yihaoDeng <yhdeng@taosdata.com>
2025-03-14 18:08:07 +08:00
wangmm0220
3fb2ec432e fix:[TS-5776]add raw type from consumer 2025-01-22 17:40:59 +08:00
dapan1121
85fc4dfc2b fix: data sink memory issues 2024-11-15 10:16:15 +08:00
dapan1121
411d61504f fix: remove taosMem calling 2024-11-11 09:09:40 +08:00