examples: Port ondeck to MySQL

examples/ondeck/mysql/db_test.go

@@ -0,0 +1,163 @@
+// +build examples
+
+package ondeck
+
+import (
+	"context"
+	"database/sql"
+	"strings"
+	"testing"
+
+	"github.com/kyleconroy/sqlc/internal/sqltest"
+
+	"github.com/google/go-cmp/cmp"
+)
+
+func join(vals ...string) sql.NullString {
+	if len(vals) == 0 {
+		return sql.NullString{}
+	}
+	return sql.NullString{
+		Valid:  true,
+		String: strings.Join(vals, ","),
+	}
+}
+
+func runOnDeckQueries(t *testing.T, q *Queries) {
+	ctx := context.Background()
+
+	_, err := q.CreateCity(ctx, CreateCityParams{
+		Slug: "san-francisco",
+		Name: "San Francisco",
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	city, err := q.GetCity(ctx, "san-francisco")
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	venueResult, err := q.CreateVenue(ctx, CreateVenueParams{
+		Slug:            "the-fillmore",
+		Name:            "The Fillmore",
+		City:            city.Slug,
+		SpotifyPlaylist: "spotify:uri",
+		Status:          StatusOpen,
+		Statuses:        join(string(StatusOpen), string(StatusClosed)),
+		Tags:            join("rock", "punk"),
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	venueID, err := venueResult.LastInsertId()
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	venue, err := q.GetVenue(ctx, GetVenueParams{
+		Slug: "the-fillmore",
+		City: city.Slug,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if diff := cmp.Diff(venue.ID, venueID); diff != "" {
+		t.Errorf("venue ID mismatch:\n%s", diff)
+	}
+
+	{
+		actual, err := q.VenueCountByCity(ctx)
+		if err != nil {
+			t.Error(err)
+		}
+		if diff := cmp.Diff(actual, []VenueCountByCityRow{
+			{city.Slug, int64(1)},
+		}); diff != "" {
+			t.Errorf("venue count mismatch:\n%s", diff)
+		}
+	}
+
+	{
+		actual, err := q.ListCities(ctx)
+		if err != nil {
+			t.Error(err)
+		}
+		if diff := cmp.Diff(actual, []City{city}); diff != "" {
+			t.Errorf("list city mismatch:\n%s", diff)
+		}
+	}
+
+	{
+		actual, err := q.ListVenues(ctx, city.Slug)
+		if err != nil {
+			t.Error(err)
+		}
+		if diff := cmp.Diff(actual, []Venue{venue}); diff != "" {
+			t.Errorf("list venue mismatch:\n%s", diff)
+		}
+	}
+
+	{
+		err := q.UpdateCityName(ctx, UpdateCityNameParams{
+			Slug: city.Slug,
+			Name: "SF",
+		})
+		if err != nil {
+			t.Error(err)
+		}
+	}
+
+	{
+		expected := "Fillmore"
+		err := q.UpdateVenueName(ctx, UpdateVenueNameParams{
+			Slug: venue.Slug,
+			Name: expected,
+		})
+		if err != nil {
+			t.Error(err)
+		}
+		fresh, err := q.GetVenue(ctx, GetVenueParams{
+			Slug: venue.Slug,
+			City: city.Slug,
+		})
+		if diff := cmp.Diff(expected, fresh.Name); diff != "" {
+			t.Errorf("update venue mismatch:\n%s", diff)
+		}
+	}
+
+	{
+		err := q.DeleteVenue(ctx, DeleteVenueParams{
+			Slug:   venue.Slug,
+			Slug_2: venue.Slug,
+		})
+		if err != nil {
+			t.Error(err)
+		}
+	}
+}
+
+func TestPrepared(t *testing.T) {
+	t.Parallel()
+
+	sdb, cleanup := sqltest.MySQL(t, []string{"schema"})
+	defer cleanup()
+
+	q, err := Prepare(context.Background(), sdb)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	runOnDeckQueries(t, q)
+}
+
+func TestQueries(t *testing.T) {
+	t.Parallel()
+
+	sdb, cleanup := sqltest.MySQL(t, []string{"schema"})
+	defer cleanup()
+
+	runOnDeckQueries(t, New(sdb))
+}

examples/ondeck/mysql/query/city.sql

@@ -0,0 +1,23 @@
+/* name: ListCities :many */
+SELECT *
+FROM city
+ORDER BY name;
+
+/* name: GetCity :one */
+SELECT *
+FROM city
+WHERE slug = ?;
+
+/* name: CreateCity :execresult */
+INSERT INTO city (
+    name,
+    slug
+) VALUES (
+    ?,
+    ? 
+); 
+
+/* name: UpdateCityName :exec */
+UPDATE city
+SET name = ?
+WHERE slug = ?;

examples/ondeck/mysql/query/venue.sql

@@ -0,0 +1,48 @@
+/* name: ListVenues :many */
+SELECT *
+FROM venue
+WHERE city = ?
+ORDER BY name;
+
+/* name: DeleteVenue :exec */
+DELETE FROM venue
+WHERE slug = ? AND slug = ?;
+
+/* name: GetVenue :one */
+SELECT *
+FROM venue
+WHERE slug = ? AND city = ?;
+
+/* name: CreateVenue :execresult */
+INSERT INTO venue (
+    slug,
+    name,
+    city,
+    created_at,
+    spotify_playlist,
+    status,
+    statuses,
+    tags
+) VALUES (
+    ?,
+    ?,
+    ?,
+    NOW(),
+    ?,
+    ?,
+    ?,
+    ?
+);
+
+/* name: UpdateVenueName :exec */
+UPDATE venue
+SET name = ?
+WHERE slug = ?;
+
+/* name: VenueCountByCity :many */
+SELECT
+    city,
+    count(*)
+FROM venue
+GROUP BY 1
+ORDER BY 1;