Skip to content

Commit 4df05fc

Browse files
author
David Stirling
committed
Don't destroy all rows when checking mysql tables
1 parent 3a15b41 commit 4df05fc

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

cpa/dbconnect.py

+2-3
Original file line numberDiff line numberDiff line change
@@ -1654,11 +1654,10 @@ def CreateObjectCheckedTable(self):
16541654
if DB_TYPE == 'mysql':
16551655
if len(AreaShape_Area) > 0:
16561656
query = f"""CREATE OR REPLACE VIEW {p.object_table} AS SELECT {', '.join(all_cols)} FROM {object_table}
1657-
WHERE {" IS NOT NULL AND ".join(all_cols)} IS NOT NULL AND {" != '' AND ".join(all_cols)} != '' AND {
1658-
" > 0 AND ".join(AreaShape_Area)} > 0"""
1657+
WHERE {" IS NOT NULL AND ".join(all_cols)} IS NOT NULL AND {" > 0 AND ".join(AreaShape_Area)} > 0"""
16591658
else:
16601659
query = f"""CREATE OR REPLACE VIEW {p.object_table} AS SELECT {', '.join(all_cols)} FROM {object_table}
1661-
WHERE {" IS NOT NULL AND ".join(all_cols)} IS NOT NULL AND {" != '' AND ".join(all_cols)} != ''"""
1660+
WHERE {" IS NOT NULL AND ".join(all_cols)} IS NOT NULL"""
16621661
self.execute(query)
16631662
elif DB_TYPE == 'sqlite':
16641663
# SQL can only handle 1000 comparisons in a query. If we have too many columns we'll need to break it up.

0 commit comments

Comments
 (0)