public String[] getSourcePrimaryKeys(SourceRecord record) {
        Struct key = (Struct) record.key();
        ArrayList<String> pks = new ArrayList<>();
        for (Field field : key.schema().fields()) {
            pks.add(field.name());
        }
        return pks.toArray(new String[0]);
    }
Constructs the SqlManager.

@param opts   the ReplicaDB ToolOptions describing the user's requested action.
@param dsType
src/main/java/org/replicadb/manager/cdc/OracleManagerCDC.java