Чтение таблицы SQL в С# DataTable
Я прочитал много сообщений о вставке DataTable в таблицу SQL, но есть ли простой способ вытащить таблицу SQL в .NET DataTable?
Ответы
Ответ 1
Здесь дайте этот снимок (это просто псевдокод)
using System;
using System.Data;
using System.Data.SqlClient;
public class PullDataTest
{
// your data table
private DataTable dataTable = new DataTable();
public PullDataTest()
{
}
// your method to pull data from database to datatable
public void PullData()
{
string connString = @"your connection string here";
string query = "select * from table";
SqlConnection conn = new SqlConnection(connString);
SqlCommand cmd = new SqlCommand(query, conn);
conn.Open();
// create data adapter
SqlDataAdapter da = new SqlDataAdapter(cmd);
// this will query your database and return the result to your datatable
da.Fill(dataTable);
conn.Close();
da.Dispose();
}
}
Ответ 2
var table = new DataTable();
using (var da = new SqlDataAdapter("SELECT * FROM mytable", "connection string"))
{
da.Fill(table);
}
Ответ 3
Множество способов.
Используйте ADO.Net и используйте fill на адаптере данных, чтобы получить DataTable:
using (SqlDataAdapter dataAdapter
= new SqlDataAdapter ("SELECT blah FROM blahblah ", sqlConn))
{
// create the DataSet
DataSet dataSet = new DataSet();
// fill the DataSet using our DataAdapter
dataAdapter.Fill (dataSet);
}
Затем вы можете получить таблицу данных из набора данных.
Примечание в наборе данных с расширенным ответом не используется (оно появилось после моего ответа)
Он делает
// create data adapter
SqlDataAdapter da = new SqlDataAdapter(cmd);
// this will query your database and return the result to your datatable
da.Fill(dataTable);
Что предпочтительнее для меня.
Я бы настоятельно рекомендовал взглянуть на структуру сущностей, хотя... использование данных и наборов данных - отличная идея. На них нет безопасности типов, что означает, что отладка может быть выполнена только во время выполнения. С сильно типизированными коллекциями (которые вы можете получить от использования LINQ2SQL или сущности) ваша жизнь будет намного проще.
Изменить: Возможно, я не был ясен: Datatables = good, datasets = evil. Если вы используете ADO.Net, вы можете использовать обе эти технологии (EF, linq2sql, dapper, nhibernate, orm месяца), поскольку они обычно сидят поверх ado.net. Преимущество, которое вы получаете, это то, что вы можете обновить свою модель намного проще, так как ваши изменения схемы при условии, что у вас есть нужный уровень абстракции, используя генерацию кода.
Адаптер ado.net использует поставщиков, которые раскрывают информацию о типе базы данных, например, по умолчанию она использует поставщика сервера sql, вы также можете подключить - например, postart provider от devart и получить доступ к информации о типе который затем позволит вам, как и выше, использовать ваш выбор (почти безболезненно - есть несколько причуд) - я считаю, что Microsoft также предоставляет поставщика оракула. Цель этого заключается в том, чтобы абстрагироваться от реализации базы данных, где это возможно.
Ответ 4
Независимая от поставщика версия, опирается только на интерфейсы ADO.NET; 2 способа:
public DataTable Read1<T>(string query) where T : IDbConnection, new()
{
using (var conn = new T())
{
using (var cmd = conn.CreateCommand())
{
cmd.CommandText = query;
cmd.Connection.ConnectionString = _connectionString;
cmd.Connection.Open();
var table = new DataTable();
table.Load(cmd.ExecuteReader());
return table;
}
}
}
public DataTable Read2<S, T>(string query) where S : IDbConnection, new()
where T : IDbDataAdapter, IDisposable, new()
{
using (var conn = new S())
{
using (var da = new T())
{
using (da.SelectCommand = conn.CreateCommand())
{
da.SelectCommand.CommandText = query;
da.SelectCommand.Connection.ConnectionString = _connectionString;
DataSet ds = new DataSet(); //conn is opened by dataadapter
da.Fill(ds);
return ds.Tables[0];
}
}
}
}
Я провел некоторое тестирование производительности, и второй подход всегда превосходил первый.
Stopwatch sw = Stopwatch.StartNew();
DataTable dt = null;
for (int i = 0; i < 100; i++)
{
dt = Read1<MySqlConnection>(query); // ~9800ms
dt = Read2<MySqlConnection, MySqlDataAdapter>(query); // ~2300ms
dt = Read1<SQLiteConnection>(query); // ~4000ms
dt = Read2<SQLiteConnection, SQLiteDataAdapter>(query); // ~2000ms
dt = Read1<SqlCeConnection>(query); // ~5700ms
dt = Read2<SqlCeConnection, SqlCeDataAdapter>(query); // ~5700ms
dt = Read1<SqlConnection>(query); // ~850ms
dt = Read2<SqlConnection, SqlDataAdapter>(query); // ~600ms
dt = Read1<VistaDBConnection>(query); // ~3900ms
dt = Read2<VistaDBConnection, VistaDBDataAdapter>(query); // ~3700ms
}
sw.Stop();
MessageBox.Show(sw.Elapsed.TotalMilliseconds.ToString());
Read1
выглядит лучше на глазах, но адаптер данных работает лучше (не путать, что один db превосходил другой, все были разные запросы). Однако разница между ними зависела от запроса. Причина может заключаться в том, что Load
требует, чтобы различные ограничения проверялись по строке из документации при добавлении строк (его метод на DataTable
), а Fill
- на DataAdapters, которые были предназначены именно для этого - быстрое создание DataTables.
Ответ 5
Централизованная модель: вы можете использовать ее из любого места!
Вам просто нужно вызвать Below Format из вашей функции в этот класс
DataSet ds = new DataSet();
SqlParameter[] p = new SqlParameter[1];
string Query = "Describe Query Information/either sp, text or TableDirect";
DbConnectionHelper dbh = new DbConnectionHelper ();
ds = dbh. DBConnection("Here you use your Table Name", p , string Query, CommandType.StoredProcedure);
Это. это идеальный метод.
public class DbConnectionHelper {
public DataSet DBConnection(string TableName, SqlParameter[] p, string Query, CommandType cmdText) {
string connString = @ "your connection string here";
//Object Declaration
DataSet ds = new DataSet();
SqlConnection con = new SqlConnection();
SqlCommand cmd = new SqlCommand();
SqlDataAdapter sda = new SqlDataAdapter();
try {
//Get Connection string and Make Connection
con.ConnectionString = connString; //Get the Connection String
if (con.State == ConnectionState.Closed) {
con.Open(); //Connection Open
}
if (cmdText == CommandType.StoredProcedure) //Type : Stored Procedure
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = Query;
if (p.Length > 0) // If Any parameter is there means, we need to add.
{
for (int i = 0; i < p.Length; i++) {
cmd.Parameters.Add(p[i]);
}
}
}
if (cmdText == CommandType.Text) // Type : Text
{
cmd.CommandType = CommandType.Text;
cmd.CommandText = Query;
}
if (cmdText == CommandType.TableDirect) //Type: Table Direct
{
cmd.CommandType = CommandType.Text;
cmd.CommandText = Query;
}
cmd.Connection = con; //Get Connection in Command
sda.SelectCommand = cmd; // Select Command From Command to SqlDataAdaptor
sda.Fill(ds, TableName); // Execute Query and Get Result into DataSet
con.Close(); //Connection Close
} catch (Exception ex) {
throw ex; //Here you need to handle Exception
}
return ds;
}
}