DB implementation for binding store

Signed-off-by: Alexandros Filios <[email protected]>

platform/view/services/db/driver/sql/common/binding.go

@@ -70,9 +70,9 @@ func (db *BindingPersistence) HaveSameBinding(this, that view.Identity) (bool, e
 func (db *BindingPersistence) PutBinding(ephemeral, longTerm view.Identity) error {
 	query := fmt.Sprintf(
 		"INSERT INTO %s (ephemeral_hash, long_term_id) "+
-			"SELECT ($1, long_term_id) FROM %s WHERE ephemeral_hash=$2",
-		db.table, db.table)
-	result, err := db.writeDB.Exec(query, ephemeral.UniqueID(), longTerm.UniqueID())
+			"SELECT '%s', long_term_id FROM %s WHERE ephemeral_hash=$1",
+		db.table, ephemeral.UniqueID(), db.table)
+	result, err := db.writeDB.Exec(query, longTerm.UniqueID())
 	if err != nil {
 		return errors.Wrapf(err, "failed executing query [%s]", query)
 	}
@@ -91,8 +91,16 @@ func (db *BindingPersistence) PutBinding(ephemeral, longTerm view.Identity) erro
 	}
 
 	logger.Debugf("Long term ID not seen before. Registering it as long term...")
-	query = fmt.Sprintf("INSERT INTO %s (ephemeral_hash, long_term_id) VALUES (($1, $2), ($3, $4))", db.table)
-	if _, err = db.writeDB.Exec(query, longTerm.UniqueID(), longTerm, ephemeral.UniqueID(), longTerm); err != nil {
+	//query = fmt.Sprintf("INSERT INTO %s (ephemeral_hash, long_term_id) VALUES ($1, $2), ($3, $4)", db.table)
+	//if _, err = db.writeDB.Exec(query, longTerm.UniqueID(), longTerm, ephemeral.UniqueID(), longTerm); err != nil {
+	//	return errors.Wrapf(err, "failed inserting long-term id and ephemeral id")
+	//}
+	query = fmt.Sprintf("INSERT INTO %s (ephemeral_hash, long_term_id) VALUES ($1, $2)", db.table)
+	if _, err = db.writeDB.Exec(query, longTerm.UniqueID(), longTerm); err != nil {
+		return errors.Wrapf(err, "failed inserting long-term id and ephemeral id")
+	}
+	query = fmt.Sprintf("INSERT INTO %s (ephemeral_hash, long_term_id) VALUES ($1, $2)", db.table)
+	if _, err = db.writeDB.Exec(query, ephemeral.UniqueID(), longTerm); err != nil {
 		return errors.Wrapf(err, "failed inserting long-term id and ephemeral id")
 	}
 	logger.Infof("Long-term and ephemeral ids registered [%s,%s]", longTerm, ephemeral)