chore: update examples/go/mysql

examples/go/mysql/mysql.go

@@ -19,8 +19,8 @@ type InsertRequest struct {
 type InsertResponse struct{}
 
 //ftl:verb export
-func Insert(ctx context.Context, req InsertRequest, db ftl.DatabaseHandle[MyDbConfig]) (InsertResponse, error) {
-	err := persistRequest(ctx, req, db)
+func Insert(ctx context.Context, req InsertRequest, insert CreateRequestClient) (InsertResponse, error) {
+	err := insert(ctx, CreateRequestQuery{Data: ftl.Some(req.Data)})
 	if err != nil {
 		return InsertResponse{}, err
 	}
@@ -29,35 +29,16 @@ func Insert(ctx context.Context, req InsertRequest, db ftl.DatabaseHandle[MyDbCo
 }
 
 //ftl:verb export
-func Query(ctx context.Context, db ftl.DatabaseHandle[MyDbConfig]) ([]string, error) {
-	rows, err := db.Get(ctx).QueryContext(ctx, "SELECT data FROM requests")
+func Query(ctx context.Context, query GetRequestDataClient) ([]string, error) {
+	rows, err := query(ctx)
 	if err != nil {
 		return nil, err
 	}
-	defer rows.Close()
 	var items []string
-	for rows.Next() {
-		var i string
-		if err := rows.Scan(
-			&i,
-		); err != nil {
-			return nil, err
+	for _, row := range rows {
+		if d, ok := row.Data.Get(); ok {
+			items = append(items, d)
 		}
-		items = append(items, i)
-	}
-	if err := rows.Close(); err != nil {
-		return nil, err
-	}
-	if err := rows.Err(); err != nil {
-		return nil, err
 	}
 	return items, nil
 }
-
-func persistRequest(ctx context.Context, req InsertRequest, db ftl.DatabaseHandle[MyDbConfig]) error {
-	_, err := db.Get(ctx).Exec("INSERT INTO requests (data) VALUES (?);", req.Data)
-	if err != nil {
-		return err
-	}
-	return nil
-}