ProgressBar для загрузки/выгрузки БД

@Bretbas · Регистрация: 05.08.2013

Студворк — интернет-сервис помощи студентам

Доброго времени суток.
При загрузки формы происходит выгрузка базы данных в DataSet:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
private void Form1_Load(object sender, EventArgs e)
{
      try
      {
             this.historyTableAdapter.Fill(CommonData.localDBDataSet.History);
             this.measureTableAdapter.Fill(CommonData.localDBDataSet.Measure);
             this.typeDataTableAdapter.Fill(CommonData.localDBDataSet.TypeData);
             this.dataTableAdapter.Fill(CommonData.localDBDataSet.Data);
             this.typeHistoryTableAdapter.Fill(CommonData.localDBDataSet.TypeHistory);
       }
       catch (System.Data.SqlClient.SqlException)
       {
              MessageBox.Show("Ошибка подключения к базе данных", "Ошибка");
 
              Application.Exit();
        }
}

А при закрытии формы происходит обновление базы данных:

C#
1
2
3
4
private void MainForm_FormClosing(object sender, FormClosingEventArgs e)
{
        this.tableAdapterManager.UpdateAll(CommonData.localDBDataSet);
}

Так как база обширная, происходит задержка программы во время этих двух обработчиков.

Мне нужно сделать ProgressBar для этого, чтобы пользователь видел степень загрузки/выгрузки базы данных.
Как мне это реализовать? Подскажите пожалуйста

Добавлено через 7 часов 39 минут
Никто не знает?

@sysrepos · 03.02.2017, 15:37

Пример с прогрессбаром. Но возможно в вашем случае для прогрессбарам надо использовать стиль

C#
1
progressBar1.Style = ProgressBarStyle.Marquee;

@sysrepos · 03.02.2017, 15:39

в любом случае для использования прогрессбара нужно уметь работать с многопоточностью.
про многопоточность можно посмотреть тут https://www.youtube.com/watch?v=D9qcKV4j75U&t=5s

@Bretbas · 03.02.2017, 17:23 **[ТС]**

sysrepos, Я так и понял, что нужна многопоточность. Принцип работы я знаю, работал с ней на c++. На C# многопоточность не использовал, но думаю, разберусь.

@TopLayer · 03.02.2017, 18:30

Вот вариант с загрузкой одной таблицы. Работает только с SELECT *, сортируя по первому столбцу. Отображается прогресс загрузки, а после завершения отображает таблицу.

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
void Main()
{
    Application.Run(new MainForm());
}
 
class MainForm: Form
{
    public MainForm()
    {
        WindowState = FormWindowState.Maximized;
        Load += MainForm_Load;
    }
    
    private async void MainForm_Load(object sender, EventArgs args)
    {
        var connectionString = @"Data Source=.\MYSERVER; Initial Catalog=AdventureWorks2014; Integrated Security = true";
        var dataTable = new DataTable();
        var dataAdapter = new SqlDataAdapter("SELECT * FROM [Person].[Person]", connectionString);
 
        var pb = new ProgressBar
        {
            Parent = this,
            Minimum = 0,
            Maximum = 100,
            Value = 0,
        };
 
        var dgv = new DataGridView
        {
            Parent = this,
            Top = 100,
            AutoSize = true
        };
 
        var progress = new Progress<int>();
        progress.ProgressChanged += (s, value) => 
        {
            pb.Value = value;
            if (value == 100)
            {
                dgv.DataSource = dataTable;
            }
        };
 
        var task = dataAdapter.FillAsync(dataTable, 1000, progress);
 
        await task;
    }
}
 
