Changeset bf76088 in observatorio for simulacion/SimEscenariosEconomicos

Timestamp:

Jan 12, 2015, 8:47:12 AM (9 years ago)

Author:

Alejandro <amujica@…>

Branches:

simulacion

Children:

23daf5e

Parents:

666042a

Message:

agrupacion de los proveedores registrados varias veces por un mismo comprador

File:

• simulacion/SimEscenariosEconomicos/queries.C (modified) (3 diffs)

simulacion/SimEscenariosEconomicos/queries.C

@@ -197 +197 @@
 }
 
+std::string getSupplierName(const std::string & rif) {
+
+    AutoConnection conn;
+
+    DBQuery query(conn);
+
+    StrQuery strQuery;
+
+    strQuery.addSelect(DB::NAME);
+    strQuery.addFrom(DB::SUPPLIER_TABLE_NAME);
+    strQuery.addWhere(op(DB::RIF, singleQuote(rif)));
+
+    if (not query.exec(strQuery)) {
+
+        std::string msg = "Cannot execute query: " + std::string(strQuery);
+
+        throw std::logic_error(msg);
+    }
+
+    if (not query.next()) {
+
+        std::stringstream msg;
+
+        msg << "Supplier with R.I.F. = " << rif
+            << " does not exists in database";
+
+        throw std::domain_error(msg.str());
+    }
+
+    return query.getValue(0);
+}
+
 void listInputs(const size_t & inputId, const std::string & year,
                 List <InputInfo> & inputs) {
@@ -258 +290 @@
     query.clear();
 
-    strQuery.addSelect(concatas(DB::SUPPLIER_TABLE_NAME, DB::ID));
-    strQuery.addSelect(concatas(DB::SUPPLIER_TABLE_NAME, DB::NAME));
-    strQuery.addSelect(concatas(DB::SUPPLIER_TABLE_NAME, DB::RIF));
-    strQuery.addSelect(concatas(DB::SUPPLIER_TABLE_NAME, DB::NATIONALITY));
-    strQuery.addSelect(concatas(DB::INPUT_SUPPLIER_TABLE_NAME,
-                                 DB::BOUGHT_QUANTITY));
-
-    strQuery.addFrom(DB::INPUT_SUPPLIER_TABLE_NAME);
-    strQuery.addFrom(DB::SUPPLIER_TABLE_NAME);
-      
-    strQuery.addWhere(op(concat(DB::INPUT_SUPPLIER_TABLE_NAME, DB::YEAR_R),
-                         year));
-    strQuery.addWhere(op(concat(DB::INPUT_SUPPLIER_TABLE_NAME, DB::INPUT_ID),
-                         idToStr(inputId)));
-    strQuery.addWhere(op(concat(DB::INPUT_SUPPLIER_TABLE_NAME,
-                                DB::SUPPLIER_ID),
-                         concat(DB::SUPPLIER_TABLE_NAME, DB::ID)));
-
-    if (not query.exec(strQuery)) {
-
-        std::string msg = "Cannot execute query: " + std::string(strQuery);
+    std::string sum = "SUM(" + concat(DB::INPUT_SUPPLIER_TABLE_NAME,
+                                      DB::BOUGHT_QUANTITY)
+                             + ") AS " +
+                       concat(DB::INPUT_SUPPLIER_TABLE_NAME,
+                              DB::BOUGHT_QUANTITY, '_');
+
+    std::string strquery =
+      "SELECT " +
+      concatas(DB::SUPPLIER_TABLE_NAME, DB::RIF) + ',' +
+      concatas(DB::SUPPLIER_TABLE_NAME, DB::NATIONALITY) + ',' + sum +
+      " FROM " +
+      DB::INPUT_SUPPLIER_TABLE_NAME + ',' +
+      DB::SUPPLIER_TABLE_NAME +
+      " WHERE " +
+      op(concat(DB::INPUT_SUPPLIER_TABLE_NAME, DB::YEAR_R), year) + " AND " +
+      op(concat(DB::INPUT_SUPPLIER_TABLE_NAME, DB::INPUT_ID),
+                         idToStr(inputId)) + " AND " +
+      op(concat(DB::INPUT_SUPPLIER_TABLE_NAME, DB::SUPPLIER_ID),
+         concat(DB::SUPPLIER_TABLE_NAME, DB::ID)) +
+      " GROUP BY " +
+      concat(DB::SUPPLIER_TABLE_NAME, DB::RIF, '_') + ',' +
+      concat(DB::SUPPLIER_TABLE_NAME, DB::NATIONALITY, '_');
+
+
+    if (not query.exec(strquery)) {
+
+        std::string msg = "Cannot execute query: " + strquery;
 
         throw std::logic_error(msg);
@@ -287 +325 @@
         inputInfo.companyRif =
             query.getValue(concat(DB::SUPPLIER_TABLE_NAME, DB::RIF, '_'));
-        inputInfo.companyName =
-            query.getValue(concat(DB::SUPPLIER_TABLE_NAME, DB::NAME, '_'));
+        inputInfo.companyName = getSupplierName(inputInfo.companyRif);
         inputInfo.quantity = std::atof(
             query.getValue(concat(DB::INPUT_SUPPLIER_TABLE_NAME,