Function TestReplay

internal/endtoend/endtoend_test.go:108–303

(t *testing.T)

}

func TestReplay(t *testing.T) {
	// Ensure that this environment variable is always set to true when running
	// end-to-end tests
	os.Setenv("SQLC_DUMMY_VALUE", "true")

	// t.Parallel()
	ctx := context.Background()

	var mysqlURI, postgresURI string

	// First, check environment variables
	if uri := os.Getenv("POSTGRESQL_SERVER_URI"); uri != "" {
		postgresURI = uri
	}
	if uri := os.Getenv("MYSQL_SERVER_URI"); uri != "" {
		mysqlURI = uri
	}

	// Try Docker for any missing databases
	if postgresURI == "" || mysqlURI == "" {
		if err := docker.Installed(); err == nil {
			if postgresURI == "" {
				host, err := docker.StartPostgreSQLServer(ctx)
				if err != nil {
					t.Logf("docker postgresql startup failed: %s", err)
				} else {
					postgresURI = host
				}
			}
			if mysqlURI == "" {
				host, err := docker.StartMySQLServer(ctx)
				if err != nil {
					t.Logf("docker mysql startup failed: %s", err)
				} else {
					mysqlURI = host
				}
			}
		}
	}

	// Try native installation for any missing databases (Linux only)
	if postgresURI == "" || mysqlURI == "" {
		if err := native.Supported(); err == nil {
			if postgresURI == "" {
				host, err := native.StartPostgreSQLServer(ctx)
				if err != nil {
					t.Logf("native postgresql startup failed: %s", err)
				} else {
					postgresURI = host
				}
			}
			if mysqlURI == "" {
				host, err := native.StartMySQLServer(ctx)
				if err != nil {
					t.Logf("native mysql startup failed: %s", err)
				} else {
					mysqlURI = host
				}