private static Schema generateAvroSchema()

in dbeam-core/src/main/java/com/spotify/dbeam/avro/BeamJdbcAvroSchema.java [81:94]

• 14 lines of code
• 1 McCabe index (conditional complexity)

  private static Schema generateAvroSchema(final JdbcExportArgs args, final Connection connection)
      throws SQLException {
    final String dbUrl = connection.getMetaData().getURL();
    final String avroDoc =
        args.avroDoc()
            .orElseGet(() -> String.format("Generate schema from JDBC ResultSet from %s", dbUrl));
    return JdbcAvroSchema.createSchemaByReadingOneRow(
        connection,
        args.queryBuilderArgs(),
        args.avroSchemaNamespace(),
        args.avroSchemaName(),
        avroDoc,
        args.useAvroLogicalTypes());
  }