Minor performance improvement and go test addition

src/client.rs

@@ -1711,8 +1711,8 @@ where
             return Ok(());
         }
 
-        let client_given_name = Parse::get_name(&message)?;
         let parse: Parse = (&message).try_into()?;
+        let client_given_name = &parse.name;
 
         // Compute the hash of the parse statement
         let hash = parse.get_hash();
@@ -1734,7 +1734,7 @@ where
         );
 
         self.prepared_statements
-            .insert(client_given_name, (new_parse.clone(), hash));
+            .insert(client_given_name.clone(), (new_parse.clone(), hash));
 
         self.extended_protocol_data_buffer
             .push_back(ExtendedProtocolData::create_new_parse(

tests/go/prepared_test.go

@@ -4,8 +4,10 @@ import (
 	"context"
 	"database/sql"
 	"fmt"
-	_ "github.com/lib/pq"
+	"sync"
 	"testing"
+
+	_ "github.com/lib/pq"
 )
 
 func Test(t *testing.T) {
@@ -36,17 +38,53 @@ func namedParameterizedPreparedStatement(t *testing.T) {
 }
 
 func unnamedParameterizedPreparedStatement(t *testing.T) {
-	db, err := sql.Open("postgres", fmt.Sprintf("host=localhost port=%d database=sharded_db user=sharding_user password=sharding_user sslmode=disable", port))
-	if err != nil {
-		t.Fatalf("could not open connection: %+v", err)
+	var wg sync.WaitGroup
+	errCh := make(chan error, 2) // create error channel
+
+	// Have two concurrent clients executing different unnamed prepared statements
+	for i := 0; i < 2; i++ {
+		wg.Add(1)
+
+		go func(id int) {
+			defer wg.Done()
+
+			db, err := sql.Open("postgres", fmt.Sprintf("host=localhost port=%d database=sharded_db user=sharding_user password=sharding_user sslmode=disable", port))
+			if err != nil {
+				errCh <- err // send error to channel
+				return
+			}
+
+			for j := 0; j < 100; j++ {
+
+				// Under the hood QueryContext generates an unnamed parameterized prepared statement
+				switch id {
+				case 0:
+					rows, err := db.QueryContext(context.Background(), "SELECT $1", 1)
+					if err != nil {
+						errCh <- err // send error to channel
+						return
+					}
+					_ = rows.Close()
+
+				case 1:
+					rows, err := db.QueryContext(context.Background(), "SELECT $1, $2", 1, 2)
+					if err != nil {
+						errCh <- err // send error to channel
+						return
+					}
+					_ = rows.Close()
+				}
+
+			}
+		}(i)
 	}
 
-	for i := 0; i < 100; i++ {
-		// Under the hood QueryContext generates an unnamed parameterized prepared statement
-		rows, err := db.QueryContext(context.Background(), "SELECT $1", 1)
+	wg.Wait()
+	close(errCh)
+
+	for err := range errCh {
 		if err != nil {
-			t.Fatalf("could not query: %+v", err)
+			t.Fatalf("received error from goroutine: %v", err)
 		}
-		_ = rows.Close()
 	}
 }