table_row.go 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641
  1. package operations
  2. import (
  3. "reflect"
  4. "time"
  5. )
  6. type TableRow struct {
  7. row map[string]any
  8. }
  9. func NewTableRow() *TableRow {
  10. return &TableRow{row: make(map[string]any)}
  11. }
  12. func NewTableRowFromMap(m map[string]any) *TableRow {
  13. tableRow := NewTableRow()
  14. for key, value := range m {
  15. v := value
  16. valueType := reflect.TypeOf(value)
  17. if valueType.Kind() == reflect.Ptr {
  18. v = reflect.ValueOf(value).Elem().Interface()
  19. }
  20. switch typedValue := v.(type) {
  21. case string:
  22. tableRow.row[key] = typedValue
  23. case int:
  24. tableRow.row[key] = uint64(typedValue)
  25. case uint:
  26. tableRow.row[key] = uint64(typedValue)
  27. case int8:
  28. tableRow.row[key] = uint64(typedValue)
  29. case uint8:
  30. tableRow.row[key] = uint64(typedValue)
  31. case int16:
  32. tableRow.row[key] = uint64(typedValue)
  33. case uint16:
  34. tableRow.row[key] = uint64(typedValue)
  35. case int32:
  36. tableRow.row[key] = uint64(typedValue)
  37. case uint32:
  38. tableRow.row[key] = uint64(typedValue)
  39. case int64:
  40. tableRow.row[key] = uint64(typedValue)
  41. case uint64:
  42. tableRow.row[key] = typedValue
  43. case float32:
  44. tableRow.row[key] = float64(typedValue)
  45. case float64:
  46. tableRow.row[key] = typedValue
  47. case bool:
  48. tableRow.row[key] = typedValue
  49. case []byte:
  50. tableRow.row[key] = typedValue
  51. case time.Time:
  52. tableRow.row[key] = typedValue
  53. default:
  54. panic("未支持的数据类型")
  55. }
  56. }
  57. return tableRow
  58. }
  59. func (tableRow *TableRow) ToMap() map[string]any {
  60. return tableRow.row
  61. }
  62. func (tableRow *TableRow) Len() int {
  63. return len(tableRow.row)
  64. }
  65. func (tableRow *TableRow) Empty() bool {
  66. return len(tableRow.row) == 0
  67. }
  68. func (tableRow *TableRow) AddColumnValueTime(columnName string, value time.Time) *TableRow {
  69. tableRow.row[columnName] = value
  70. return tableRow
  71. }
  72. func (tableRow *TableRow) AddColumnValueBool(columnName string, value bool) *TableRow {
  73. tableRow.row[columnName] = value
  74. return tableRow
  75. }
  76. func (tableRow *TableRow) AddColumnValueString(columnName string, value string) *TableRow {
  77. tableRow.row[columnName] = value
  78. return tableRow
  79. }
  80. func (tableRow *TableRow) AddColumnValueBytes(columnName string, value []byte) *TableRow {
  81. tableRow.row[columnName] = value
  82. return tableRow
  83. }
  84. func (tableRow *TableRow) AddColumnValueInt(columnName string, value int) *TableRow {
  85. tableRow.row[columnName] = uint64(value)
  86. return tableRow
  87. }
  88. func (tableRow *TableRow) AddColumnValueInt8(columnName string, value int8) *TableRow {
  89. tableRow.row[columnName] = uint64(value)
  90. return tableRow
  91. }
  92. func (tableRow *TableRow) AddColumnValueInt16(columnName string, value int16) *TableRow {
  93. tableRow.row[columnName] = uint64(value)
  94. return tableRow
  95. }
  96. func (tableRow *TableRow) AddColumnValueInt32(columnName string, value int32) *TableRow {
  97. tableRow.row[columnName] = uint64(value)
  98. return tableRow
  99. }
  100. func (tableRow *TableRow) AddColumnValueInt64(columnName string, value int64) *TableRow {
  101. tableRow.row[columnName] = uint64(value)
  102. return tableRow
  103. }
  104. func (tableRow *TableRow) AddColumnValueUint(columnName string, value uint) *TableRow {
  105. tableRow.row[columnName] = uint64(value)
  106. return tableRow
  107. }
  108. func (tableRow *TableRow) AddColumnValueUint8(columnName string, value uint8) *TableRow {
  109. tableRow.row[columnName] = uint64(value)
  110. return tableRow
  111. }
  112. func (tableRow *TableRow) AddColumnValueUint16(columnName string, value uint16) *TableRow {
  113. tableRow.row[columnName] = uint64(value)
  114. return tableRow
  115. }
  116. func (tableRow *TableRow) AddColumnValueUint32(columnName string, value uint32) *TableRow {
  117. tableRow.row[columnName] = uint64(value)
  118. return tableRow
  119. }
  120. func (tableRow *TableRow) AddColumnValueUint64(columnName string, value uint64) *TableRow {
  121. tableRow.row[columnName] = value
  122. return tableRow
  123. }
  124. func (tableRow *TableRow) AddColumnValueFloat32(columnName string, value float32) *TableRow {
  125. tableRow.row[columnName] = float64(value)
  126. return tableRow
  127. }
  128. func (tableRow *TableRow) AddColumnValueFloat64(columnName string, value float64) *TableRow {
  129. tableRow.row[columnName] = value
  130. return tableRow
  131. }
  132. func (tableRow *TableRow) AddColumnValueTimePtr(columnName string, value *time.Time) *TableRow {
  133. if value == nil {
  134. value = &time.Time{}
  135. }
  136. tableRow.row[columnName] = *value
  137. return tableRow
  138. }
  139. func (tableRow *TableRow) AddColumnValueBoolPtr(columnName string, value *bool) *TableRow {
  140. if value == nil {
  141. v := false
  142. value = &v
  143. }
  144. tableRow.row[columnName] = *value
  145. return tableRow
  146. }
  147. func (tableRow *TableRow) AddColumnValueStringPtr(columnName string, value *string) *TableRow {
  148. if value == nil {
  149. v := ""
  150. value = &v
  151. }
  152. tableRow.row[columnName] = *value
  153. return tableRow
  154. }
  155. func (tableRow *TableRow) AddColumnValueBytesPtr(columnName string, value *[]byte) *TableRow {
  156. if value == nil {
  157. v := make([]byte, 0)
  158. value = &v
  159. }
  160. tableRow.row[columnName] = *value
  161. return tableRow
  162. }
  163. func (tableRow *TableRow) AddColumnValueIntPtr(columnName string, value *int) *TableRow {
  164. if value == nil {
  165. v := 0
  166. value = &v
  167. }
  168. tableRow.row[columnName] = uint64(*value)
  169. return tableRow
  170. }
  171. func (tableRow *TableRow) AddColumnValueInt8Ptr(columnName string, value *int8) *TableRow {
  172. if value == nil {
  173. v := int8(0)
  174. value = &v
  175. }
  176. tableRow.row[columnName] = uint64(*value)
  177. return tableRow
  178. }
  179. func (tableRow *TableRow) AddColumnValueInt16Ptr(columnName string, value *int16) *TableRow {
  180. if value == nil {
  181. v := int16(0)
  182. value = &v
  183. }
  184. tableRow.row[columnName] = uint64(*value)
  185. return tableRow
  186. }
  187. func (tableRow *TableRow) AddColumnValueInt32Ptr(columnName string, value *int32) *TableRow {
  188. if value == nil {
  189. v := int32(0)
  190. value = &v
  191. }
  192. tableRow.row[columnName] = uint64(*value)
  193. return tableRow
  194. }
  195. func (tableRow *TableRow) AddColumnValueInt64Ptr(columnName string, value *int64) *TableRow {
  196. if value == nil {
  197. v := int64(0)
  198. value = &v
  199. }
  200. tableRow.row[columnName] = uint64(*value)
  201. return tableRow
  202. }
  203. func (tableRow *TableRow) AddColumnValueUintPtr(columnName string, value *uint) *TableRow {
  204. if value == nil {
  205. v := uint(0)
  206. value = &v
  207. }
  208. tableRow.row[columnName] = uint64(*value)
  209. return tableRow
  210. }
  211. func (tableRow *TableRow) AddColumnValueUint8Ptr(columnName string, value *uint8) *TableRow {
  212. if value == nil {
  213. v := uint8(0)
  214. value = &v
  215. }
  216. tableRow.row[columnName] = uint64(*value)
  217. return tableRow
  218. }
  219. func (tableRow *TableRow) AddColumnValueUint16Ptr(columnName string, value *uint16) *TableRow {
  220. if value == nil {
  221. v := uint16(0)
  222. value = &v
  223. }
  224. tableRow.row[columnName] = uint64(*value)
  225. return tableRow
  226. }
  227. func (tableRow *TableRow) AddColumnValueUint32Ptr(columnName string, value *uint32) *TableRow {
  228. if value == nil {
  229. v := uint32(0)
  230. value = &v
  231. }
  232. tableRow.row[columnName] = uint64(*value)
  233. return tableRow
  234. }
  235. func (tableRow *TableRow) AddColumnValueUint64Ptr(columnName string, value *uint64) *TableRow {
  236. if value == nil {
  237. v := uint64(0)
  238. value = &v
  239. }
  240. tableRow.row[columnName] = *value
  241. return tableRow
  242. }
  243. func (tableRow *TableRow) AddColumnValueFloat32Ptr(columnName string, value *float32) *TableRow {
  244. if value == nil {
  245. v := float32(0)
  246. value = &v
  247. }
  248. tableRow.row[columnName] = float64(*value)
  249. return tableRow
  250. }
  251. func (tableRow *TableRow) AddColumnValueFloat64Ptr(columnName string, value *float64) *TableRow {
  252. if value == nil {
  253. v := float64(0)
  254. value = &v
  255. }
  256. tableRow.row[columnName] = *value
  257. return tableRow
  258. }
  259. func (tableRow *TableRow) ColumnValueTime(columnName string) time.Time {
  260. value, ok := tableRow.row[columnName].(time.Time)
  261. if !ok {
  262. return time.Time{}
  263. }
  264. return value
  265. }
  266. func (tableRow *TableRow) ColumnValueBool(columnName string) bool {
  267. value, ok := tableRow.row[columnName].(bool)
  268. if !ok {
  269. return false
  270. }
  271. return value
  272. }
  273. func (tableRow *TableRow) ColumnValueString(columnName string) string {
  274. value, ok := tableRow.row[columnName].(string)
  275. if !ok {
  276. return ""
  277. }
  278. return value
  279. }
  280. func (tableRow *TableRow) ColumnValueBytes(columnName string) []byte {
  281. value, ok := tableRow.row[columnName].([]byte)
  282. if !ok {
  283. return make([]byte, 0)
  284. }
  285. return value
  286. }
  287. func (tableRow *TableRow) ColumnValueInt(columnName string) int {
  288. value, ok := tableRow.row[columnName].(uint64)
  289. if !ok {
  290. return 0
  291. }
  292. return int(value)
  293. }
  294. func (tableRow *TableRow) ColumnValueInt8(columnName string) int8 {
  295. value, ok := tableRow.row[columnName].(uint64)
  296. if !ok {
  297. return 0
  298. }
  299. return int8(value)
  300. }
  301. func (tableRow *TableRow) ColumnValueInt16(columnName string) int16 {
  302. value, ok := tableRow.row[columnName].(uint64)
  303. if !ok {
  304. return 0
  305. }
  306. return int16(value)
  307. }
  308. func (tableRow *TableRow) ColumnValueInt32(columnName string) int32 {
  309. value, ok := tableRow.row[columnName].(uint64)
  310. if !ok {
  311. return 0
  312. }
  313. return int32(value)
  314. }
  315. func (tableRow *TableRow) ColumnValueInt64(columnName string) int64 {
  316. value, ok := tableRow.row[columnName].(uint64)
  317. if !ok {
  318. return 0
  319. }
  320. return int64(value)
  321. }
  322. func (tableRow *TableRow) ColumnValueUint(columnName string) uint {
  323. value, ok := tableRow.row[columnName].(uint64)
  324. if !ok {
  325. return 0
  326. }
  327. return uint(value)
  328. }
  329. func (tableRow *TableRow) ColumnValueUint8(columnName string) uint8 {
  330. value, ok := tableRow.row[columnName].(uint64)
  331. if !ok {
  332. return 0
  333. }
  334. return uint8(value)
  335. }
  336. func (tableRow *TableRow) ColumnValueUint16(columnName string) uint16 {
  337. value, ok := tableRow.row[columnName].(uint64)
  338. if !ok {
  339. return 0
  340. }
  341. return uint16(value)
  342. }
  343. func (tableRow *TableRow) ColumnValueUint32(columnName string) uint32 {
  344. value, ok := tableRow.row[columnName].(uint64)
  345. if !ok {
  346. return 0
  347. }
  348. return uint32(value)
  349. }
  350. func (tableRow *TableRow) ColumnValueUint64(columnName string) uint64 {
  351. value, ok := tableRow.row[columnName].(uint64)
  352. if !ok {
  353. return 0
  354. }
  355. return value
  356. }
  357. func (tableRow *TableRow) ColumnValueFloat32(columnName string) float32 {
  358. value, ok := tableRow.row[columnName].(float64)
  359. if !ok {
  360. return 0
  361. }
  362. return float32(value)
  363. }
  364. func (tableRow *TableRow) ColumnValueFloat64(columnName string) float64 {
  365. value, ok := tableRow.row[columnName].(float64)
  366. if !ok {
  367. return 0
  368. }
  369. return value
  370. }
  371. func (tableRow *TableRow) ColumnValueTimePtr(columnName string) *time.Time {
  372. value, ok := tableRow.row[columnName].(time.Time)
  373. if !ok {
  374. value = time.Time{}
  375. }
  376. return &value
  377. }
  378. func (tableRow *TableRow) ColumnValueBoolPtr(columnName string) *bool {
  379. value, ok := tableRow.row[columnName].(bool)
  380. if !ok {
  381. value = false
  382. }
  383. return &value
  384. }
  385. func (tableRow *TableRow) ColumnValueStringPtr(columnName string) *string {
  386. value, ok := tableRow.row[columnName].(string)
  387. if !ok {
  388. value = ""
  389. }
  390. return &value
  391. }
  392. func (tableRow *TableRow) ColumnValueBytesPtr(columnName string) *[]byte {
  393. value, ok := tableRow.row[columnName].([]byte)
  394. if !ok {
  395. value = make([]byte, 0)
  396. }
  397. return &value
  398. }
  399. func (tableRow *TableRow) ColumnValueIntPtr(columnName string) *int {
  400. v, ok := tableRow.row[columnName].(uint64)
  401. if !ok {
  402. v = 0
  403. }
  404. var value int
  405. value = int(v)
  406. return &value
  407. }
  408. func (tableRow *TableRow) ColumnValueInt8Ptr(columnName string) *int8 {
  409. v, ok := tableRow.row[columnName].(uint64)
  410. if !ok {
  411. v = 0
  412. }
  413. var value int8
  414. value = int8(v)
  415. return &value
  416. }
  417. func (tableRow *TableRow) ColumnValueInt16Ptr(columnName string) *int16 {
  418. v, ok := tableRow.row[columnName].(uint64)
  419. if !ok {
  420. v = 0
  421. }
  422. var value int16
  423. value = int16(v)
  424. return &value
  425. }
  426. func (tableRow *TableRow) ColumnValueInt32Ptr(columnName string) *int32 {
  427. v, ok := tableRow.row[columnName].(uint64)
  428. if !ok {
  429. v = 0
  430. }
  431. var value int32
  432. value = int32(v)
  433. return &value
  434. }
  435. func (tableRow *TableRow) ColumnValueInt64Ptr(columnName string) *int64 {
  436. v, ok := tableRow.row[columnName].(uint64)
  437. if !ok {
  438. v = 0
  439. }
  440. var value int64
  441. value = int64(v)
  442. return &value
  443. }
  444. func (tableRow *TableRow) ColumnValueUintPtr(columnName string) *uint {
  445. v, ok := tableRow.row[columnName].(uint64)
  446. if !ok {
  447. v = 0
  448. }
  449. var value uint
  450. value = uint(v)
  451. return &value
  452. }
  453. func (tableRow *TableRow) ColumnValueUint8Ptr(columnName string) *uint8 {
  454. v, ok := tableRow.row[columnName].(uint64)
  455. if !ok {
  456. v = 0
  457. }
  458. var value uint8
  459. value = uint8(v)
  460. return &value
  461. }
  462. func (tableRow *TableRow) ColumnValueUint16Ptr(columnName string) *uint16 {
  463. v, ok := tableRow.row[columnName].(uint64)
  464. if !ok {
  465. v = 0
  466. }
  467. var value uint16
  468. value = uint16(v)
  469. return &value
  470. }
  471. func (tableRow *TableRow) ColumnValueUint32Ptr(columnName string) *uint32 {
  472. v, ok := tableRow.row[columnName].(uint64)
  473. if !ok {
  474. v = 0
  475. }
  476. var value uint32
  477. value = uint32(v)
  478. return &value
  479. }
  480. func (tableRow *TableRow) ColumnValueUint64Ptr(columnName string) *uint64 {
  481. v, ok := tableRow.row[columnName].(uint64)
  482. if !ok {
  483. v = 0
  484. }
  485. var value uint64
  486. value = uint64(v)
  487. return &value
  488. }
  489. func (tableRow *TableRow) ColumnValueFloat32Ptr(columnName string) *float32 {
  490. v, ok := tableRow.row[columnName].(float64)
  491. if !ok {
  492. v = 0
  493. }
  494. var value float32
  495. value = float32(v)
  496. return &value
  497. }
  498. func (tableRow *TableRow) ColumnValueFloat64Ptr(columnName string) *float64 {
  499. v, ok := tableRow.row[columnName].(float64)
  500. if !ok {
  501. v = 0
  502. }
  503. var value float64
  504. value = float64(v)
  505. return &value
  506. }