static class SqlDataAdapterExtensions
{
    public static Task FillAsync(this SqlDataAdapter adapter, DataTable dataTable, int rowsPerBlock, IProgress<int> progress = null)
    {
        return Task.Run(() =>
        {
            progress?.Report(0);
            
            string selectText = adapter.SelectCommand.CommandText;
            
            int total = GetCount(adapter);
            int steps = total / rowsPerBlock + (total % rowsPerBlock != 0 ? 1 : 0);
            for (int start = 0, step = 0; start < total; start += rowsPerBlock, step++)
            {
                adapter.SelectCommand = new SqlCommand($"{selectText} order by (1) offset {start} rows fetch next {rowsPerBlock} rows only", adapter.SelectCommand.Connection);
                adapter.Fill(dataTable);
                
                double percentage = Math.Min((step + 1) / (double)steps * 100, 99);
                progress?.Report((int)percentage);
            }
            
            progress?.Report(100);
        });
    }
    
    private static int GetCount(SqlDataAdapter adapter)
    {
        string selectText = adapter.SelectCommand.CommandText.Replace("*", "COUNT(*)");
 
        int count;
    
        using (var connection = new SqlConnection(adapter.SelectCommand.Connection.ConnectionString))
        {
            connection.Open();
            var countCommand = new SqlCommand(selectText, connection);
            count = (int)countCommand.ExecuteScalar();
        }
        
        return count;
    }
}

@Bretbas · 03.02.2017, 19:06 **[ТС]**

TopLayer, Прошу прощения, код в принципе понятен, но я не очень разбираюсь в синтаксисе C#'па. Вы не могли бы уточнить, что значит символ ? вот тут:

C#
1
progress?.Report(0);

и символ $ в передачи строки как параметра вот здесь:

C#
1
$"{selectText} order by (1) offset {start} rows fetch next {rowsPerBlock} rows only"

@TopLayer · 03.02.2017, 19:14

Bretbas, это новые фишки C# 6.0
1) то же самое что и

C#
1
if (progress != null) progress.Report(0);

2) то же самое что и

C#
1
string.Format("{0} order by (1) offset {1} rows fetch next {2} rows only", selectText, start, rowsPerBlock);

@Bretbas · 03.02.2017, 19:21 **[ТС]**

TopLayer, Понял

Спасибо.

Я не могу никак Ваш код подсоединить к своему проекту, так как объект адаптер у меня создается конструктором, я его не инициализирую вот так:

C#
1
var dataAdapter = new SqlDataAdapter("SELECT * FROM [Person].[Person]", connectionString);

он где-то внутри сам по себе создается.

Из-за этого возникают проблемы. К примеру когда выполняется вот эта строчка:

C#
1
string selectText = adapter.SelectCommand.CommandText;

у меня выпадает исключение
An unhandled exception of type 'System.Reflection.TargetInvocationExcep tion' occurred in mscorlib.dll
Additional information: Адресат вызова создал исключение.

@TopLayer · 03.02.2017, 19:28

Bretbas, я не понимаю как в этой строчке может быть такое исключение. Тут нужна "помощь зала".

@Bretbas · 03.02.2017, 19:37 **[ТС]**

TopLayer,

Сообщение от TopLayer

я не понимаю как в этой строчке может быть такое исключение. Тут нужна "помощь зала".

Я тоже не очень понимаю, так как не знаю как работает конструктор C#'па для создания Адаптера и всяких его приколюшек...
Но возможно подвох в том, что он в этом конструкторе создается без параметра строки(запроса), а метод Fill, который является стандартным у него, уже имеет в себе запрос.
А так как в твоем коде:

C#
1
string selectText = adapter.SelectCommand.CommandText;

идет запрос на получение строки запроса адаптера, который по идее должен был инициализироваться в его конструкторе, то у меня возможно выдает из-за этого ошибку, так как C# конструктор адаптера его не передает в начале.

Че-то я как-то запутанно написал

Добавлено через 4 минуты
TopLayer, ладно хрен с ним, с этим ProgressBar'ом. Лучше подскажи как мне сделать тогда просто "крутящий кружочек", когда выполняется вот этот код:

