如何使用 WinForm 将 1 个文件 PDF 保存到 SQL Server

Question

代码查询数据库：

我无法将 PDF 文件保存到我的数据库中，我的数据库存储区域出现了严重问题。

public void ADDWORK(String MAW, string NAMEW, string IDUSER, bool Image,string room, byte[] document,string content,bool donework)
{
    String strSql = string.Format("INSERT INTO WORK(IDWORD,NAMEWORk,IDUSER,IMAGES,IDROOM,DOCUMENTS,CONTENT,DONEWORK)VALUES('{0}',N'{1}',N'{2}','{3}',N'{4}',N'{5}',N'{6}',N'{7}')"
        , MAW, NAMEW, IDUSER, Image,room,document,content,donework);
    db.ExecuteNonQuery(strSql);
}

代码调用函数：

byte[] pdf;
public void UploadFlie(string file)
{
    FileStream fileStream = File.OpenRead(file);
    byte[] contents = new byte[fileStream.Length];
    fileStream.Read(contents, 0, (int)fileStream.Length);
    fileStream.Close();
    pdf = contents;
}

private void button1_Click(object sender, EventArgs e)
{
    UploadFlie(filename);
     dg.ADDWORK(idword, textBox1.Text,"1",  false,"ROOM1", pdf, richTextBox1.Text, false);
    MessageBox.Show("Done!");
}

Answer 1

这是我的示例，如何获取任何文件并将其保存在数据库中。

我使用两种不同的方法

1. 保存字节数组。
2. 保存流

首先你需要创建列 varbinary(MAX) 在我的例子中我称之为 - PdfFile 和 PdfExtn 列将文件的类型保存为 varchar(10)（可以使用 4）。

1. 保存字节数组：

        private void btnGetFile_Click(object sender, EventArgs e)
    {
        OpenFileDialog openFileDialog1 = new OpenFileDialog();
        DialogResult result = openFileDialog1.ShowDialog(); // Show the dialog.
        if (result == DialogResult.OK) // Test result.
        {
            string file = openFileDialog1.FileName;
            string extn = new FileInfo(file).Extension;
   
            try
            {
                byte[] fileBytes = File.ReadAllBytes(file);
                string cmd = "INSERT INTO Employee(Id,FirstName,LastName,Email,Password,PdfFile,FileExtn) VALUES (@Id,@FirstName,@LastName,@Email,@Password,@PdfFile,@FileExtn)";
   
                List<SqlParameter> l = new List<SqlParameter>();
                l.Add(new SqlParameter("@Id", "101"));
                l.Add(new SqlParameter("@FirstName", "Aviv"));
                l.Add(new SqlParameter("@LastName", "Halevy"));
                l.Add(new SqlParameter("@Email", "Assadsa@gmail.com"));
                l.Add(new SqlParameter("@Password", "123456"));
                SqlParameter sp = new SqlParameter("@PdfFile", SqlDbType.VarBinary, -1);
                sp.Value = fileBytes;
                l.Add(sp);
                l.Add(new SqlParameter("@FileExtn", extn));
                if (DAL.Database.ParametersCommand(cmd, l) > 0)
                    textBox1.Text = "SUCCESS! Save with byte array";
            }
            catch (IOException ex)
            {
   
            }
        }
    }
   

从字节写入文件：

  private void btnReadFromDb_Click(object sender, EventArgs e)
    {
        string cmd = "SELECT * FROM Employee WHERE Id = '101'";
        string path = "YOUR_PATH\\Test";
        DataTable dt = DAL.Database.GetDataTable(cmd);
        if (dt != null && dt.Rows.Count > 0)
        {
            Byte[] file = (Byte[])dt.Rows[0]["PdfFile"];
            string extn = dt.Rows[0]["FileExtn"].ToString();
            path = Path.Combine(path, "Test321"+extn);

            File.WriteAllBytes(path, file);
            Process.Start(path);
        }
    }

结果：

1. 使用流

   private void button1_Click(object sender, EventArgs e)
    {
   
        OpenFileDialog openFileDialog1 = new OpenFileDialog();
        DialogResult result = openFileDialog1.ShowDialog(); // Show the dialog.          
        if (result == DialogResult.OK) // Test result.
        {
            string file = openFileDialog1.FileName;
            using (Stream stream = File.OpenRead(file))
            {
                byte[] buffer = new byte[stream.Length];
                stream.Read(buffer, 0, buffer.Length);
                string extn = new FileInfo(file).Extension;
                string cmd = "INSERT INTO Employee(Id,FirstName,LastName,Email,Password,PdfFile,FileExtn) VALUES (@Id,@FirstName,@LastName,@Email,@Password,@PdfFile,@FileExtn)";
   
                List<SqlParameter> l = new List<SqlParameter>();
   
                l.Add(new SqlParameter("@Id", "102"));
                l.Add(new SqlParameter("@FirstName", "Aviv"));
                l.Add(new SqlParameter("@LastName", "Halevy"));
                l.Add(new SqlParameter("@Email", "Assadsa@gmail.com"));
                l.Add(new SqlParameter("@Password", "123456"));
                l.Add(new SqlParameter("@PdfFile", buffer));
                l.Add(new SqlParameter("@FileExtn", extn));
                if (DAL.Database.ParametersCommand(cmd, l) > 0)
                    textBox1.Text = "SUCCESS! Save with Stream";
            }
        }
    }
   

从流中写入文件：

   private void button2_Click(object sender, EventArgs e)
    {
        string cmd = "SELECT * FROM Employee WHERE ID = '102'";
        string path = "YOUR_PATH\\Test";
        DataTable dt = DAL.Database.GetDataTable(cmd);
        if (dt != null && dt.Rows.Count > 0)
        {
            Byte[] file = (Byte[])dt.Rows[0]["PdfFile"];
            string extn = dt.Rows[0]["FileExtn"].ToString();
            path = Path.Combine(path, "Test123"+extn);

            File.WriteAllBytes(path, file);
            Process.Start(path);
        }
    }

结果：

注意： 在我的示例中，DAL 项目有一个运行我的 sql 命令的静态方法。