hongbo-miao/hongbomiao.com

conn = database('hm-trino', 'hadoop', '');

eventId = 'ad7953cd-6d49-4929-8180-99555bebc255';
fieldNames = {'current', 'voltage', 'temperature'};

columnNames = strjoin(fieldNames, ', ');
sqlQuery = [
            'with ', ...
            't0 as (select * from delta.production_hm_delta_db.motor_data_0 where _event_id = ''', eventId, '''), ', ...
            't1 as (select * from delta.production_hm_delta_db.motor_data_1 where _event_id = ''', eventId, '''), ', ...
            't2 as (select * from delta.production_hm_delta_db.motor_data_2 where _event_id = ''', eventId, '''), ', ...
            't3 as (select * from delta.production_hm_delta_db.motor_data_3 where _event_id = ''', eventId, '''), ', ...
            't4 as (select * from delta.production_hm_delta_db.motor_data_4 where _event_id = ''', eventId, '''), ', ...
            't5 as (select * from delta.production_hm_delta_db.motor_data_5 where _event_id = ''', eventId, '''), ', ...
            't6 as (select * from delta.production_hm_delta_db.motor_data_6 where _event_id = ''', eventId, '''), ', ...
            't7 as (select * from delta.production_hm_delta_db.motor_data_7 where _event_id = ''', eventId, '''), ', ...
            't8 as (select * from delta.production_hm_delta_db.motor_data_8 where _event_id = ''', eventId, '''), ', ...
            't9 as (select * from delta.production_hm_delta_db.motor_data_9 where _event_id = ''', eventId, '''), ', ...
            'ta as (select * from delta.production_hm_delta_db.motor_data_a where _event_id = ''', eventId, '''), ', ...
            'tb as (select * from delta.production_hm_delta_db.motor_data_b where _event_id = ''', eventId, '''), ', ...
            'tc as (select * from delta.production_hm_delta_db.motor_data_c where _event_id = ''', eventId, '''), ', ...
            'td as (select * from delta.production_hm_delta_db.motor_data_d where _event_id = ''', eventId, '''), ', ...
            'te as (select * from delta.production_hm_delta_db.motor_data_e where _event_id = ''', eventId, '''), ', ...
            'tf as (select * from delta.production_hm_delta_db.motor_data_f where _event_id = ''', eventId, ''') ', ...
            'select from_unixtime_nanos(t0._time) as _time, ', columnNames, ' ', ...
            'from t0 ', ...
            'join t1 on t0._time = t1._time ', ...
            'join t2 on t0._time = t2._time ', ...
            'join t3 on t0._time = t3._time ', ...
            'join t4 on t0._time = t4._time ', ...
            'join t5 on t0._time = t5._time ', ...
            'join t6 on t0._time = t6._time ', ...
            'join t7 on t0._time = t7._time ', ...
            'join t8 on t0._time = t8._time ', ...
            'join t9 on t0._time = t9._time ', ...
            'join ta on t0._time = ta._time ', ...
            'join tb on t0._time = tb._time ', ...
            'join tc on t0._time = tc._time ', ...
            'join td on t0._time = td._time ', ...
            'join te on t0._time = te._time ', ...
            'join tf on t0._time = tf._time ', ...
            'order by _time asc'
           ];
data = fetch(conn, sqlQuery);

close(conn);

clear columnNames;
clear conn;
clear fieldNames;
clear sqlQuery;