SQL, один ко многим и SqlConnection

@xr_Sanya · Регистрация: 13.07.2020

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

Здравствуйте, подскажите пожалуйста как работать со связью один ко многим/многие ко многим.
Допустим у меня есть пользователь и у него список ссылок, как получить данные я знаю, а вот как добавить новые не понятно.
Суть в том что я хочу сделать метод CreateUser, он соответственно принимает в себе сущностью пользователя. У сущности есть id и List со ссылками. Ссылки представлены классом Link, в нем есть id, url и UserId. Тоесть связь один ко многим.

Что написать в теле метода? Я так понимаю что сперва нужно добавить пользователя в базу, потом найти добавленного пользователя в базе, потом добавить в таблицу со ссылками ссылки пользователя и каждой присвоить UserId полученный от базы? Или может есть другие варианты? Все это я делаю через SqlConnection, не через EF.

@OwenGlendower · 21.08.2022, 17:17

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

Я так понимаю что сперва нужно добавить пользователя в базу, потом найти добавленного пользователя в базе, потом добавить в таблицу со ссылками ссылки пользователя и каждой присвоить UserId полученный от базы?

Да. EF или другой ORM именно так и делает. С небольшим уточнением, что нет необходимости искать новую запись для получения нового первичного ключа. Можно использовать SCOPE_IDENTITY или OUTPUT inserted.

@xr_Sanya · 21.08.2022, 21:27 **[ТС]**

Посмотрите пожалуйста, вроде работает, но может есть замечания?

Процедуры хранимые

SQL
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
CREATE PROCEDURE [dbo].[sp_InsertUser]
    @tag text,
    @name text,
    @joinDate datetime,
    @lastActivity datetime,
    @parsingPaused bit,
AS
    INSERT INTO Users
(Tag, Name, JoinDate, LastActivity, ParsingPaused)
    VALUES 
(@tag, @name, @joinDate, @lastActivity, @parsingPaused)
  
    SELECT SCOPE_IDENTITY()
GO
 
CREATE PROCEDURE [dbo].[sp_InsertLink]
    @url text,
    @lastDataCollectionTime datetime,
    @description text,
    @userId INT
AS
    INSERT INTO Link
(Url, LastDataCollectionTime, Description, UserId)
    VALUES 
(@url, @lastDataCollectionTime, @description, @userId)
  
    SELECT SCOPE_IDENTITY()

Код добавления юзера в бд

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
       public async Task<bool> CreateAsync(User user)
        {
            await _db.ConnectAsync;
 
            var command = new SqlCommand("sp_InsertUser", _db.Connection);
            command.CommandType = CommandType.StoredProcedure;
            command.Parameters.AddWithValue("@Tag", user.Tag);
            command.Parameters.AddWithValue("@Name", user.Name);
            command.Parameters.AddWithValue("@JoinDate", user.JoinDate);
            command.Parameters.AddWithValue("@LastActivity", user.LastActivity);
            command.Parameters.AddWithValue("@ParsingPaused", user.ParsingPaused);
 
            var userId = (decimal) await command.ExecuteScalarAsync();
 
            if (user.Links.Count > 0)
            {
               var transaction = _db.Connection.BeginTransaction();
 
                foreach (var link in user.Links)
                {
                    var linkCommand = new SqlCommand("sp_InsertLink", _db.Connection);
                    linkCommand.CommandType = CommandType.StoredProcedure;
                    linkCommand.Transaction = transaction;
                    
                    linkCommand.Parameters.AddWithValue("@url", link.Url);
                    linkCommand.Parameters.AddWithValue("@lastDataCollectionTime", link.LastDataCollectionTime);
                    linkCommand.Parameters.AddWithValue("@description", link.Description);
                    linkCommand.Parameters.AddWithValue("@userId", userId);
                    await linkCommand.ExecuteNonQueryAsync();
                }
                
                await transaction.CommitAsync();
            }
 
            await _db.DisconnectAsync;
            return userId > 0;
        }

@OwenGlendower · 21.08.2022, 22:17

xr_Sanya, 1. Почему транзакция используется только для ссылок?

2. Где обработка исключений с откатом транзакции?

