Проект «SnakeProject» Михаила Козлова

⇒ Общая ⇐

CISCO

Voice(Asterisk\Cisco)

Microsoft

Powershell

Python

SQL\T-SQL

FreeBSD and Nix

1С

WEB Разработка

ORACLE SQL \ JAVA

Мото

C#: ADO - Работаем с базой данных

Имеем имя проекта дал - ADO

В app.config:

 В Program.cs:

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Data.SqlClient; using System.Threading; using System.Data; using ADO.Properties; namespace ADO { class Program { static void Main(string[] args) { //Initial Catalog: указывает на название базы данных на сервере //Integrated Security: устанавливает проверку подлинности //Connecting to SQL Server using windows authentication //"Server= 10.10.1.5; Database= Your_Database;Integrated Security = SSPI;" //Пример с подключением из свойств проекта вкладки парамтры(в App.config для консольного приложения) using (IDbConnection connection = new SqlConnection(Settings.Default.DbConnectionSA)) { IDbCommand command = new SqlCommand("SELECT * FROM people"); command.Connection = connection; connection.Open(); IDataReader reader = command.ExecuteReader(); while (reader.Read()) { Console.WriteLine("{0}\t{1}", reader.GetValue(0), reader.GetValue(1)); } reader.Close(); connection.Close(); } //Остальные примеры без подключения из свойств проекта вкладки парамтры string sqlQuery = "SELECT * FROM dbo.people"; string connStr = "Data Source=10.10.12.5;Initial Catalog=your_base;User ID=your_user;Password=your_pass"; try { GetResultAsync(sqlQuery, connStr); GetResult(sqlQuery, connStr); } catch (Exception ex) { Console.WriteLine("Can not open connection ! \n" + ex.Message); } Thread.Sleep(6000); //Изменение данных GSQLQuerys(connStr); Console.ReadKey(); } static void GetResult(string query, string connStr) { SqlConnection DbConnection = new SqlConnection(connStr); DbConnection.Open(); SqlDataReader dataReader; SqlCommand command = new SqlCommand(query, DbConnection); dataReader = command.ExecuteReader(); Console.WriteLine("=====================GetResult====================="); while (dataReader.Read()) { Console.WriteLine(dataReader.GetValue(0) + " - " + dataReader.GetValue(1)); //Console.WriteLine(dataReader["name"] + " - " + dataReader["age"]); } Console.WriteLine("=====================GetResult====================="); dataReader.Close(); command.Dispose(); DbConnection.Close(); } static async void GetResultAsync(string query, string connStr) { using (SqlConnection DbConnection = new SqlConnection(connStr)) { await DbConnection.OpenAsync(); SqlCommand command = new SqlCommand(query, DbConnection); SqlDataReader reader = await command.ExecuteReaderAsync(); Thread.Sleep(3000); Console.WriteLine("=====================GetResultAsync====================="); if (reader.HasRows) { // выводим названия столбцов Console.WriteLine("{0}\t{1}", reader.GetName(0), reader.GetName(1)); while (await reader.ReadAsync()) { object name = reader.GetValue(0); object age = reader.GetValue(1); Console.WriteLine("{0}\t{1}", name, age); } } Console.WriteLine("=====================GetResultAsync====================="); reader.Close(); command.Dispose(); DbConnection.Close(); } } static void GSQLQuerys(string connStrInst) { string sqlQueryInsert = "INSERT INTO dbo.people(name, age) VALUES('Tester Test', 30)"; string sqlQueryUpdate = "UPDATE dbo.people SET age = 33 WHERE name = 'Tester Test'"; string sqlQuerySelect = "SELECT * FROM dbo.people"; string sqlQueryDelete = "DELETE FROM dbo.people WHERE name = 'Tester Test'"; SqlConnection DbConnection = new SqlConnection(connStrInst); DbConnection.Open(); SqlCommand command1 = new SqlCommand(sqlQueryInsert, DbConnection); command1.ExecuteNonQuery(); SqlCommand command2 = new SqlCommand(sqlQueryUpdate, DbConnection); command2.ExecuteNonQuery(); SqlCommand command3 = new SqlCommand(sqlQuerySelect, DbConnection); SqlDataReader data3Reader = command3.ExecuteReader(); Console.WriteLine("====================data3Reader===================="); while (data3Reader.Read()) { //Console.WriteLine(data3Reader.GetValue(0) + " - " + data3Reader.GetValue(1)); Console.WriteLine(data3Reader["name"] + " - " + data3Reader["age"]); } Console.WriteLine("====================data3Reader===================="); data3Reader.Close(); command3.Dispose(); SqlCommand command4 = new SqlCommand(sqlQueryDelete, DbConnection); command4.ExecuteNonQuery(); DbConnection.Close(); } } }

Комментарии пользователей