11package sql
22
33import (
4+ "testing"
5+
46 bulker "github.com/jitsucom/bulker/bulkerlib"
57 "github.com/jitsucom/bulker/jitsubase/utils"
6- "testing"
78)
89
910func TestNaming (t * testing.T ) {
@@ -18,7 +19,7 @@ func TestNaming(t *testing.T) {
1819 expectedRowsCount : 1 ,
1920 expectedTableCaseChecking : true ,
2021 expectedTable : ExpectedTable {
21- Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_e" , "camelCase" , "int" , "user" , "select" , "__ROOT__" , "hash" , "default" ),
22+ Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_e" , "camelCase" , "int" , "user" , "select" , "__ROOT__" , "hash" , "default" , "current_time" ),
2223 },
2324 configIds : utils .ArrayExcluding (allBulkerConfigs , RedshiftBulkerTypeId + "_serverless" , RedshiftBulkerTypeId + "_iam" , RedshiftBulkerTypeId , SnowflakeBulkerTypeId , BigqueryBulkerTypeId , ClickHouseBulkerTypeId , ClickHouseBulkerTypeId + "_cluster" , ClickHouseBulkerTypeId + "_cluster_noshards" ),
2425 },
@@ -31,7 +32,7 @@ func TestNaming(t *testing.T) {
3132 expectedRowsCount : 1 ,
3233 expectedTableCaseChecking : true ,
3334 expectedTable : ExpectedTable {
34- Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_eni" , "camelCase" , "int" , "user" , "select" , "__ROOT__" , "hash" , "default" ),
35+ Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_eni" , "camelCase" , "int" , "user" , "select" , "__ROOT__" , "hash" , "default" , "current_time" ),
3536 },
3637 configIds : []string {ClickHouseBulkerTypeId },
3738 },
@@ -47,7 +48,7 @@ func TestNaming(t *testing.T) {
4748 expectedTableCaseChecking : false ,
4849 expectedRowsCount : 1 ,
4950 expectedTable : ExpectedTable {
50- Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_eni" , "camelCase" , "int" , "user" , "select" , "__ROOT__" , "hash" , "default" ),
51+ Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_eni" , "camelCase" , "int" , "user" , "select" , "__ROOT__" , "hash" , "default" , "current_time" ),
5152 //Columns: justColumns("id", "name", "column_12b241e808ae6c964a5bb9f1c012e63d", "1test_name", "2", "column_c16da609b86c01f16a2c609eac4ccb0c", "test name", "test name drop database public select 1 from dual", "université français", "_timestamp", "_unnamed", "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_eni", "странное имя", "秒速センチメートル", "camelcase", "int", "user", "select","__root__"),
5253 },
5354 configIds : []string {RedshiftBulkerTypeId + "_serverless" , RedshiftBulkerTypeId + "_iam" , RedshiftBulkerTypeId },
@@ -61,7 +62,7 @@ func TestNaming(t *testing.T) {
6162 expectedTableCaseChecking : true ,
6263 expectedRowsCount : 1 ,
6364 expectedTable : ExpectedTable {
64- Columns : justColumns ("ID" , "NAME" , "_TIMESTAMP" , "COLUMN_C16DA609B86C01F16A2C609EAC4CCB0C" , "COLUMN_12B241E808AE6C964A5BB9F1C012E63D" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_UNNAMED" , "LOREM_IPSUM_DOLOR_SIT_AMET_CONSECTETUR_ADIPISCING_ELIT_SED_DO_EIUSMOD_TEMPOR_INCIDIDUNT_UT_LABORE_ET_DOLORE_MAGNA_ALIQUA_UT_ENIM_AD_MINIM_VENIAM_QUIS_NOSTRUD_EXERCITATION_ULLAMCO_LABORIS_NISI_UT_ALIQUIP_EX_EA_COMMODO_CONSEQUAT" , "camelCase" , "INT" , "USER" , "SELECT" , "__ROOT__" , "HASH" , "DEFAULT" ),
65+ Columns : justColumns ("ID" , "NAME" , "_TIMESTAMP" , "COLUMN_C16DA609B86C01F16A2C609EAC4CCB0C" , "COLUMN_12B241E808AE6C964A5BB9F1C012E63D" , "秒速_センチメートル" , "Université Français" , "Странное Имя" , "Test Name_ DROP DATABASE public_ SELECT 1 from DUAL_" , "Test Name" , "1test_name" , "2" , "_UNNAMED" , "LOREM_IPSUM_DOLOR_SIT_AMET_CONSECTETUR_ADIPISCING_ELIT_SED_DO_EIUSMOD_TEMPOR_INCIDIDUNT_UT_LABORE_ET_DOLORE_MAGNA_ALIQUA_UT_ENIM_AD_MINIM_VENIAM_QUIS_NOSTRUD_EXERCITATION_ULLAMCO_LABORIS_NISI_UT_ALIQUIP_EX_EA_COMMODO_CONSEQUAT" , "camelCase" , "INT" , "USER" , "SELECT" , "__ROOT__" , "HASH" , "DEFAULT" , "_CURRENT_TIME" ),
6566 },
6667 configIds : []string {SnowflakeBulkerTypeId },
6768 },
@@ -74,7 +75,7 @@ func TestNaming(t *testing.T) {
7475 expectedTableCaseChecking : true ,
7576 expectedTable : ExpectedTable {
7677 Name : "strangetablename_replace_table" ,
77- Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "université français" , "странное имя" , "test name_ drop database public_ select 1 from dual_" , "test name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_e" , "camelcase" , "int" , "user" , "select" , "__root__" , "hash" , "default" ),
78+ Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "秒速_センチメートル" , "université français" , "странное имя" , "test name_ drop database public_ select 1 from dual_" , "test name" , "1test_name" , "2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_e" , "camelcase" , "int" , "user" , "select" , "__root__" , "hash" , "default" , "current_time" ),
7879 },
7980 streamOptions : []bulker.StreamOption {bulker .WithToSameCase ()},
8081 configIds : []string {PostgresBulkerTypeId },
@@ -88,7 +89,7 @@ func TestNaming(t *testing.T) {
8889 expectedRowsCount : 1 ,
8990 expectedTable : ExpectedTable {
9091 Name : "STRANGETABLENAME_BATCH" ,
91- Columns : justColumns ("ID" , "NAME" , "_TIMESTAMP" , "COLUMN_C16DA609B86C01F16A2C609EAC4CCB0C" , "COLUMN_12B241E808AE6C964A5BB9F1C012E63D" , "秒速_センチメートル" , "UNIVERSITÉ FRANÇAIS" , "СТРАННОЕ ИМЯ" , "TEST NAME_ DROP DATABASE PUBLIC_ SELECT 1 FROM DUAL_" , "TEST NAME" , "1TEST_NAME" , "2" , "_UNNAMED" , "LOREM_IPSUM_DOLOR_SIT_AMET_CONSECTETUR_ADIPISCING_ELIT_SED_DO_EIUSMOD_TEMPOR_INCIDIDUNT_UT_LABORE_ET_DOLORE_MAGNA_ALIQUA_UT_ENIM_AD_MINIM_VENIAM_QUIS_NOSTRUD_EXERCITATION_ULLAMCO_LABORIS_NISI_UT_ALIQUIP_EX_EA_COMMODO_CONSEQUAT" , "CAMELCASE" , "INT" , "USER" , "SELECT" , "__ROOT__" , "HASH" , "DEFAULT" ),
92+ Columns : justColumns ("ID" , "NAME" , "_TIMESTAMP" , "COLUMN_C16DA609B86C01F16A2C609EAC4CCB0C" , "COLUMN_12B241E808AE6C964A5BB9F1C012E63D" , "秒速_センチメートル" , "UNIVERSITÉ FRANÇAIS" , "СТРАННОЕ ИМЯ" , "TEST NAME_ DROP DATABASE PUBLIC_ SELECT 1 FROM DUAL_" , "TEST NAME" , "1TEST_NAME" , "2" , "_UNNAMED" , "LOREM_IPSUM_DOLOR_SIT_AMET_CONSECTETUR_ADIPISCING_ELIT_SED_DO_EIUSMOD_TEMPOR_INCIDIDUNT_UT_LABORE_ET_DOLORE_MAGNA_ALIQUA_UT_ENIM_AD_MINIM_VENIAM_QUIS_NOSTRUD_EXERCITATION_ULLAMCO_LABORIS_NISI_UT_ALIQUIP_EX_EA_COMMODO_CONSEQUAT" , "CAMELCASE" , "INT" , "USER" , "SELECT" , "__ROOT__" , "HASH" , "DEFAULT" , "_CURRENT_TIME" ),
9293 },
9394 configIds : []string {SnowflakeBulkerTypeId },
9495 streamOptions : []bulker.StreamOption {bulker .WithToSameCase ()},
@@ -103,7 +104,7 @@ func TestNaming(t *testing.T) {
103104 expectedRowsCount : 1 ,
104105 expectedTable : ExpectedTable {
105106 PKFields : []string {"id" },
106- Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "column_b4de5a5c8f92f77af9904705b3f08253" , "Universit_Franais" , "column_c41d0d6c9ff6db34c6df393bdd283e19" , "Test_Name__DROP_DATABASE_public__SELECT_1_from_DUAL_" , "Test_Name" , "_1test_name" , "_2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_enim_ad_minim_veniam_quis_nostrud_exercitation_ullamco_laboris_nisi_ut_aliquip_ex_ea_commodo_consequat" , "camelCase" , "int" , "user" , "select" , "___ROOT__" , "hash" , "default" ),
107+ Columns : justColumns ("id" , "name" , "_timestamp" , "column_c16da609b86c01f16a2c609eac4ccb0c" , "column_12b241e808ae6c964a5bb9f1c012e63d" , "column_b4de5a5c8f92f77af9904705b3f08253" , "Universit_Franais" , "column_c41d0d6c9ff6db34c6df393bdd283e19" , "Test_Name__DROP_DATABASE_public__SELECT_1_from_DUAL_" , "Test_Name" , "_1test_name" , "_2" , "_unnamed" , "lorem_ipsum_dolor_sit_amet_consectetur_adipiscing_elit_sed_do_eiusmod_tempor_incididunt_ut_labore_et_dolore_magna_aliqua_ut_enim_ad_minim_veniam_quis_nostrud_exercitation_ullamco_laboris_nisi_ut_aliquip_ex_ea_commodo_consequat" , "camelCase" , "int" , "user" , "select" , "___ROOT__" , "hash" , "default" , "current_time" ),
107108 },
108109 configIds : []string {BigqueryBulkerTypeId },
109110 streamOptions : []bulker.StreamOption {bulker .WithPrimaryKey ("id" ), bulker .WithDeduplicate ()},
0 commit comments