多媒體檔案上傳(一)
阿新 • • 發佈：2018-11-15
一個多媒體圖片上傳的功能(winform),web同理，本例子實現儲存路徑至資料庫
實現思路，使用者上傳本地多媒體資料至服務端，服務端接收使用者傳遞的資料，在伺服器上建立一個儲存資料夾，儲存使用者多媒體資料，資料庫儲存資料在伺服器上的絕對路徑
一、先在伺服器上建立一個檔案上傳後儲存的路徑資料夾，然後在程式碼config裡配置一下
<!--檔案上傳儲存路徑-->
<add key="saveFileFolder" value="D:\多媒體資料\" />
二、獲取照片的一些資訊(FileUploadDTO)
using System;namespace Media { public class FileUploadDTO { /// <summary> /// 檔名 /// </summary> public string name;/// <summary> /// 檔案大小 /// </summary> public int size;/// <summary> /// 副檔名 例：".txt" /// </summary> publicstring ext;
/// <summary>
/// 檔案路徑
/// </summary>
public string SAVEPATH;//傳遞的位元組數 public byte[] Data; } }
三、存入資料庫的資訊(FileImageDTO)
using System; using System.Collections.Generic;using System.Linq; using System.Text; using System.Threading.Tasks; namespace Media { public class FileImageDTO { /// <summary> /// 檔名 /// </summary> public string name { get; set; } /// <summary> /// 伺服器上檔名 /// </summary> public string FILENAME { get; set; } /// <summary> /// 描述名 /// </summary> public string FILEDESC { get; set; } /// <summary> /// 檔案主鍵 /// </summary> public string GUID { get; set; } /// <summary> /// 副檔名 /// </summary> public string FILEEXTNAME { get; set; } /// <summary> /// 建立時間 /// </summary> public System.DateTime CREATEDDATE { get; set; } /// <summary> /// 檔案儲存路徑 /// </summary> public string SAVEPATH { get; set; } } }
四、多媒體上傳幫助類(Mediaupload)
using System; using System.Collections.Generic; using System.Data; using System.IO; using System.Linq; using System.Runtime.Remoting.Messaging; using System.Text; using System.Threading.Tasks; namespace Media { public class Mediaupload { public void segmentReadUpload(FileUploadDTO file) { string filePath = System.Configuration.ConfigurationManager.AppSettings["saveFileFolder"];//指定檔案上傳位置 FileImageDTO dto = new FileImageDTO(); if (file.Offset == 0)//第一次傳入檔案 { DateTime dateTime = DateTime.Now; dto.name = file.name;//檔名 filePath = Path.Combine(filePath, "uploadFiles", dateTime.ToString("yyyy-MM-dd"));//上傳後文件在伺服器上存放檔案資料夾的路徑 checkDIR(filePath); dto.FILENAME = Guid.NewGuid().ToString() + file.ext;//上傳至伺服器後文件的名稱 filePath = Path.Combine(filePath, dto.FILENAME); dto.CREATEDDATE = dateTime;//上傳時間 dto.GUID = Guid.NewGuid().ToString();//檔案唯一識別 dto.FILEEXTNAME = file.ext;//副檔名 dto.SAVEPATH = filePath;//上傳後文件在伺服器上的路徑 } FileStream fs = new FileStream(filePath, FileMode.OpenOrCreate);//開啟檔案 long offset = file.Offset; //file.Offset 檔案偏移位置,表示從這個位置開始進行後面的資料新增 BinaryWriter writer = new BinaryWriter(fs);//初始化檔案寫入器 writer.Seek((int)offset, SeekOrigin.Begin);//設定檔案的寫入位置 writer.Write(file.Data);//寫入資料 file.Offset = fs.Length;//返回追加資料後的檔案位置 file.Data = null; Upload(dto);//資訊寫入資料庫 writer.Close(); fs.Close(); } //檢查目錄，如果不存在則建立 private void checkDIR(string path) { if (!Directory.Exists(path)) Directory.CreateDirectory(path); } public void Upload(FileImageDTO DTO) { // StringBuilder sql = new StringBuilder(); string sql = string.Format("INSERT INTO FILEIMAGE(NAME,FILENAME,FILEDESC,GUID,FILEEXTNAME,SAVEPATH,CREATEDDATE) VALUES('{0}','{1}','{2}','{3}','{4}','{5}',to_date('{6}','yyyy-mm-dd hh24:MI:SS'))",DTO.name,DTO.FILENAME,DTO.FILEDESC,DTO.GUID,DTO.FILEEXTNAME,DTO.SAVEPATH,DTO.CREATEDDATE); SqlHelper.ExecuteNonQuery(sql, CommandType.Text, null);//增加 } } }
五、點選上傳操作
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Drawing.Imaging; using System.IO; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; namespace Media { public partial class Form1 : Form { public Form1() { InitializeComponent(); } private void button1_Click(object sender, EventArgs e) { FileUploadDTO dt = new FileUploadDTO(); OpenFileDialog f1 = new OpenFileDialog(); f1.Title = "檔案上傳"; f1.Filter = "All Files|*.*|課件(*.ppt)|*.ppt|教學大綱和授課計劃(*.doc)|*.doc"; if (f1.ShowDialog() == DialogResult.OK) { FileInfo fileInfo = new FileInfo(f1.FileName); dt.name = fileInfo.Name;//檔名稱 dt.ext = fileInfo.Extension;//副檔名 dt.size = (int)fileInfo.Length;//檔案大小 Image image = Image.FromFile(fileInfo.FullName); // Bitmap bitmap = new Bitmap(f1.FileName); dt.Data = ImageToBytes(image); Mediaupload _fi = new Mediaupload(); _fi.segmentReadUpload(dt); } } /// <summary> /// 將照片轉為byte[] /// </summary> /// <param name="image"></param> /// <returns></returns> public static byte[] ImageToBytes(Image image) { ImageFormat format = image.RawFormat; using (MemoryStream ms = new MemoryStream()) { image.Save(ms, format); return ms.ToArray(); } } } }
六、oracle資料庫幫助類
using System; using System.Collections.Generic; using System.Data; using System.Data.OracleClient; using System.Linq; using System.Reflection; using System.Text; using System.Threading.Tasks; namespace Media { public class SqlHelper { #region 樣本 //標準連線 private static readonly string defaultConnectString = "Data Source=******;User Id=*****;Password=****;"; //標準連結 #endregion #region 變數 private static OracleConnection _con = null; public static string _constr = "Data Source=******;User Id=*****;Password=****;"; #endregion #region 屬性 public static string constr { get { if (_constr == null || _constr.Equals(String.Empty)) { _constr = defaultConnectString; } return _constr; } set { _constr = value; } } /// <summary> /// 獲取或設定資料庫連線物件 /// </summary> public static OracleConnection Con { get { if (SqlHelper._con == null) { SqlHelper._con = new OracleConnection(); } if (SqlHelper._con.ConnectionString == null || SqlHelper._con.ConnectionString.Equals(string.Empty)) { SqlHelper._con.ConnectionString = SqlHelper.constr; } return SqlHelper._con; } set { SqlHelper._con = value; } } #endregion #region 方法 /// <summary> /// 執行並返回第一行第一列的資料庫操作 /// </summary> /// <param name="commandText">Sql語句或儲存過程名</param> /// <param name="commandType">Sql命令型別</param> /// <param name="param">Oracle命令引數陣列</param> /// <returns>第一行第一列的記錄</returns> public static int ExecuteScalar(string commandText, CommandType commandType, params OracleParameter[] param) { int result = 0; try { using (OracleCommand cmd = new OracleCommand(commandText, SqlHelper.Con)) { try { cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } SqlHelper.Con.Open(); string x = cmd.CommandText; result = Convert.ToInt32(cmd.ExecuteScalar()); } catch { result = -1; } } } finally { if (SqlHelper.Con.State != ConnectionState.Closed) { SqlHelper.Con.Close(); } } return result; } /// <summary> /// 執行不查詢的資料庫操作 /// </summary> /// <param name="commandText">Oracle語句或儲存過程名</param> /// <param name="commandType">Oracle命令型別</param> /// <param name="param">Oracle命令引數陣列</param> /// <returns>受影響的行數</returns> public static int ExecuteNonQuery(string commandText, CommandType commandType, params OracleParameter[] param) { int result = 0; try { using (OracleCommand cmd = new OracleCommand(commandText, SqlHelper.Con)) { try { //cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } SqlHelper.Con.Open(); result = cmd.ExecuteNonQuery(); } catch (Exception ex) { result = -1; } } } finally { if (SqlHelper.Con.State != ConnectionState.Closed) { SqlHelper.Con.Close(); } } return result; } /// <summary> /// 獲取資料表 /// </summary> /// <param name="commandText">select命令</param> /// <param name="param">引數表</param> /// <returns></returns> public static DataTable GetDataTable(string commandText, params OracleParameter[] param) { DataTable result = new DataTable(); try { using (OracleCommand cmd = new OracleCommand(commandText, SqlHelper.Con)) { if (param != null) cmd.Parameters.AddRange(param); try { OracleDataAdapter adapter = new OracleDataAdapter(cmd); adapter.Fill(result); } catch (Exception ex) { result = null; } } } finally { if (SqlHelper.Con.State != ConnectionState.Closed) { SqlHelper.Con.Close(); } } return result; } public static int GetNextValueInSequence(string sequenceName) { if (ExecuteScalar("select count(*) from user_objects where OBJECT_NAME=:seqName", CommandType.Text, new OracleParameter(":seqName", sequenceName)) > 0) { return ExecuteScalar("select " + sequenceName + ".nextval from dual", CommandType.Text); } else { return -1; } } /// <summary> /// 事務模式執行多行非查詢語句 /// </summary> /// <param name="commandText">sql語句</param> /// <param name="param">引數</param> /// <returns>受影響行數</returns> public static int ExecuteNonQueryTransaction(string commandText, List<OracleParameter[]> param) { int result = 0; try { using (OracleCommand cmd = new OracleCommand(commandText, SqlHelper.Con)) { SqlHelper.Con.Open(); cmd.Transaction = cmd.Connection.BeginTransaction(); try { foreach (OracleParameter[] par in param) { cmd.Parameters.Clear(); cmd.Parameters.AddRange(par); result += cmd.ExecuteNonQuery(); } cmd.Transaction.Commit(); } catch { result = -1; try { cmd.Transaction.Rollback(); } catch { result = -2; } } } } finally { if (SqlHelper.Con.State != ConnectionState.Closed) { SqlHelper.Con.Close(); } } return result; } /// <summary> /// 執行返回一條記錄的泛型物件 /// </summary> /// <typeparam name="T">泛型型別</typeparam> /// <param name="reader">只進只讀物件</param> /// <returns>泛型物件</returns> private static T ExecuteDataReader<T>(IDataReader reader) { T obj = default(T); try { Type type = typeof(T); obj = (T)Activator.CreateInstance(type);//從當前程式集裡面通過反射的方式建立指定型別的物件 //obj = (T)Assembly.Load(SqlHelper._assemblyName).CreateInstance(SqlHelper._assemblyName + "." + type.Name);//從另一個程式集裡面通過反射的方式建立指定型別的物件 PropertyInfo[] propertyInfos = type.GetProperties();//獲取指定型別裡面的所有屬性 foreach (PropertyInfo propertyInfo in propertyInfos) { for (int i = 0; i < reader.FieldCount; i++) { string fieldName = reader.GetName(i); if (fieldName.ToLower() == propertyInfo.Name.ToLower()) { object val = reader[propertyInfo.Name];//讀取表中某一條記錄裡面的某一列 if (val != null && val != DBNull.Value) { Type valType = val.GetType(); if (valType == typeof(float) || valType == typeof(double) || valType == typeof(decimal)) { propertyInfo.SetValue(obj, Convert.ToDouble(val), null); } else if (valType == typeof(int)) { propertyInfo.SetValue(obj, Convert.ToInt32(val), null); } else if (valType == typeof(DateTime)) { propertyInfo.SetValue(obj, Convert.ToDateTime(val), null); } else if (valType == typeof(string)) { propertyInfo.SetValue(obj, Convert.ToString(val), null); } } break; } } } } catch { throw; } return obj; } /// <summary> /// 執行返回一條記錄的泛型物件 /// </summary> /// <typeparam name="T">泛型型別</typeparam> /// <param name="commandText">Oracle語句或儲存過程名</param> /// <param name="commandType">Oracle命令型別</param> /// <param name="param">Oracle命令引數陣列</param> /// <returns>實體物件</returns> public static T ExecuteEntity<T>(string commandText, CommandType commandType, params OracleParameter[] param) { T obj = default(T); try { using (OracleCommand cmd = new OracleCommand(commandText, SqlHelper.Con)) { cmd.CommandType = commandType; cmd.Parameters.AddRange(param); SqlHelper.Con.Open(); OracleDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); while (reader.Read()) { obj = SqlHelper.ExecuteDataReader<T>(reader); } } } finally { if (SqlHelper.Con.State != ConnectionState.Closed) { SqlHelper.Con.Close(); } } return obj; } /// <summary> /// 執行返回多條記錄的泛型集合物件 /// </summary> /// <typeparam name="T">泛型型別</typeparam> /// <param name="commandText">Oracle語句或儲存過程名</param> /// <param name="commandType">Oracle命令型別</param> /// <param name="param">Oracle命令引數陣列</param> /// <returns>泛型集合物件</returns> public static List<T> ExecuteList<T>(string commandText, CommandType commandType, params OracleParameter[] param) { List<T> list = new List<T>(); try { using (OracleCommand cmd = new OracleCommand(commandText, SqlHelper.Con)) { try { cmd.CommandType = commandType; if (param != null) { cmd.Parameters.AddRange(param); } SqlHelper.Con.Open(); OracleDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); while (reader.Read()) { T obj = SqlHelper.ExecuteDataReader<T>(reader); list.Add(obj); } } catch (Exception ex) { list = null; } } } finally { if (SqlHelper.Con.State != ConnectionState.Closed) { SqlHelper.Con.Close(); } } return list; } #endregion } }
create table FILEIMAGE ( name VARCHAR2(60), filename VARCHAR2(60), filedesc VARCHAR2(200), guid VARCHAR2(50) not null, fileextname VARCHAR2(10), savepath VARCHAR2(100), createddate DATE )
web 實現思路，其他不用更改，只需要在傳參哪裡改為web實現獲取這4個(檔名，副檔名，檔案大小，檔案轉成byte[])資料傳到後臺即可