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