3. Почему userId в коде это decimal когда в БД это вроде int?

4. Для создания ссылок можно переиспользовать одну и ту же команду и параметры. Будет небольшая экономия памяти.

@xr_Sanya · 21.08.2022, 22:40 **[ТС]**

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

1. Почему транзакция используется только для ссылок?
2. Где обработка исключений с откатом транзакции?
3. Почему userId в коде это decimal когда в БД это вроде int?
4. Для создания ссылок можно переиспользовать одну и ту же команду и параметры. Будет небольшая экономия памяти.

1. Да, действительно не подумал что можно одним запросом
2. Сделал
3. Без понятия, почему то не кастится к инту, хотя в бд установлен int
4. Поправил

Получаю ошибку

Code
1
System.Data.SqlClient.SqlException (0x80131904): Для процедуры или функции sp_InsertLink указано слишком много аргументов.

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
        public async Task<bool> CreateAsync(User user)
        {
            await _db.ConnectAsync;
            var transaction = _db.Connection.BeginTransaction();
 
            try
            {
                var command = new SqlCommand("sp_InsertUser", _db.Connection);
                command.CommandType = CommandType.StoredProcedure;
                command.Transaction = transaction;
 
                command.Parameters.AddWithValue("@Tag", user.Tag);
                command.Parameters.AddWithValue("@Name", user.Name);
                command.Parameters.AddWithValue("@JoinDate", user.JoinDate);
                command.Parameters.AddWithValue("@LastActivity", user.LastActivity);
                command.Parameters.AddWithValue("@ParsingPaused", user.ParsingPaused);
 
                var userId = (decimal) await command.ExecuteScalarAsync();
 
                if (user.Links.Count > 0)
                {
                    var linkCommand = new SqlCommand("sp_InsertLink", _db.Connection);
                    linkCommand.CommandType = CommandType.StoredProcedure;
                    linkCommand.Transaction = transaction;
                    
                    foreach (var link in user.Links)
                    {
                        linkCommand.Parameters.AddWithValue("@url", link.Url);
                        linkCommand.Parameters.AddWithValue("@lastDataCollectionTime", link.LastDataCollectionTime);
                        linkCommand.Parameters.AddWithValue("@description", link.Description);
                        linkCommand.Parameters.AddWithValue("@userId", userId);
                        await linkCommand.ExecuteNonQueryAsync();
                    }
 
                    await transaction.CommitAsync();
                }
 
                return userId > 0;
            }
            catch (Exception ex)
            {
                transaction.Rollback();
                Console.WriteLine(ex);
            }
            finally
            {
                await _db.DisconnectAsync;
            }
            
            return false;
        }

@OwenGlendower · 21.08.2022, 22:57

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

3. Без понятия, почему то не кастится к инту, хотя в бд установлен int

Попробуйте в хранимке кастануть SCOPE_IDENTITY к int.

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

4. Поправил Получаю ошибку

Добавлять параметры нужно только один раз. Далее можно использовать переменную параметра или через индексатор значения назначать.

@xr_Sanya · 21.08.2022, 23:09 **[ТС]**

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

Попробуйте в хранимке кастануть SCOPE_IDENTITY к int.

Code
1
 select CAST(SCOPE_IDENTITY() as int)

Вроде правильно кастанул, работает. Сам столбец интовый, из за чего может возникать такое?

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

Добавлять параметры нужно только один раз. Далее можно использовать переменную параметра или через индексатор значения назначать.

Не совсем понял, если можно напишите пожалуйста пример

@OwenGlendower · 21.08.2022, 23:32

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

Сам столбец интовый, из за чего может возникать такое?

Ответ есть в документации. Тип возвращаемого значения для SCOPE_IDENTITY это numeric(38,0). В C# ему соответствует decimal.

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

если можно напишите пожалуйста пример

Раз

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
SqlCommand cmd = new SqlCommand();
var prmId = new SqlParameter("@Id", SqlDbType.Int);
var prmName = new SqlParameter("@Name", SqlDbType.VarChar);
cmd.Parameters.Add(prmId);
cmd.Parameters.Add(prmName);
 
