Rewriting "Add records" dialog. Added relations records view.

dm.py

@@ -142,13 +142,13 @@ def createTables(tbl_list):
     return tbl_names_list
 
 def initDBstructure():
-    global tbl_descr_list, template_file
+    global tbl_descr_list, template_file, tblNamesList
     table_list = open(template_file, "r", encoding="utf-8")
     data = json.load(table_list, encoding="utf-8")
     tbl_list = data["tables"]
-    tbl_names_list = createTables(tbl_list)
+    tblNamesList = createTables(tbl_list)
 
-    return tbl_names_list
+    return tblNamesList
 
 # выборка данных из заданной таблицы
 def selectData(tbl):
@@ -278,11 +278,84 @@ def insertDataIntoBD(dataList):
 
     qwery = qwery + qweryField.rstrip(',') + ')' + ' VALUES (' + qweryData.rstrip(',') + ');'
 
-    print(qwery)
+    #print(qwery)
     c.execute(qwery)
     #c.close()
     return
 
+# Выборка данных по значению
+# принимает на вход название таблицы, назване поля, значение этого поля
+def selectDataFromDB(tblName, fieldName, fieldValue):
+    global tbl_struct_list, c, db_type
+    qwery = "SELECT "
+    subqwery = ""
+    for item in tbl_struct_list:
+        if item[0] == tblName:
+            for field in item[1]:
+                field = field[0]
+                qwery = qwery + field + ","
+            for rel in item[2]:
+                field = rel[0]
+                fieldRel = rel[1][0]
+                fieldReplace = rel[1][1]
+                #field_replace = field_replace.replace(",", ",' ',")
+                #field_replace = field_replace.replace(",", " || ")
+                # определяем название таблицы для вложенного запроса
+                table1 = fieldRel.split('.')[0]
+                field1 = fieldRel.split('.')[1]
+                if table1 == tblName:
+                    table1 = table1 + "_1"
+                    subqwery = tblName + " AS " +table1
+                else:
+                    subqwery = table1
+                # составляем подзапрос и подменяем им поле в запросе
+                if db_type == "mysql":
+                    fieldReplace = fieldReplace.replace(",", ",' ',")
+                    subqwery = "(SELECT CONCAT(" + fieldReplace + ") FROM " + subqwery + " WHERE " + table1 + "." + field1 + "=" + tblName + "." + field + ") AS " + field
+                elif db_type == "sqlite":
+                    field_replace = fieldReplace.replace(",", " || ' ' ||")
+                    subqwery = "(SELECT (" + fieldReplace + ") FROM " + subqwery +" WHERE "+ table1 + "." + field1 +"="+ tblName +"."+ field +") AS " + field
+                qwery = qwery.replace(field, subqwery)
+    #qwery = qwery.rstrip(',') + " FROM " + tblName + " LIMIT 10000"
+    qwery = qwery.rstrip(',') + " FROM " + tblName + " WHERE " + fieldName + '=' + fieldValue
+    #print(qwery)
+    c.execute(qwery)
+    return c.fetchall()
+
+def selectRelationsDataFromDB(tblSearch, fieldName, fieldValue):
+    global tbl_struct_list, c, db_type
+    #print("Ищем связи для:" +tblSearch +','+ fieldName +','+fieldValue)
+    #print(tbl_struct_list)
+    searchField = tblSearch + '.' + fieldName
+    dataList = []
+    for item in tbl_struct_list:
+        #print(item)
+        tblName = item[0]
+        for field in item[1]:
+            field = field[0]
+        for rel in item[2]:
+            if rel[1][0] == searchField:
+                #print("таблица:" + tblName + "поле:"+ rel[0] + 'Значение:' + fieldValue)
+                data = selectDataFromDB(tblName, rel[0], fieldValue)
+                #print(data)
+                dataList.append([tblName, data])
+    return dataList
+
+# Ищем название таблицы по её описанию
+def getTablesNameOfDescription(tblDescr):
+    global tblNamesList
+    for i in tblNamesList:
+        if i[1] == tblDescr:
+            return(i[0])
+
+# Ищем описание таблицы по её названию
+def getTablesDescriptionOfName(tblName):
+    global tblNamesList
+    for i in tblNamesList:
+        if i[0] == tblName:
+            return(i[1])
+
+
 
 #initDBstructure()
 firstInit()