using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.IO;

namespace BLL
{
    public class ClsFile
    {
        private string _server = string.Empty;
        private string _database = string.Empty;
        private string _uid = string.Empty;
        private string _pwd = string.Empty;
        private string _sqlConnection = string.Empty;

        public ClsFile(string server, string database, string uid, string pwd)
        {
            _server = server;
            _database = database;
            _uid = uid;
            _pwd = pwd;
            _sqlConnection = "server=" + _server + ";database=" + _database + ";uid=" + _uid + ";pwd=" + _pwd;
        }

        //插入图片（table 表名、fieldName 存储文件字段名、sPath 文件完整路径）【程序上传使用，存入HX_UPDATE】
        /// <summary>
        /// 
        /// </summary>
        /// <param name="table">表名</param>
        /// <param name="fieldName">存储文件字段名</param>
        /// <param name="sName">文件名</param>
        /// <param name="sNo">版本号</param>
        /// <param name="sSize">文件大小</param>
        /// <param name="sPath">文件完整路径</param>
        /// <param name="sErr"></param>
        /// <returns></returns>
        public bool Insert_File(string table, string fieldName, string sName, long sNo, long sSize, string sPath, ref string sErr)
        {
            try
            {
                SqlConnection con = new SqlConnection(_sqlConnection);
                con.Open();
                byte[] FileList = this.FileToByteArray(sPath);
                string commandText = @"  INSERT INTO " + table + "(" + fieldName + ") " +
                "VALUES ('" + sName + "'," + sNo.ToString() + ",@FileList," + sSize.ToString() + ")";
                SqlCommand comm = new SqlCommand(commandText, con);
                comm.Parameters.AddWithValue("@FileList", FileList);
                comm.ExecuteNonQuery();
                con.Close();
            }
            catch (Exception e)
            {
                sErr = e.Message;
                return false;
            }
            return true;
        }

        //插入图片（table 表名、fieldName 存储文件字段名、sPath 文件完整路径）
        public bool Insert_File(string table, string fieldName,long HInterID,int HEntryID,string sPath, ref string sErr)
        {
            try
            {
                SqlConnection con = new SqlConnection(_sqlConnection);
                con.Open();
                byte[] FileList = this.FileToByteArray(sPath);
                string commandText = @"  INSERT INTO " + table + "(" + fieldName + ") " +
                "VALUES (" + HInterID.ToString() + "," + HEntryID.ToString() + ",@FileList,'" + sPath + "')";
                SqlCommand comm = new SqlCommand(commandText, con);
                comm.Parameters.AddWithValue("@FileList", FileList);
                comm.ExecuteNonQuery();
                con.Close();
            }
            catch(Exception e) 
            {
                sErr = e.Message;
                return false; 
            }
            return true;
        }

        //把文件转换成byte[]
        public byte[] FileToByteArray(String FilePath)
        {
            FileStream stream = new FileInfo(FilePath).OpenRead();
            byte[] buffer = new byte[stream.Length];
            stream.Read(buffer, 0, Convert.ToInt32(stream.Length));
            return buffer;
        }

        //读取 fieldName 该字段中符合条件的所有文件（sql SQL查询语句、fieldName 存储图片字段名）
        public void Get_File(string sql, string fieldName,string FileName)
        {
            List<Image> InformatoinCollection = new List<Image>();
            SqlConnection cn = new SqlConnection(_sqlConnection);
            cn.Open();
            SqlCommand cm = new SqlCommand(sql, cn);
            SqlDataReader dr = cm.ExecuteReader();
            byte[] oFile = null;
            if (dr.Read())
            {
                oFile = (byte[])dr[fieldName];
            }
            FileStream fs;
            FileInfo fi = new FileInfo(FileName);
            fs = fi.OpenWrite();
            fs.Write(oFile, 0, oFile.Length);
            fs.Close();
            dr.Close();
            cn.Close();
        }
    }

}