for (...)
{
    prmId.Value = id;
    prmName.Value = name;
    
    await cmd.ExecuteNonQueryAsync();
}

Два

C#
1
2
3
4
5
6
7
8
9
10
11
SqlCommand cmd = new SqlCommand();
cmd.Parameters.Add(new SqlParameter("@Id", SqlDbType.Int));
cmd.Parameters.Add(new SqlParameter("@Name", SqlDbType.VarChar));
 
for (...)
{
    cmd.Parameters["@Id"].Value = id;
    cmd.Parameters["@Name"].Value = name;
    
    await cmd.ExecuteNonQueryAsync();
}

@Andrey-MSK · 23.08.2022, 11:22

xr_Sanya, вот вам пример с параметрами и всем остальным - https://www.cyberforum.ru/ado-... st16373306

Новые блоги и статьи Все статьи Все блоги /
Переходник USB-CAN-GPIO Eddy_Em 20.03.2026 Достаточно давно на работе возникла необходимость в переходнике CAN-USB с гальваноразвязкой, оный и был разработан. Однако, все меня терзала совесть, что аж 48-ногий МК используется так тупо: просто. . .	Оттенки серого Argus19 18.03.2026 Оттенки серого Нашёл в интернете 3 прекрасных модуля: Модуль класса открытия диалога открытия/ сохранения файла на Win32 API; Модуль класса быстрого перекодирования цветного изображения в оттенки. . .	SDL3 для Desktop (MinGW): Рисуем цветные прямоугольники с помощью рисовальщика SDL3 на Си и C++ 8Observer8 17.03.2026 Содержание блога Финальные проекты на Си и на C++: finish-rectangles-sdl3-c. zip finish-rectangles-sdl3-cpp. zip	Символические и жёсткие ссылки в Linux. algri14 15.03.2026 Существует два типа ссылок — символические и жёсткие. Ссылка в Linux — это запись в каталоге, которая может указывать либо на inode «файла-ИСТОЧНИКА», тогда это будет «жёсткая ссылка» (hard link),. . .
[Owen Logic] Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ФедосеевПавел 14.03.2026 Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ВВЕДЕНИЕ Выполняя задание на управление насосной группой заполнения резервуара,. . .	делаю науч статью по влиянию грибов на сукцессию anaschu 13.03.2026 прикрепляю статью	SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .

@xr_Sanya 3 / 3 / 0 Регистрация: 13.07.2020 Сообщений: 229

	SQL, один ко многим и SqlConnection 21.08.2022, 16:53. Показов 1134. Ответов 8 Метки нет (Все метки) Здравствуйте, подскажите пожалуйста как работать со связью один ко многим/многие ко многим. Допустим у меня есть пользователь и у него список ссылок, как получить данные я знаю, а вот как добавить новые не понятно. Суть в том что я хочу сделать метод CreateUser, он соответственно принимает в себе сущностью пользователя. У сущности есть id и List со ссылками. Ссылки представлены классом Link, в нем есть id, url и UserId. Тоесть связь один ко многим. Что написать в теле метода? Я так понимаю что сперва нужно добавить пользователя в базу, потом найти добавленного пользователя в базе, потом добавить в таблицу со ссылками ссылки пользователя и каждой присвоить UserId полученный от базы? Или может есть другие варианты? Все это я делаю через SqlConnection, не через EF. 0

@OwenGlendower Администратор 18298 / 14222 / 5368 Регистрация: 17.03.2014 Сообщений: 28,900 Записей в блоге: 1
	21.08.2022, 22:17
	xr_Sanya, 1. Почему транзакция используется только для ссылок? 2. Где обработка исключений с откатом транзакции? 3. Почему userId в коде это decimal когда в БД это вроде int? 4. Для создания ссылок можно переиспользовать одну и ту же команду и параметры. Будет небольшая экономия памяти. 1

@Andrey-MSK 3349 / 2235 / 388 Регистрация: 14.08.2018 Сообщений: 7,557 Записей в блоге: 4
	23.08.2022, 11:22
	xr_Sanya, вот вам пример с параметрами и всем остальным - https://www.cyberforum.ru/ado-... st16373306 1

SQL, один ко многим и SqlConnection

Решение