fix: add support for multiple data source type starting with MySQL

poligonoio · Jul 27, 2024 · 86dd57a · 86dd57a
1 parent 2c36846
commit 86dd57a
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/internal/services/trino.engine.impl.service.go b/internal/services/trino.engine.impl.service.go
@@ -45,15 +45,13 @@ func (self *TrinoEngineServiceImpl) Query(query string, dest interface{}) error
 	rows, err := self.db.Query(query)
 	if err != nil {
 		logger.Error.Printf("Failed to get data from data source: %v\n", err)
-		logger.Error.Printf("Query: \n\n%s\n\n", query)
 		return err
 	}
 
 	var columns []string
 	columns, err = rows.Columns()
 	if err != nil {
 		logger.Error.Printf("Failed to get data from data source: %v\n", err)
-		logger.Error.Printf("Query: \n\n%s\n\n", query)
 		return err
 	}
 
@@ -72,7 +70,6 @@ func (self *TrinoEngineServiceImpl) Query(query string, dest interface{}) error
 		err = rows.Scan(r...)
 		if err != nil {
 			logger.Error.Printf("Failed to get data from data source: %v\n", err)
-			logger.Error.Printf("Query: \n\n%s\n\n", query)
 			return err
 		}
 
@@ -108,15 +105,13 @@ func (self *TrinoEngineServiceImpl) GetRawData(query string) ([]map[string]inter
 
 	if err != nil {
 		logger.Error.Printf("Failed to get data from data source: %v\n", err)
-		logger.Error.Printf("Query: \n\n%s\n\n", query)
 		return nil, err
 	}
 
 	var columns []string
 	columns, err = rows.Columns()
 	if err != nil {
 		logger.Error.Printf("Failed to get data from data source: %v\n", err)
-		logger.Error.Printf("Query: \n\n%s\n\n", query)
 		return nil, err
 	}
 
@@ -135,7 +130,6 @@ func (self *TrinoEngineServiceImpl) GetRawData(query string) ([]map[string]inter
 		err = rows.Scan(r...)
 		if err != nil {
 			logger.Error.Printf("Failed to get data from data source: %v\n", err)
-			logger.Error.Printf("Query: \n\n%s\n\n", query)
 			return nil, err
 		}