C#涓璭xecutereader鎬庝箞浣跨敤
鍦–#涓紝ExecuteReader鏂规硶鐢ㄤ簬浠庢暟鎹簱涓绱㈡暟鎹€備互涓嬫槸浣跨敤ExecuteReader鏂规硶鐨勫熀鏈娉曪細
- 鍒涘缓涓€涓猄qlConnection瀵硅薄锛岀敤浜庝笌鏁版嵁搴撳缓绔嬭繛鎺ャ€?/li>
SqlConnection connection = new SqlConnection(connectionString);
- 鍒涘缓涓€涓猄qlCommand瀵硅薄锛岀敤浜庢墽琛孲QL鏌ヨ璇彞銆?/li>
SqlCommand command = new SqlCommand(query, connection);
-
query锛氳鎵ц鐨凷QL鏌ヨ璇彞銆?/p>
-
connection锛氳繛鎺ュ埌鏁版嵁搴撶殑SqlConnection瀵硅薄銆?/p>
- 鎵撳紑鏁版嵁搴撹繛鎺ャ€?/li>
connection.Open();
- 浣跨敤ExecuteReader鏂规硶鎵ц鏌ヨ锛屽苟灏嗙粨鏋滃瓨鍌ㄥ湪SqlDataReader瀵硅薄涓€?/li>
SqlDataReader reader = command.ExecuteReader();
- 浣跨敤reader瀵硅薄鐨凴ead鏂规硶鏉ラ€愯璇诲彇鏌ヨ缁撴灉銆?/li>
while (reader.Read())
{
// 澶勭悊姣忎竴琛岀殑鏁版嵁
}
- Read鏂规硶杩斿洖涓€涓竷灏斿€硷紝琛ㄧず鏄惁杩樻湁鍙敤鐨勬暟鎹銆?/li>
- 鍦ㄤ娇鐢ㄥ畬reader瀵硅薄鍚庯紝鍏抽棴鏁版嵁搴撹繛鎺ュ拰reader瀵硅薄銆?/li>
reader.Close();
connection.Close();
瀹屾暣鐨勭ず渚嬩唬鐮佸涓嬶細
using System;
using System.Data.SqlClient;
class Program
{
static void Main()
{
string connectionString = "YourConnectionString";
string query = "SELECT * FROM YourTable";
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(query, connection);
connection.Open();
using (SqlDataReader reader = command.ExecuteReader())
{
while (reader.Read())
{
// 澶勭悊姣忎竴琛岀殑鏁版嵁
}
}
}
}
}
璇锋敞鎰忥紝涓婅堪绀轰緥浣跨敤using璇彞鏉ョ‘淇濆湪浣跨敤瀹岀浉鍏冲璞″悗姝g‘鍏抽棴鏁版嵁搴撹繛鎺ュ拰reader瀵硅薄銆?/p>