Test adjustments subsequent to buildkite changes from I4c9eac4d

It's probably safer to revert most of the authority changes.  Also one
test started itself in a unique way that passed no dialect.

Change-Id: I9bc04355750abcb094f3e646e07c9690311d2a20
Reviewed-on: https://gerrit.readyset.name/c/readyset/+/10221
Tested-by: Buildkite CI
Reviewed-by: Jason Brown <jason.b@readyset.io>

Author: rs-sac

build/docker-compose.ci-mysql57.yml

@@ -9,5 +9,6 @@ services:
     depends_on:
       - mysql
     environment:
+      - AUTHORITY=standalone
       - ALLOW_UNAUTHENTICATED_CONNECTIONS=true
       - MYSQL_HOST=mysql

build/docker-compose.ci-mysql80.yml

@@ -8,5 +8,6 @@ services:
     depends_on:
       - mysql
     environment:
+      - AUTHORITY=standalone
       - ALLOW_UNAUTHENTICATED_CONNECTIONS=true
       - MYSQL_HOST=mysql

build/docker-compose.ci-mysql84.yml

@@ -8,5 +8,6 @@ services:
     depends_on:
       - mysql
     environment:
+      - AUTHORITY=standalone
       - ALLOW_UNAUTHENTICATED_CONNECTIONS=true
       - MYSQL_HOST=mysql

build/docker-compose.ci-postgis-15.yml

@@ -12,6 +12,7 @@ services:
     depends_on:
       - postgres
     environment:
+      - AUTHORITY=standalone
       - ALLOW_UNAUTHENTICATED_CONNECTIONS=true
       - POSTGRESQL_HOST=postgres
       - PGHOST=postgres

build/docker-compose.ci-postgres13.yml

@@ -12,6 +12,7 @@ services:
     depends_on:
       - postgres
     environment:
+      - AUTHORITY=standalone
       - ALLOW_UNAUTHENTICATED_CONNECTIONS=true
       - POSTGRESQL_HOST=postgres
       - PGHOST=postgres

build/docker-compose.ci-postgres15.yml

@@ -12,6 +12,7 @@ services:
     depends_on:
       - postgres
     environment:
+      - AUTHORITY=standalone
       - ALLOW_UNAUTHENTICATED_CONNECTIONS=true
       - POSTGRESQL_HOST=postgres
       - PGHOST=postgres

readyset-server/src/controller/mod.rs

@@ -139,7 +139,7 @@ impl ControllerState {
                 config
                     .replicator_config
                     .get_cdc_db_url()
-                    .expect("Failed to get CDC database URL")
+                    .expect("Failed to get CDC database URL; provide URL or explicit dialect")
                     .database_type()
                     .into()
             })

replicators/tests/tests.rs

@@ -329,17 +329,18 @@ impl TestHandle {
         mut builder: Builder,
     ) -> ReadySetResult<(TestHandle, ShutdownSender)> {
         readyset_tracing::init_test_logging();
+
         let persistence = readyset_server::PersistenceParameters {
             mode: readyset_server::DurabilityMode::DeleteOnExit,
             ..Default::default()
         };
         builder.set_persistence(persistence);
+
         let parsing_preset = builder.parsing_preset;
         let telemetry_sender = builder.telemetry.clone();
         let (noria, shutdown_tx) = builder.start(Arc::clone(&authority)).await.unwrap();
 
         let dialect = data_dialect_from_url(&url);
-
         let mut handle = TestHandle {
             url,
             dialect,
@@ -2082,16 +2083,16 @@ async fn postgresql_ddl_replicate_create_view_internal(url: &str) {
 #[tokio::test(flavor = "multi_thread")]
 #[tags(serial, slow, mysql_upstream)]
 async fn snapshot_telemetry_mysql() {
-    snapshot_telemetry_inner(&mysql_url()).await
+    snapshot_telemetry_inner(readyset_sql::Dialect::MySQL, &mysql_url()).await
 }
 
 #[tokio::test(flavor = "multi_thread")]
 #[tags(serial, slow, postgres_upstream)]
 async fn snapshot_telemetry_postgresql() {
-    snapshot_telemetry_inner(&pgsql_url()).await
+    snapshot_telemetry_inner(readyset_sql::Dialect::PostgreSQL, &pgsql_url()).await
 }
 
-async fn snapshot_telemetry_inner(url: &String) {
+async fn snapshot_telemetry_inner(dialect: readyset_sql::Dialect, url: &String) {
     readyset_tracing::init_test_logging();
     let mut client = DbConnection::connect(url).await.unwrap();
     client.query(CREATE_SCHEMA).await.unwrap();
@@ -2100,6 +2101,7 @@ async fn snapshot_telemetry_inner(url: &String) {
     let (sender, mut reporter) = TelemetryInitializer::test_init();
     let mut builder = Builder::for_tests();
     builder.set_telemetry_sender(sender);
+    builder.set_dialect(dialect);
     let (mut ctx, shutdown_tx) =
         TestHandle::start_noria_with_builder(url.to_string(), None, builder)
             .await