C#
1
2
3
4
5
             this.historyTableAdapter.Fill(CommonData.localDBDataSet.History);
             this.measureTableAdapter.Fill(CommonData.localDBDataSet.Measure);
             this.typeDataTableAdapter.Fill(CommonData.localDBDataSet.TypeData);
             this.dataTableAdapter.Fill(CommonData.localDBDataSet.Data);
             this.typeHistoryTableAdapter.Fill(CommonData.localDBDataSet.TypeHistory);

Думаю нужно поток запускать дополнительный, в нем запускать форму, которая имеет вид крутящегося кружочка, а в главном потоке уже выполнять все Fill'ы?

Если честно, меня попросили написать программу на C#, вот я и пишу, но не очень хочется вдаваться в подробности этого языка, так как мне он не очень симпатичен...C++ - вот мощь

@TopLayer · 03.02.2017, 20:14

Bretbas, как такой вариант?

Кликните здесь для просмотра всего текста

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
class MainForm: Form
{
    public MainForm()
    {
        Text = "MainForm";
        Load += MainForm_Load;
    }
 
    private async void MainForm_Load(object sender, EventArgs args)
    {
        var cts = new CancellationTokenSource();
        new WaitingForm(cts.Token).Show(this);
        Enabled = false;
        
        await Task.Run(() =>
        {
            // time consuming operation
            Thread.Sleep(5000);
            cts.Cancel();
            Invoke((Action)delegate { Enabled = true; });
        });
    }
}
 
class WaitingForm : Form
{
    CancellationToken _ct;
    
    public WaitingForm(CancellationToken ct)
    {
        _ct = ct;
        StartPosition = FormStartPosition.CenterScreen;
        Size = new Size(300, 30);
        FormBorderStyle = FormBorderStyle.None;
        Load += WaitingForm_Load;
    }
 
    private void WaitingForm_Load(object sender, EventArgs args)
    {
        var pb = new ProgressBar { Parent = this, Style = ProgressBarStyle.Marquee, Dock = DockStyle.Fill };
 
        new System.Windows.Forms.Timer { Enabled = true, Interval = 1000 }.Tick += (_, __) =>
        {
            if (_ct.IsCancellationRequested) Close();
        };
    }
}
 
void Main()
{
    Application.Run(new MainForm());
}

@Bretbas · 03.02.2017, 20:19 **[ТС]**

TopLayer, Я не очень понял этот пример, а чего собственно ждет форма WaitingForm?

@TopLayer · 03.02.2017, 20:24

Сообщение от Bretbas

а чего собственно ждет форма WaitingForm?

18ю строку

@Bretbas · 03.02.2017, 20:26 **[ТС]**

, Тоесть чтобы выполнить Fill'ы для всех таблиц, мне нужно поместить их в обработчик Run объекта Task?
Да, и что такое CancellationTokenSource?

@TopLayer · 03.02.2017, 20:35

Сообщение от Bretbas

мне нужно поместить их в обработчик Run объекта Task?

Ну да, правда это не обработчик.

Сообщение от Bretbas

Да, и что такое CancellationTokenSource?

Источник токенов отмены

Короче если пишешь cts.Cancel(), то все токены, полученные путём cts.Token, буду иметь свойство IsCancellationRequested == true. И всё это безопасно в отношении потоков.

Добавлено через 3 минуты
Bretbas, кстати вместо таймера лучше вот так сделать

C#
1
_ct.Register(() => Invoke((Action)delegate { Close(); }));

@Bretbas · 03.02.2017, 21:01 **[ТС]**

TopLayer,

Сообщение от TopLayer

Короче если пишешь cts.Cancel(), то все токены, полученные путём cts.Token, буду иметь свойство IsCancellationRequested == true. И всё это безопасно в отношении потоков.

Ах это грязное событийно-управляемое программирование

Ща попробую

