You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/09/26 07:10:59 UTC
(iotdb-client-go) 01/02: init
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch new_datatype
in repository https://gitbox.apache.org/repos/asf/iotdb-client-go.git
commit c92755dc272e0846219f2bce9aff0b31427d95cd
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Sep 19 09:54:40 2024 +0800
init
---
client/protocol.go | 54 +++++++++++++++++++++++++++---------------------------
client/session.go | 11 +++++++++++
2 files changed, 38 insertions(+), 27 deletions(-)
diff --git a/client/protocol.go b/client/protocol.go
index 883f9ae..edc211e 100644
--- a/client/protocol.go
+++ b/client/protocol.go
@@ -26,42 +26,42 @@ type TSEncoding uint8
type TSCompressionType uint8
const (
- UNKNOWN TSDataType = -1
- BOOLEAN TSDataType = 0
- INT32 TSDataType = 1
- INT64 TSDataType = 2
- FLOAT TSDataType = 3
- DOUBLE TSDataType = 4
- TEXT TSDataType = 5
+ UNKNOWN TSDataType = -1
+ BOOLEAN TSDataType = 0
+ INT32 TSDataType = 1
+ INT64 TSDataType = 2
+ FLOAT TSDataType = 3
+ DOUBLE TSDataType = 4
+ TEXT TSDataType = 5
+ TIMESTAMP TSDataType = 8
+ DATE TSDataType = 9
+ BLOB TSDataType = 10
+ STRING TSDataType = 11
)
const (
- PLAIN TSEncoding = 0
- PLAIN_DICTIONARY TSEncoding = 1
- RLE TSEncoding = 2
- DIFF TSEncoding = 3
- TS_2DIFF TSEncoding = 4
- BITMAP TSEncoding = 5
- GORILLA_V1 TSEncoding = 6
- REGULAR TSEncoding = 7
- GORILLA TSEncoding = 8
- ZIGZAG TSEncoding = 9
- FREQ TSEncoding = 10
- CHIMP TSEncoding = 11
- SPRINTZ TSEncoding = 12
- RLBE TSEncoding = 13
+ PLAIN TSEncoding = 0
+ DICTIONARY TSEncoding = 1
+ RLE TSEncoding = 2
+ DIFF TSEncoding = 3
+ TS_2DIFF TSEncoding = 4
+ BITMAP TSEncoding = 5
+ GORILLA_V1 TSEncoding = 6
+ REGULAR TSEncoding = 7
+ GORILLA TSEncoding = 8
+ ZIGZAG TSEncoding = 9
+ FREQ TSEncoding = 10
+ CHIMP TSEncoding = 11
+ SPRINTZ TSEncoding = 12
+ RLBE TSEncoding = 13
)
const (
UNCOMPRESSED TSCompressionType = 0
SNAPPY TSCompressionType = 1
GZIP TSCompressionType = 2
- LZO TSCompressionType = 3
- SDT TSCompressionType = 4
- PAA TSCompressionType = 5
- PLA TSCompressionType = 6
LZ4 TSCompressionType = 7
- ZSTD TSCompressionType = 8
+ ZSTD TSCompressionType = 8
LZMA2 TSCompressionType = 9
)
@@ -201,4 +201,4 @@ const (
CqAlreadyActive int32 = 1401
CqAlreadyExist int32 = 1402
CqUpdateLastExecTimeError int32 = 1403
-)
\ No newline at end of file
+)
diff --git a/client/session.go b/client/session.go
index 47985f8..6fc014b 100644
--- a/client/session.go
+++ b/client/session.go
@@ -952,6 +952,7 @@ func valuesToBytes(dataTypes []TSDataType, values []interface{}) ([]byte, error)
return nil, fmt.Errorf("values[%d] %v(%v) must be int32", i, v, reflect.TypeOf(v))
}
case INT64:
+ case TIMESTAMP:
switch v.(type) {
case int64:
binary.Write(buff, binary.BigEndian, v)
@@ -973,6 +974,16 @@ func valuesToBytes(dataTypes []TSDataType, values []interface{}) ([]byte, error)
return nil, fmt.Errorf("values[%d] %v(%v) must be float64", i, v, reflect.TypeOf(v))
}
case TEXT:
+ case STRING:
+ switch s := v.(type) {
+ case string:
+ size := len(s)
+ binary.Write(buff, binary.BigEndian, int32(size))
+ binary.Write(buff, binary.BigEndian, []byte(s))
+ default:
+ return nil, fmt.Errorf("values[%d] %v(%v) must be string", i, v, reflect.TypeOf(v))
+ }
+ case BLOB:
switch s := v.(type) {
case string:
size := len(s)