|
1 | 1 | import os |
2 | 2 |
|
3 | | -_ENVISIONWARE_QUERY = ''' |
| 3 | +_ENVISIONWARE_QUERY = """ |
4 | 4 | SELECT |
5 | | - pcrKey, pcrUserID, pcrMinutesUsed, pcrDateTime, pcrBranch, |
6 | | - pcrArea, pcrUserData1 |
| 5 | + pcrKey, pcrUserID, pcrMinutesUsed, pcrDateTime, pcrBranch, pcrArea, pcrUserData1 |
7 | 6 | FROM strad_bci |
8 | 7 | WHERE pcrDateTime > '{date_time}' |
9 | 8 | OR (pcrDateTime = '{date_time}' AND pcrKey > {key}) |
10 | | - ORDER BY pcrDateTime, pcrKey LIMIT {limit};''' |
11 | | - |
12 | | -_SIERRA_QUERY = ''' |
13 | | - SELECT barcode, id, ptype_code, home_library_code, pcode3 |
| 9 | + ORDER BY pcrDateTime, pcrKey |
| 10 | + LIMIT {limit};""" |
| 11 | + |
| 12 | +_SIERRA_QUERY = """ |
| 13 | + SELECT |
| 14 | + barcode, id, ptype_code, pcode3, |
| 15 | + CASE WHEN LENGTH(TRIM(home_library_code)) = 0 |
| 16 | + OR TRIM(home_library_code) = 'none' THEN NULL |
| 17 | + ELSE TRIM(home_library_code) END |
14 | 18 | FROM sierra_view.patron_view |
15 | | - WHERE barcode IN ({});''' |
| 19 | + WHERE barcode IN ({});""" |
16 | 20 |
|
17 | | -_REDSHIFT_QUERY = ''' |
| 21 | +_REDSHIFT_QUERY = """ |
18 | 22 | SELECT patron_id, postal_code, geoid |
19 | 23 | FROM {table} |
20 | | - WHERE patron_id IN ({ids});''' |
| 24 | + WHERE patron_id IN ({ids});""" |
21 | 25 |
|
22 | 26 |
|
23 | 27 | def build_envisionware_query(date_time, key): |
24 | 28 | return _ENVISIONWARE_QUERY.format( |
25 | | - date_time=date_time, key=key, |
26 | | - limit=os.environ['ENVISIONWARE_BATCH_SIZE']) |
| 29 | + date_time=date_time, key=key, limit=os.environ["ENVISIONWARE_BATCH_SIZE"] |
| 30 | + ) |
27 | 31 |
|
28 | 32 |
|
29 | 33 | def build_sierra_query(barcodes): |
|
0 commit comments