С#. SQLNonQuery Execute

Metanit

После установки подключения мы можем выполнить к базе данных какие-либо команды, например, добавить в базу данных объект, удалить, изменить его или просто извлечь. Команды представлены объектом интерфейса System.Data.IDbCommand. Провайдер для MS SQL предоставляет его реализацию в виде класса SqlCommand. Этот класс инкапсулирует sql-выражение, которое должно быть выполнено.

Для выполнения команды нам потребуется sql-выражение и объект подключения:

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    SqlCommand command = new SqlCommand();
    command.CommandText = "SELECT * FROM Users";
    command.Connection = connection;
}

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

SqlCommand command = new SqlCommand();

command.CommandText = "SELECT * FROM Users";

command.Connection = connection;

}

С помощью свойства CommandText устанавливается SQL-выражение, которое будет выполняться. В данном случае это запрос на получение всех объектов из таблицы Users. А с помощью свойства Connection можно установить объект подключения SqlConnection.

В качестве альтернативы можно было бы использовать одну из версий конструктора класса:

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";
string sqlExpression = "SELECT * FROM Users";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    SqlCommand command = new SqlCommand(sqlExpression, connection);
}

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";

string sqlExpression = "SELECT * FROM Users";

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

SqlCommand command = new SqlCommand(sqlExpression, connection);

}

Чтобы выполнить команду, необходимо применить один из методов SqlCommand:

ExecuteNonQuery: просто выполняет sql-выражение и возвращает количество измененных записей. Подходит для sql-выражений INSERT, UPDATE, DELETE.
ExecuteReader: выполняет sql-выражение и возвращает строки из таблицы. Подходит для sql-выражения SELECT.
ExecuteScalar: выполняет sql-выражение и возвращает одно скалярное значение, например, число. Подходит для sql-выражения SELECT в паре с одной из встроенных функций SQL, как например, Min, Max, Sum, Count.

Добавление объектов

Выполним команду по добавлению одного объекта в таблицу Users базы данных usersdb, которая ранее была создана:

class Program
{
    static void Main(string[] args)
    {
        string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";
        string sqlExpression = "INSERT INTO Users (Name, Age) VALUES ('Tom', 18)";
             
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlCommand command = new SqlCommand(sqlExpression, connection);
            int number = command.ExecuteNonQuery();
            Console.WriteLine("Добавлено объектов: {0}", number);
        }
        Console.Read();
    }
}

class Program

{

static void Main(string[] args)

{

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";

string sqlExpression = "INSERT INTO Users (Name, Age) VALUES ('Tom', 18)";

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

SqlCommand command = new SqlCommand(sqlExpression, connection);

int number = command.ExecuteNonQuery();

Console.WriteLine("Добавлено объектов: {0}", number);

}

Console.Read();

}

Обновление объектов

Обновление будет происходить аналогично, только теперь будет использоваться sql-выражение UPDATE, которое имеет следующий синтаксис:

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";
 
string sqlExpression = "UPDATE Users SET Age=20 WHERE Name='Tom'";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    SqlCommand command = new SqlCommand(sqlExpression, connection);
    int number = command.ExecuteNonQuery();
    Console.WriteLine("Обновлено объектов: {0}", number);
}

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";

string sqlExpression = "UPDATE Users SET Age=20 WHERE Name='Tom'";

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

SqlCommand command = new SqlCommand(sqlExpression, connection);

int number = command.ExecuteNonQuery();

Console.WriteLine("Обновлено объектов: {0}", number);

}

Удаление производится с помощью sql-выражения DELETE, которое имеет следующий синтаксис:

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";
string sqlExpression = "DELETE  FROM Users WHERE Name='Tom'";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    SqlCommand command = new SqlCommand(sqlExpression, connection);
    int number = command.ExecuteNonQuery();
    Console.WriteLine("Удалено объектов: {0}", number);
}

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";

string sqlExpression = "DELETE FROM Users WHERE Name='Tom'";

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

SqlCommand command = new SqlCommand(sqlExpression, connection);

int number = command.ExecuteNonQuery();

Console.WriteLine("Удалено объектов: {0}", number);

}

Во всех трех случаях фактически меняется только sql-выражение, а остальная логика остается неизменной. И мы также можем выполнять сразу несколько операций:

static void Main(string[] args)
{
    string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";
 
    Console.WriteLine("Введите имя:");
    string name = Console.ReadLine();
 
    Console.WriteLine("Введите возраст:");
    int age = Int32.Parse(Console.ReadLine());
 
    string sqlExpression = String.Format("INSERT INTO Users (Name, Age) VALUES ('{0}', {1})", name, age);
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();
        // добавление
        SqlCommand command = new SqlCommand(sqlExpression, connection);
        int number = command.ExecuteNonQuery();
        Console.WriteLine("Добавлено объектов: {0}", number);
 
        // обновление ранее добавленного объекта
        Console.WriteLine("Введите новое имя:");
        name = Console.ReadLine();
        sqlExpression = String.Format("UPDATE Users SET Name='{0}' WHERE Age={1}", name, age);
        command.CommandText = sqlExpression;
        number = command.ExecuteNonQuery();
        Console.WriteLine("Обновлено объектов: {0}", number);
    }       
    Console.Read();
}

static void Main(string[] args)

{

string connectionString = @"Data Source=.\SQLEXPRESS;Initial Catalog=usersdb;Integrated Security=True";

Console.WriteLine("Введите имя:");

string name = Console.ReadLine();

Console.WriteLine("Введите возраст:");

int age = Int32.Parse(Console.ReadLine());

string sqlExpression = String.Format("INSERT INTO Users (Name, Age) VALUES ('{0}', {1})", name, age);

using (SqlConnection connection = new SqlConnection(connectionString))

{

connection.Open();

// добавление

SqlCommand command = new SqlCommand(sqlExpression, connection);

int number = command.ExecuteNonQuery();

Console.WriteLine("Добавлено объектов: {0}", number);

// обновление ранее добавленного объекта

Console.WriteLine("Введите новое имя:");

name = Console.ReadLine();

sqlExpression = String.Format("UPDATE Users SET Name='{0}' WHERE Age={1}", name, age);

command.CommandText = sqlExpression;

number = command.ExecuteNonQuery();

Console.WriteLine("Обновлено объектов: {0}", number);

}

Console.Read();

}

Добавление объектов

Обновление объектов

MY PROJECTS

Recent Posts

Categories