close db when insert finished

Edgenesis · Sep 19, 2023 · db2b1c2 · db2b1c2
1 parent 5a19f6b
commit db2b1c2
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/telemetryservice/sql/mysql/mysql.go b/pkg/telemetryservice/sql/mysql/mysql.go
@@ -41,7 +41,7 @@ func (db *DBHelper) SendToDB(ctx context.Context, deviceName string, rawData []b
 		return err
 	}
 
-	return nil
+	return db.DB.Close()
 }
 
 func constructDBUri(sqlcs *v1alpha1.SQLConnectionSetting) string {

diff --git a/pkg/telemetryservice/sql/sqlserver/sqlserver.go b/pkg/telemetryservice/sql/sqlserver/sqlserver.go
@@ -41,7 +41,7 @@ func (db *DBHelper) SendToDB(ctx context.Context, deviceName string, rawData []b
 		return err
 	}
 
-	return nil
+	return db.DB.Close()
 }
 
 func constructDBUri(sqlcs *v1alpha1.SQLConnectionSetting) string {

diff --git a/pkg/telemetryservice/sql/tdengine/tdengine.go b/pkg/telemetryservice/sql/tdengine/tdengine.go
@@ -34,7 +34,7 @@ func (db *DBHelper) SendToDB(ctx context.Context, deviceName string, rawData []b
 		return err
 	}
 
-	return nil
+	return db.DB.Close()
 }
 
 func (db *DBHelper) ConnectToDB(ctx context.Context) error {