几个数据库的小案例（一）：将文本文件中的信息导入数据库的表中

//FrmMain.cs
//作者：Me
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
using System.IO;

namespace 数据库的链接
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }


        private void btnOpenFile_Click(object sender, EventArgs e)
        {
            #region 写一个程序，要求：uName和uPass从文件导入，并将其插入到数据库WebSite的UserInfo表中
            //打开文件对话框
            OpenFileDialog ofd = new OpenFileDialog();

            //指定ofd的过滤器
            ofd.Filter = "文本文件|*.txt|所有文件|*.*";
            //指定ofd的是否多选择属性
            ofd.Multiselect = false;
            //指定ofd的初始化目录
            ofd.InitialDirectory = @"D:\";
            //指定ofd的标题
            ofd.Title = "请选择要打开的文本文件";

            if (ofd.ShowDialog() == DialogResult.OK)
            {
                txtFileName.Text = ofd.FileName;
            }

            

            #endregion
        }
        /// <summary>
        /// 需求增加
        /// 1.增加一个导入成功后弹出的统计对话框
        /// 2.增加判断如果，用户选择的是一个非法的文本文件，那么让Insert方法返回false
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnImportData_Click(object sender, EventArgs e)
        {
            //判断文本框是否有值 并且 文件是否存在 并且 值是否为一个txt文件的路径
            if (String.IsNullOrEmpty(txtFileName.Text) 
                || !File.Exists(txtFileName.Text) 
                || !String.Equals(txtFileName.Text.Split(‘.‘)[txtFileName.Text.Split(‘.‘).Length - 1], "txt"))
            {
                MessageBox.Show("文件错误，请重新导入！");
                return;
            }

            //读取文本文件的数据，并循环导入
            string[] allLines = File.ReadAllLines(txtFileName.Text.Trim(), Encoding.Default);
            //定义一个判断是否全部导入的计数器
            int totalNumber = allLines.Length;
            int hasImportedNumber = 0;

            foreach (string str in allLines)
            {
                string[] eachLinesArray = str.Split(‘|‘);

                //传入要插入的用户名和密码
                if (str.IndexOf(‘|‘) != -1)
                {
                    //eachLines{string[1]} 表示的是eachLines是一个长度为1的字符串数组（也就是说只有eachLines[1]的位置有值）
                    if (SqlHelper.Insert(eachLinesArray[0], eachLinesArray[1]))
                    {
                        hasImportedNumber++;
                    }
                }
            }

            MessageBox.Show(String.Format("总共：{0}条\n成功导入:{1}条\n成功率:{2}%\n", totalNumber, hasImportedNumber, hasImportedNumber/(float)totalNumber*100));

        }

        private void btnOutPut_Click(object sender, EventArgs e)
        {
            //创建保存文本框对象
            SaveFileDialog sfd = new SaveFileDialog();
            
            //设置默认的保存格式，这里只有txt
            sfd.Filter = "文本文件(*.txt)|*.txt";
            //设置标题
            sfd.Title = "请选择要保存的文件";

            //当点击确定，获取路径
            if (sfd.ShowDialog() == DialogResult.OK)
            {
                //创建一个空的泛型集合
                List<string> list = new List<string>();
                //使用查询函数将查询结果添加到泛型集合中
                SqlHelper.DataSelect(list);
                //将泛型集合的数组写入文件
                File.WriteAllLines(sfd.FileName, list);
            }

        }
    }



}

//SqlHelper.cs
//作者：Me
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Windows.Forms;

namespace 数据库的链接
{
    /// <summary>
    /// SqlHelper用于执行数据库增删改查的操作
    /// </summary>
    class SqlHelper
    {
        private static string sqlStr = "server=.;database=WebSite;uid=sa;pwd=123456";

        /// <summary>
        /// 向数据库插入记录
        /// </summary>
        /// <param name="name">待插入用户名</param>
        /// <param name="pass">待插入密码</param>
        /// <returns></returns>
        public static bool Insert(string name, string pass)
        {
            using (SqlConnection conn = new SqlConnection(sqlStr))
            {
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    bool res = false;
                    cmd.CommandText = "insert UserInfo values (@name, @pass)";
                    cmd.Parameters.Add(new SqlParameter("@name", name));
                    cmd.Parameters.Add(new SqlParameter("@pass", pass));

                    try
                    {
                        conn.Open();
                        res = cmd.ExecuteNonQuery() > 0;
                    }
                    catch (Exception ex)
                    {
                        MessageBox.Show(ex.Message);

                    }

                    return res;
                }

            }
        }

        public static void DataSelect(List<string>  list)
        {
            using (SqlConnection conn = new SqlConnection(sqlStr))
            {
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    SqlDataReader dr = null;

                    cmd.CommandText = "select uName,uPass from UserInfo";
                    try
                    {
                        conn.Open();
                        dr = cmd.ExecuteReader();
                    }
                    catch (Exception ex)
                    {
                        MessageBox.Show("数据库错误：\n"+ex.Message);
                        return;
                    }

                    if (dr.HasRows)
                    {
                        while (dr.Read())
                        {
                            list.Add( String.Concat(dr[0].ToString(), "|", dr[1].ToString()) );
                        }
                    }
                    
                }
            }
            
        }
    }
}