Добавлено через 17 минут
TopLayer, Итак, попробовал. Возникло две проблемы:
1. Ты в своем коде делаешь главное окно недоступным Enabled = false;. Так работает. Я хочу сделать окно невидимым. Заменяю гребанный Enabled на Visible. У меня не работает. Окно не становится невидимым. Как-будто ничего не происходит

2. Вот мой код:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
        private async void MainForm_Load(object sender, EventArgs e)
        {
            var cts = new CancellationTokenSource();
            new Form1(cts.Token).Show(this);
            this.Enabled = false;
 
            await Task.Run(() =>
            {
                // Загружаем базу данных
                try
                {
                    this.historyTableAdapter.Fill(CommonData.localDBDataSet.History);
                    this.measureTableAdapter.Fill(CommonData.localDBDataSet.Measure);
                    this.typeDataTableAdapter.Fill(CommonData.localDBDataSet.TypeData);
                    this.dataTableAdapter.Fill(CommonData.localDBDataSet.Data);
                    this.typeHistoryTableAdapter.Fill(CommonData.localDBDataSet.TypeHistory);
                }
                catch (System.Data.SqlClient.SqlException)
                {
                    MessageBox.Show("Ошибка подключения к базе данных", "Ошибка");
 
                    // Закрываем приложение
                    Application.Exit();
                }
 
                // Источник данных для таблицы Measure
                this.measureBindingSource.DataMember = "Measure";
                this.measureBindingSource.DataSource = CommonData.localDBDataSet;
 
                // Источник данных для таблицы TypeData
                this.typeDataBindingSource.DataMember = "TypeData";
                this.typeDataBindingSource.DataSource = CommonData.localDBDataSet;
 
                // Источник данных для таблицы Data
                this.dataBindingSource.DataMember = "FK_Data_ToTypeData";
                this.dataBindingSource.DataSource = this.typeDataBindingSource;
                this.dataBindingSource.Sort = "name";
 
                // Столбец id_measure привязываем к таблице Measure
                this.id_measure.DataPropertyName = "id_measure";
                this.id_measure.DisplayMember = "measure";
                this.id_measure.ValueMember = "id";
 
                cts.Cancel();
 
                Invoke((Action)delegate 
                {
                    this.Enabled = true; 
                });
            });
        }

На вот этой строке this.typeDataBindingSource.DataMember = "TypeData"; происходит исключение:
An unhandled exception of type 'System.Reflection.TargetInvocationExcep tion' occurred in mscorlib.dll
Additional information: Адресат вызова создал исключение.

хотя без потоков, этот код работал. Бред вообще. Я уже замудохался

Добавлено через 6 минут
Второй вопрос отпал, просто инициализацию источников данных переместил вот в этот блок:

C#
1
2
3
4
                Invoke((Action)delegate 
                {
                    this.Enabled = true; 
                });

все заработало

@TopLayer · 03.02.2017, 21:02

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
        private async void MainForm_Load(object sender, EventArgs e)
        {
            var cts = new CancellationTokenSource();
            new Form1(cts.Token).Show(this);
                Opacity = 0;
        ShowInTaskbar = false;
        Enabled = false;
 
            await Task.Run(() =>
            {
                // Загружаем базу данных
                try
                {
                    this.historyTableAdapter.Fill(CommonData.localDBDataSet.History);
                    this.measureTableAdapter.Fill(CommonData.localDBDataSet.Measure);
                    this.typeDataTableAdapter.Fill(CommonData.localDBDataSet.TypeData);
                    this.dataTableAdapter.Fill(CommonData.localDBDataSet.Data);
                    this.typeHistoryTableAdapter.Fill(CommonData.localDBDataSet.TypeHistory);
                }
                catch (System.Data.SqlClient.SqlException)
                {
                    MessageBox.Show("Ошибка подключения к базе данных", "Ошибка");
 
                    // Закрываем приложение
                    Application.Exit();
                }
            });
 
                // Источник данных для таблицы Measure
                this.measureBindingSource.DataMember = "Measure";
                this.measureBindingSource.DataSource = CommonData.localDBDataSet;
 
                // Источник данных для таблицы TypeData
                this.typeDataBindingSource.DataMember = "TypeData";
                this.typeDataBindingSource.DataSource = CommonData.localDBDataSet;
 
                // Источник данных для таблицы Data
                this.dataBindingSource.DataMember = "FK_Data_ToTypeData";
                this.dataBindingSource.DataSource = this.typeDataBindingSource;
                this.dataBindingSource.Sort = "name";
 
                // Столбец id_measure привязываем к таблице Measure
                this.id_measure.DataPropertyName = "id_measure";
                this.id_measure.DisplayMember = "measure";
                this.id_measure.ValueMember = "id";
 
                cts.Cancel();
                Enabled = true;
        ShowInTaskbar = true;
        Opacity = 100;
        }

