Дублирование кода SQLite DataAdapter

private void ExecuteWithDataAdapter(string query, Action<SQLiteDataAdapter> action)
        {
            using (SQLiteConnection connection = new SQLiteConnection(connectionString))
            {
                connection.Open();
                using (SQLiteDataAdapter adapter = new SQLiteDataAdapter(query, connection))
                {
                    action(adapter);
                }
            }
        }

private int GetContractCountByName(string tableName, string selectedItem)
        {
            int count = 0;
            int id = -1; // Идентификатор, который мы будем искать
 
            // Сначала получаем идентификатор по имени
            string idQuery = $"SELECT Id FROM {tableName} WHERE Name = @Name";
 
            ExecuteWithDataAdapter(idQuery, adapter =>
            {
                adapter.SelectCommand.Parameters.AddWithValue("@Name", selectedItem);
                DataTable resultTable = new DataTable();
                adapter.Fill(resultTable);
                if (resultTable.Rows.Count > 0)
                {
                    id = Convert.ToInt32(resultTable.Rows[0]["Id"]);
                }
            });
 
            // Если идентификатор найден, считаем количество договоров
            if (id != -1)
            {
                string countQuery = $"SELECT COUNT(*) FROM Contract WHERE {tableName}Id = @ForeignKeyId";
 
                ExecuteWithDataAdapter(countQuery, adapter =>
                {
                    adapter.SelectCommand.Parameters.AddWithValue("@ForeignKeyId", id);
                    DataTable countTable = new DataTable();
                    adapter.Fill(countTable);
                    if (countTable.Rows.Count > 0)
                    {
                        count = Convert.ToInt32(countTable.Rows[0][0]);
                    }
                });
            }
 
            return count;
        }

private int GetContractCountByName(string tableName, string selectedItem)
        {
            int count = 0;
            int id = -1; // Идентификатор, который мы будем искать
 
            // Сначала получаем идентификатор по имени
            string idQuery = $"SELECT Id FROM {tableName} WHERE Name = @Name";
 
            ExecuteWithDataAdapter(idQuery, adapter =>
            {
                adapter.SelectCommand.Parameters.AddWithValue("@Name", selectedItem);
                DataTable resultTable = new DataTable();
                adapter.Fill(resultTable);
                if (resultTable.Rows.Count > 0)
                {
                    id = Convert.ToInt32(resultTable.Rows[0]["Id"]);
                }
 
                    // Если идентификатор найден, считаем количество договоров
                    if (id != -1)
                    {
                            string countQuery = $"SELECT COUNT(*) FROM Contract WHERE {tableName}Id = @ForeignKeyId";
 
                            adapter.SelectCommand.Parameters.Clear();
                            adapter.SelectCommand.Parameters.AddWithValue("@ForeignKeyId", id);
                            countTable = new DataTable();
                            adapter.Fill(countTable);
                            if (countTable.Rows.Count > 0)
                            {
                                count = Convert.ToInt32(countTable.Rows[0][0]);
                            }
                    }
            });
 
            return count;
        }

using (OleDbConnection excelConnection = new OleDbConnection(excelConnectionString))
{
    using (OleDbDataAdapter oleDbDataAdapter = new OleDbDataAdapter(excelQuery, excelConnection))
    {
        _ = oleDbDataAdapter.Fill(excelDataTable);
    }
}

public async Task<int> GetCounterAsync(EObject mainItem)
{
    int counter;
    string sqlText =
        "SELECT COUNT(*) " +
        "FROM dbo.tblGPlansN " +
        "WHERE ID_EObject = @eoID";
 
    try
    {
        using (SqlConnection sqlConnection = new SqlConnection(_connectionString))
        {
            using (SqlCommand sqlCommand = new SqlCommand(sqlText, sqlConnection))
            {
                SqlParameter parameterID = new SqlParameter
                {
                    ParameterName = "@eoID",
                    Value = mainItem.EObjectID,
                    SqlDbType = SqlDbType.Int,
                    Direction = ParameterDirection.Input
                };
                sqlCommand.Parameters.Add(parameterID);
 
                await sqlCommand.Connection.OpenAsync();
 
                return counter = (int)await sqlCommand.ExecuteScalarAsync();
            }
        }
    }
    catch (SqlException sqlEx)
    {
        throw new ApplicationException(string.Format("T-SQL #{0} - {1}", sqlEx.Number, sqlEx.Message), sqlEx);
    }
    catch (Exception ex)
    {
        throw new ApplicationException(ex.Message, ex);
    }
}

