@@ -6,25 +6,25 @@ QMHASH=QmPpCt1aYGb9JWJRmXRUnmJtVgeFFTJGzWFYEEX7bo9zGJ
6
6
7
7
echo " drop table if exists ontime_200;" | $MYSQL_CLIENT_CONNECT
8
8
9
- # # Create table
10
- cat $CURDIR /../ddl/ontime.sql | sed " s/ontime/ontime_200/g" | $MYSQL_CLIENT_CONNECT
9
+ # # # Create table
10
+ # cat $CURDIR/../ddl/ontime.sql | sed "s/ontime/ontime_200/g" | $MYSQL_CLIENT_CONNECT
11
11
12
- copy_from_location_cases=(
13
- # copy csv
14
- " copy into ontime_200 from 'ipfs://$QMHASH /ontime.csv' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' record_delimiter = '\n' skip_header = 1)"
15
- # copy gzip csv
16
- " copy into ontime_200 from 'ipfs://$QMHASH /ontime.csv.gz' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' compression = 'gzip' record_delimiter = '\n' skip_header = 1)"
17
- # copy zstd csv
18
- " copy into ontime_200 from 'ipfs://$QMHASH /ontime.csv.zst' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' compression = 'zstd' record_delimiter = '\n' skip_header = 1)"
19
- # copy bz2 csv
20
- " copy into ontime_200 from 'ipfs://$QMHASH /ontime.csv.bz2' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' compression = 'bz2' record_delimiter = '\n' skip_header = 1)"
21
- )
12
+ # copy_from_location_cases=(
13
+ # # copy csv
14
+ # "copy into ontime_200 from 'ipfs://$QMHASH/ontime.csv' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' record_delimiter = '\n' skip_header = 1)"
15
+ # # copy gzip csv
16
+ # "copy into ontime_200 from 'ipfs://$QMHASH/ontime.csv.gz' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' compression = 'gzip' record_delimiter = '\n' skip_header = 1)"
17
+ # # copy zstd csv
18
+ # "copy into ontime_200 from 'ipfs://$QMHASH/ontime.csv.zst' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' compression = 'zstd' record_delimiter = '\n' skip_header = 1)"
19
+ # # copy bz2 csv
20
+ # "copy into ontime_200 from 'ipfs://$QMHASH/ontime.csv.bz2' CONNECTION = (ENDPOINT_URL='https://ipfs.filebase.io') FILE_FORMAT = (type = 'CSV' field_delimiter = ',' compression = 'bz2' record_delimiter = '\n' skip_header = 1)"
21
+ # )
22
22
23
- for i in " ${copy_from_location_cases[@]} " ; do
24
- echo " $i " | $MYSQL_CLIENT_CONNECT
25
- echo " select count(1), avg(Year), sum(DayOfWeek) from ontime_200" | $MYSQL_CLIENT_CONNECT
26
- echo " truncate table ontime_200" | $MYSQL_CLIENT_CONNECT
27
- done
23
+ # for i in "${copy_from_location_cases[@]}"; do
24
+ # echo "$i" | $MYSQL_CLIENT_CONNECT
25
+ # echo "select count(1), avg(Year), sum(DayOfWeek) from ontime_200" | $MYSQL_CLIENT_CONNECT
26
+ # echo "truncate table ontime_200" | $MYSQL_CLIENT_CONNECT
27
+ # done
28
28
29
- # # Drop table
30
- echo " drop table if exists ontime_200;" | $MYSQL_CLIENT_CONNECT
29
+ # # # Drop table
30
+ # echo "drop table if exists ontime_200;" | $MYSQL_CLIENT_CONNECT
0 commit comments