@Bretbas · 03.02.2017, 21:28 **[ТС]**

TopLayer, Спасибо! Очень выручил. Вроде все работает

Добавлено через 13 минут
TopLayerКстати, вопрос не в тему. Если я создаю форму вот так:

C#
1
new Form1(cts.Token).Show(this);

не будет утечек памяти? Ведь я ее не освобождаю? Или как в C# это происходит?

@TopLayer · 03.02.2017, 22:36

Сообщение от Bretbas

не будет утечек памяти

не будет. Это вам не с++ где одни объекты забывают удалить, другие же удаляют по несколько раз

Здесь же автоматический сборщик мусора периодически (по наступлению некоторых событий) просматривает все ссылочные переменные (корни), находит все достижимые из них объекты и помечает их как 'нельзящасудалять'. Все остальные объекты удаляются.

@Bretbas · 04.02.2017, 07:36 **[ТС]**

TopLayer, Понял

Я не знал, что C# имеет сборщик мусора

Новые блоги и статьи Все статьи Все блоги /
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .	Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .
SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .	Реалии Hrethgir 01.03.2026 Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .	Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .

@sysrepos 83 / 77 / 30 Регистрация: 08.08.2013 Сообщений: 461 Записей в блоге: 1
	03.02.2017, 15:39
	в любом случае для использования прогрессбара нужно уметь работать с многопоточностью. про многопоточность можно посмотреть тут https://www.youtube.com/watch?v=D9qcKV4j75U&t=5s 0

@Bretbas Каждому свое 533 / 219 / 81 Регистрация: 05.08.2013 Сообщений: 1,614
	03.02.2017, 17:23 [ТС]
	sysrepos, Я так и понял, что нужна многопоточность. Принцип работы я знаю, работал с ней на c++. На C# многопоточность не использовал, но думаю, разберусь. 0

@TopLayer 907 / 664 / 318 Регистрация: 23.10.2016 Сообщений: 1,543
	03.02.2017, 19:28
	Bretbas, я не понимаю как в этой строчке может быть такое исключение. Тут нужна "помощь зала". 0

@Bretbas Каждому свое 533 / 219 / 81 Регистрация: 05.08.2013 Сообщений: 1,614
	03.02.2017, 20:19 [ТС]
	TopLayer, Я не очень понял этот пример, а чего собственно ждет форма WaitingForm? 0

@Bretbas Каждому свое 533 / 219 / 81 Регистрация: 05.08.2013 Сообщений: 1,614
	03.02.2017, 20:26 [ТС]
	, Тоесть чтобы выполнить Fill'ы для всех таблиц, мне нужно поместить их в обработчик Run объекта Task? Да, и что такое CancellationTokenSource? 0

@Bretbas Каждому свое 533 / 219 / 81 Регистрация: 05.08.2013 Сообщений: 1,614
	04.02.2017, 07:36 [ТС]
	TopLayer, Понял Я не знал, что C# имеет сборщик мусора 0

ProgressBar для загрузки/выгрузки БД

Решение