adapter.SelectCommand.Parameters.Clear();
                    adapter.SelectCommand.Parameters.AddWithValue("@ForeignKeyId", id);
                    DataTable countTable = new DataTable(); // // Объявил countTable
                    adapter.Fill(countTable);

public partial class Form1 : Form
    {
        private SetInterface setInterface; // настройки поведения элементов интерфейса
        private LoadReportData loadReportData; // загрузка данных для блока справок
        private GetReport getReport;
        private string connectionString = @"Data Source=|DataDirectory|\CarDistributionDB.db;Version=3;";
        private DataTable distributionTable;
 
        public Form1()
        {
             InitializeComponent();
             ...
             getReport = new GetReport(connectionString, ExecuteWithDataAdapter);
             ...
        }
...

public static string ContractCount(string tableName)
        {
            return $@"
            SELECT COUNT(*) 
            FROM Contract 
            WHERE {tableName}Id = (
                SELECT Id 
                FROM {tableName} 
                WHERE Name = @OptionName
            )";
        }

private void GetContractCount(Form1.ReportData reportData)
        {
            // Получаем количество договоров для выбранного элемента
            int contractCount = 0;
            string tableName = reportData.ContractOption == "АЗС" ? "GasStation" : "Base";
 
            string query = DBQuery.ContractCount(tableName); // Получаем SQL-запрос
 
            executeWithDataAdapter(query, adapter =>
            {
                adapter.SelectCommand.Parameters.AddWithValue("@OptionName", reportData.ContractOptionName);
                DataTable dataTable = new DataTable();
                adapter.Fill(dataTable);
                if (dataTable.Rows.Count > 0)
                {
                    contractCount = Convert.ToInt32(dataTable.Rows[0][0]);
                }
            });
 
            // Строка для изменения окончания в зависимости от значения ContractOption
            string optionText = reportData.ContractOption == "автобаза" ? "автобазы" : reportData.ContractOption;
            // Отображаем количество договоров
            MessageBox.Show($"Количество договоров для {optionText} '{reportData.ContractOptionName}': {contractCount} шт.");
        }

contractCount = Convert.ToInt32(dataTable.Rows[0][0]);

var result = (int)command.ExecuteScalar();

DataTable excelDataTable = new DataTable();
 
excelDataTable.Columns.AddRange(new DataColumn[10]
{
    new DataColumn("ID_LaborHB_01", typeof(int)),
    new DataColumn("PosNum", typeof(int)),
    new DataColumn("NameOfWork", typeof(string)),
    new DataColumn("WorkCode", typeof(string)),
    new DataColumn("Labor", typeof(decimal)),
    new DataColumn("LaborAssembly", typeof(decimal)),
    new DataColumn("ErectCoeff", typeof(decimal)),
    new DataColumn("ID_Measure", typeof(int)),
    new DataColumn("ID_Branch", typeof(int)),
    new DataColumn("ID_EObject", typeof(int))
});
 
// ...
 
await ExcelDataTableFillAsync(excelConectionString, excelQuery, excelDataTable);
 
using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(_connectionString, sqlBulkCopyOptions))
{
    sqlBulkCopy.DestinationTableName = "dbo.tblLaborHB_02";
 
    sqlBulkCopy.ColumnMappings.Add("ID_LaborHB_01", "ID_LaborHB_01");
    sqlBulkCopy.ColumnMappings.Add("PosNum", "PosNum");
    sqlBulkCopy.ColumnMappings.Add("NameOfWork", "NameOfWork");
    sqlBulkCopy.ColumnMappings.Add("WorkCode", "WorkCode");
    sqlBulkCopy.ColumnMappings.Add("Labor", "Labor");
    sqlBulkCopy.ColumnMappings.Add("LaborAssembly", "LaborAssembly");
    sqlBulkCopy.ColumnMappings.Add("ErectCoeff", "ErectCoeff");
    sqlBulkCopy.ColumnMappings.Add("ID_Measure", "ID_Measure");
    sqlBulkCopy.ColumnMappings.Add("ID_Branch", "ID_Branch");
    sqlBulkCopy.ColumnMappings.Add("ID_EObject", "ID_EObject");
 
    await sqlBulkCopy.WriteToServerAsync(excelDataTable);
}