C# 中實現(xiàn)ftp 圖片上傳功能(多快好省)
更新時間：2017年06月17日 16:15:46 作者：瀟十一郎
這篇文章主要介紹了C# 中實現(xiàn)ftp 圖片上傳功能(多快好省),需要的朋友可以參考下
前言
此篇講到的是圖片上傳功能，每個網(wǎng)站必定會有這樣類似的功能，上傳文件、上傳圖片等等。那么接下來，看看我們EF+uploadfile+ftp如何玩轉(zhuǎn)上傳圖片吧
效果預(yù)覽
具體實現(xiàn)
一個簡單數(shù)據(jù)庫 只有一個主鍵Id，一個身份證正面路徑和一個身份證背面路徑三個字段。
首先呢，我們把實體類新建好如下：
public class ImageModel:BaseEntity
{
/// <summary>
/// 用戶Id
/// </summary>
public int ID { get; set; }
/// <summary>
///身份證正面相對路徑
/// </summary>
public string IDProofFront { get; set; }
/// <summary>
///身份證背面相對路徑
/// </summary>
public string IDProofBack { get; set; }
}
其中 我們將身份信息實體繼承自BaseEntity,我們看看BaseEntity里面是什么東東，代碼如下：
public abstract partial class BaseEntity
{
public override bool Equals(object obj)
{
return Equals(obj as BaseEntity);
}
private Type GetUnproxiedType()
{
return GetType();
}
public virtual bool Equals(BaseEntity other)
{
if (other == null)
return false;
if (ReferenceEquals(this, other))
return true;
return false;
}
public override int GetHashCode()
{
return base.GetHashCode();
}
public static bool operator ==(BaseEntity x, BaseEntity y)
{
return Equals(x, y);
}
public static bool operator !=(BaseEntity x, BaseEntity y)
{
return !(x == y);
}
}
這里，我們將BaseEntity定義成一個抽象類，里面包含一些靜態(tài)方法和重載方法
======================回到HTML=======
我們先回過頭來講頁面，上面演示的是一個很簡單的單頁面，HTML代碼如下：
<form enctype="multipart/form-data" id="form" action="/Home/UpLoadImage" method="post">
<div class="full_w" style="margin-top: 100px; margin-left: 30%; width: 800px;">
<div class="h_title"> <b>用戶上傳的文件</b></div>
<div class="entry">
步驟： <span class="red" style="color: red">(上傳資料必須是bmp,gif,jpg,jpeg,png類型,不能大于2M)</span>
<ol>
<li>先按『選擇』鍵選擇上傳文件；</li>
<li>按『上傳』鍵上傳文件；</li>
<li>按『保存』鍵保存文件；</li>
</ol>
</div>
<div class="entry">
<div class="sep"></div>
</div>
<div class="entry">
<div id="wrapper" style="text-align: center; position: relative;">
<div class="form-group">
<input id="uploadfile" type="file" value="瀏覽..." class="file" name="FileName" data-upload-url="#" style="position: absolute; top: 0; right: 0; min-width: 100%; min-height: 100%; text-align: right; opacity: 0; background: none repeat scroll 0 0 transparent; cursor: inherit; display: block;" />
</div>
</div>
</div>
<table>
<tbody>
<tr>
<td class="entry">身份證正面</td>
<td>
@if (Model == null || Model.ID == null || string.IsNullOrEmpty(Model.IDProofFront))
{
<a href="javascript:void(0);" rel="external nofollow" rel="external nofollow" target="_blank" class="winView">
<img style="border: none; width: 150px; height: 100px" src="/img/noupload.png" />
</a>
}
else
{
<a href="@(ViewBag.pathSrc + Model.IDProofFront)" rel="external nofollow" target="_blank"class="winView" >
<img style="border: none; width: 150px; height: 100px" src="@(ViewBag.pathSrc + Model.IDProofFront)" />
</a>
}
@Html.HiddenFor(m => m.IDProofFront)
@Html.HiddenFor(m => m.ID)
</td>
<td>
<a href="javascript:void(0)" rel="external nofollow" rel="external nofollow" class="easyui-linkbutton btnFinleUP" data-op="1" data-type="image">上傳</a>
</td>
</tr>
<tr>
<td class="entry">身份證背面</td>
<span id="lblinfosi" style="color: Green"></span>
<td>
@if (Model == null || Model.ID == null || string.IsNullOrEmpty(Model.IDProofBack))
{
<a href="javascript:void(0);" rel="external nofollow" rel="external nofollow" target="_blank" class="winView">
<img style="border: none; width: 150px; height: 100px" src="/img/noupload.png" />
</a>
}
else
{
<a href="@(ViewBag.pathSrc + Model.IDProofBack)" rel="external nofollow" target="_blank" class="winView" >
<img style="border: none; width: 150px; height: 100px" src="@(ViewBag.pathSrc + Model.IDProofBack)" />
</a>
}
@Html.HiddenFor(m => m.IDProofBack)
</td>
<td>
<a href="javascript:void(0)" rel="external nofollow" rel="external nofollow" class="easyui-linkbutton btnFinleUP" data-op="2" data-type="image">上傳</a>
</td>
</tr>
</tbody>
</table>
<div class="entry">
<button class="button" name="btnSaveAll" value="保存" id="btnSaveAll" style="height: 30px; width: 80px; text-align: center;">保存</button>
<a href="/Home/Index" rel="external nofollow" style="height: 30px; text-align: center; width: 80px; background: #ffffff; border: 1px solid #DCDCDC; border-radius: 2px; color: #444444; cursor: pointer; display: inline-block; font: 700 11px Tahoma, Arial, sans-serif; margin-right: 10px; padding: 7px 12px 7px 12px; position: relative; text-decoration: none; text-shadow: 0px 1px 0px #FFFFFF;">返回</a>
</div>
</div>
</form>
現(xiàn)在我們看頁面將會毫無樣式，所以我們先引用下樣式，這里引用了bootstrap 和一個 style2.css ，引入樣式后 界面如下：
其中，關(guān)于選擇框是用了一個js單獨封裝起來了，是代碼中的zh.js，代碼如下：
/*!
* FileInput Chinese Translations
*
* This file must be loaded after 'fileinput.js'. Patterns in braces '{}', or
* any HTML markup tags in the messages must not be converted or translated.
*
* @see http://github.com/kartik-v/bootstrap-fileinput
* @author kangqf <kangqingfei@gmail.com>
*
* NOTE: this file must be saved in UTF-8 encoding.
*/
(function ($) {
"use strict";
$.fn.fileinputLocales['zh'] = {
fileSingle: '文件',
filePlural: '個文件',
browseLabel: '選擇 …',
removeLabel: '移除',
removeTitle: '清除選中文件',
cancelLabel: '取消',
cancelTitle: '取消進行中的上傳',
uploadLabel: '上傳',
uploadTitle: '上傳選中文件',
msgNo: '沒有',
msgNoFilesSelected: '',
msgCancelled: '取消',
msgZoomModalHeading: '詳細預(yù)覽',
msgSizeTooSmall: 'File "{name}" (<b>{size} KB</b>) is too small and must be larger than <b>{minSize} KB</b>.',
msgSizeTooLarge: '文件 "{name}" (<b>{size} KB</b>) 超過了允許大小 <b>{maxSize} KB</b>.',
msgFilesTooLess: '你必須選擇最少 <b>{n}</b> {files} 來上傳. ',
msgFilesTooMany: '選擇的上傳文件個數(shù) <b>({n})</b> 超出最大文件的限制個數(shù) <b>{m}</b>.',
msgFileNotFound: '文件 "{name}" 未找到!',
msgFileSecured: '安全限制，為了防止讀取文件 "{name}".',
msgFileNotReadable: '文件 "{name}" 不可讀.',
msgFilePreviewAborted: '取消 "{name}" 的預(yù)覽.',
msgFilePreviewError: '讀取 "{name}" 時出現(xiàn)了一個錯誤.',
msgInvalidFileName: 'Invalid or unsupported characters in file name "{name}".',
msgInvalidFileType: '不正確的類型 "{name}". 只支持 "{types}" 類型的文件.',
msgInvalidFileExtension: '不正確的文件擴展名 "{name}". 只支持 "{extensions}" 的文件擴展名.',
msgFileTypes: {
'image': 'image',
'html': 'HTML',
'text': 'text',
'video': 'video',
'audio': 'audio',
'flash': 'flash',
'pdf': 'PDF',
'object': 'object'
},
msgUploadAborted: '該文件上傳被中止',
msgUploadThreshold: 'Processing...',
msgUploadEmpty: 'No valid data available for upload.',
msgValidationError: '驗證錯誤',
msgLoading: '加載第 {index} 文件 共 {files} …',
msgProgress: '加載第 {index} 文件 共 {files} - {name} - {percent}% 完成.',
msgSelected: '{n} {files} 選中',
msgFoldersNotAllowed: '只支持拖拽文件! 跳過 {n} 拖拽的文件夾.',
msgImageWidthSmall: '寬度的圖像文件的"{name}"的必須是至少{size}像素.',
msgImageHeightSmall: '圖像文件的"{name}"的高度必須至少為{size}像素.',
msgImageWidthLarge: '寬度的圖像文件"{name}"不能超過{size}像素.',
msgImageHeightLarge: '圖像文件"{name}"的高度不能超過{size}像素.',
msgImageResizeError: '無法獲取的圖像尺寸調(diào)整。',
msgImageResizeException: '錯誤而調(diào)整圖像大小。<pre>{errors}</pre>',
msgAjaxError: 'Something went wrong with the {operation} operation. Please try again later!',
msgAjaxProgressError: '{operation} failed',
ajaxOperations: {
deleteThumb: 'file delete',
uploadThumb: 'single file upload',
uploadBatch: 'batch file upload',
uploadExtra: 'form data upload'
},
dropZoneTitle: '拖拽文件到這里 …<br>支持多文件同時上傳',
dropZoneClickTitle: '<br>(或點擊{files}按鈕選擇文件)',
fileActionSettings: {
removeTitle: '刪除文件',
uploadTitle: '上傳文件',
zoomTitle: '查看詳情',
dragTitle: '移動 / 重置',
indicatorNewTitle: '沒有上傳',
indicatorSuccessTitle: '上傳',
indicatorErrorTitle: '上傳錯誤',
indicatorLoadingTitle: '上傳 ...'
},
previewZoomButtonTitles: {
prev: '預(yù)覽上一個文件',
next: '預(yù)覽下一個文件',
toggleheader: '縮放',
fullscreen: '全屏',
borderless: '無邊界模式',
close: '關(guān)閉當前預(yù)覽'
}
};
})(window.jQuery);
好了，界面大概就整成這樣子，現(xiàn)在需要我們實現(xiàn)功能了。首先用JS將上傳控件初始化一下：
//上傳控件初始化
function initFileUpload() {
$("#uploadfile").fileinput({
//uploadExtraData: { kvId: '10' },
language: 'zh', //設(shè)置語言
showUpload: false, //是否顯示上傳按鈕
uploadAsync: true, //默認異步上傳
showRemove: false,
autoReplace: true,
maxFileCount: 1,
maxFileSize: 10240,
dropZoneTitle: '拖拽文件到這里 …<br>僅限.pdf, .jpg, .jpeg, .gif',
enctype: 'multipart/form-data',
fileActionSettings: { uploadClass: "hidden", zoomClass: "hidden", removeClass: "hidden" },
allowedFileExtensions: ['jpg', 'png', 'gif', 'pdf'],//接收的文件后綴
msgFilesTooMany: "選擇上傳的文件數(shù)量({n}) 超過允許的最大數(shù)值{m}！",
uploadUrl: "/FileUpload/FileUpLoad", //上傳的地址
}).on("filebatchselected", function (event, files) {
$(".file-preview-success").remove();
})
$("#uploadfile").on("fileuploaded", function (event, data, previewId, index) {
console.log("accountData 初始化后 FileOpt" + accountData);
console.log("accountData.FileOpt " + accountData.FileOpt);
var obj = data.response;
if (obj.Status != 500 && obj.Data != undefined) {
var src = accountData.PathSrc + obj.Data.FileName;
showName = obj.Data.FileName;
//alert(showName);
var pId = accountData.PId;
var fileObj = undefined;
var field = "";
var isPdf = false;
debugger;
if (accountData.FileOpt == 1) {
fileObj = $("#IDProofFront");
//$("#PersonInfo_OldIDFile").val(obj.Data.FileName);
field = "IDProofFront";
fileObj.val(obj.Data.FileName);
} else if (accountData.FileOpt == 2) {
fileObj = $("#IDProofBack");
field = "IDProofBack";
$("#IDProofBack").val(showName);
fileObj.val(obj.Data.FileName);
}
//fileObj = $("#IDProofFront");
//$("#IDProofFront").val(obj.Data.FileName);
//field = "IDProofFront";
//fileObj.val(obj.Data.FileName);
fileObj.prev().attr("href", src);
src = isPdf == true ? "/Content/images/PDF.png" : src;
fileObj.prev().find("img").attr("src", src);
} else {
console.error(obj.Data);
}
});
$('#uploadfile').on('filesuccessremove', function (event, id) {
});
$('#uploadfile').on('fileerror', function (event, data, msg) {
});
//上傳
$(".btnFinleUP").click(function () {
var fileName = $("#uploadfile").val();
var obj = document.getElementById("uploadfile");
var type = $(this).attr("data-op");
//alert("當前點擊的type是：" + type);
var fileType = $(this).attr("data-type");
var files = $("#uploadfile").fileinput("getFileStack");
if (files.length == 0) {
layer.msg('請選擇要上傳的文件', function () { });
return;
}
var array = fileType.split(",");
var selectType = files[0].type.toLowerCase();
var falg = false;
for (var i = 0; i < array.length; i++) {
if (selectType.indexOf(array[i]) == -1) {
falg = false;
} else
falg = true;
if (falg)
break;
}
if (!falg) {
layer.msg('只能選擇' + fileType + ' 類型的文件', function () { });
return;
}
accountData.FileOpt = type;
$("#uploadfile").fileinput("upload");
});
}
然后再 加載頁面的時候調(diào)用這個初始化即可
$(function () {
initFileUpload();
})
FTP上傳操作
注意，再initFileUpload方法中 上傳了圖片，會自動訪問uploadUrl 這個url地址，存放圖片，我們先看看這個action如何通過ftp上傳指定服務(wù)器的。
FileUpLoad方法如下
/// <summary>
/// 通過ftp上傳指定服務(wù)器
/// </summary>
/// <returns></returns>
public ActionResult FileUpLoad()
{
bool flag = false;
string msg = string.Empty;
int size = Convert.ToInt16(_fileSize) * 1024 * 1024;
try
{
Dictionary<string, string> fileDict = new Dictionary<string, string>();
for (int i = 0; i < Request.Files.Count; i++)
{
HttpPostedFileBase file = Request.Files[i];
string extension = Path.GetExtension(file.FileName);
string[] fileExtensions = _fileExtension.Split(';');
if (fileExtensions.Any(o => o.Equals(extension, StringComparison.OrdinalIgnoreCase)))
{
if (file.ContentLength <= size)
{
string fileName = string.Format("{0}_{1}", DateTime.Now.ToString("yyyyMMddHHmmssfff"), Path.GetFileName(file.FileName));
if (file.ContentLength <= 10 * 1024 * 1024)
{
byte[] buffer = new byte[file.ContentLength];
file.InputStream.Read(buffer, 0, file.ContentLength);
flag = FileUpLoad(buffer, file.FileName, out fileName, out msg);
}
else//圖片壓縮有問題>>
{
var stream = ImageHelper.GetPicThumbnail(file.InputStream, 40);
byte[] buffer = new byte[stream.Length];
stream.Read(buffer, 0, (int)stream.Length);
flag = FileUpLoad(buffer, file.FileName, out fileName, out msg);
}
fileDict.Add(Request.Files.AllKeys[i], fileName);
}
else
{
msg = string.Format("上傳文件不能大于{0}M", _fileSize);
}
}
else
{
msg = string.Format("上傳的文件類型不正確");
}
}
return Json(new { Result = "0", MSG = "" + msg, Data = fileDict });
}
catch (Exception ex)
{
return Json(new { Result = "0", MSG = "網(wǎng)絡(luò)異常，請稍后再試" });
}
}
其中 _fileExtension _filePath _fileSize 是分別從配置文件中讀取出來的如下：
private static string _fileExtension = ConfigurationManager.AppSettings["FileType"]; private readonly string _filePath = ConfigurationManager.AppSettings["UploadPath"]; private readonly string _fileSize = ConfigurationManager.AppSettings["FileSizem"];
方法中有一個 FileUpLoad 上傳文件的方法 如下：
/// <summary>
/// 上傳文件
/// </summary>
/// <param name="fileBytes"></param>
/// <param name="originalName"></param>
/// <param name="msg"></param>
/// <returns></returns>
protected bool FileUpLoad(byte[] fileBytes, string originalName, out string newFileName, out string msg)
{
msg = "";
newFileName = "";
try
{
FTPUpFile ftp = new FTPUpFile();
newFileName = ftp.UpFile(fileBytes, originalName);
if (string.IsNullOrEmpty(newFileName))
{
msg = "上傳文件時出錯！";
return false;
}
return true;
}
catch (Exception ex)
{
msg = ex.Message;
return false;
}
}
其中
FTPUpFile 是一個ftp上傳文件幫助類，大家可以直接照搬 ，代碼如下：
/// <summary>
/// FTP上傳文件
/// </summary>
public class FTPUpFile
{
string Filetype = ConfigurationManager.AppSettings["FileType"];
string ipaddress = ConfigurationManager.AppSettings["IPaddress"];
string Username = ConfigurationManager.AppSettings["UserName"];
string Password = ConfigurationManager.AppSettings["Password"];
/// <summary>
/// FTP上傳文件
/// </summary>
/// <param name="filename">上傳文件路徑</param>
/// <param name="ftpServerIP">FTP服務(wù)器的IP和端口</param>
/// <param name="ftpPath">FTP服務(wù)器下的哪個目錄</param>
/// <param name="ftpUserID">FTP用戶名</param>
/// <param name="ftpPassword">FTP密碼</param>
public bool Upload(string filename, string ftpServerIP, string ftpPath, string ftpUserID, string ftpPassword)
{
FileInfo fileInf = new FileInfo(filename);
string uri = "ftp://" + ftpServerIP + "/" + ftpPath + "/" + fileInf.Name;
try
{
FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
// ftp用戶名和密碼
reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
reqFTP.KeepAlive = false;
// 指定執(zhí)行什么命令
reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
// 指定數(shù)據(jù)傳輸類型
reqFTP.UseBinary = true;
// 上傳文件時通知服務(wù)器文件的大小
reqFTP.ContentLength = fileInf.Length;
//this.Invoke(InitUProgress, fileInf.Length);
// 緩沖大小設(shè)置為2kb
int buffLength = 4096;
byte[] buff = new byte[buffLength];
int contentLen;
// 打開一個文件流 (System.IO.FileStream) 去讀上傳的文件
FileStream fs = fileInf.OpenRead();
// 把上傳的文件寫入流
Stream strm = reqFTP.GetRequestStream();
contentLen = fs.Read(buff, 0, buffLength);
while (contentLen != 0)
{
strm.Write(buff, 0, contentLen);
contentLen = fs.Read(buff, 0, buffLength);
}
// 關(guān)閉兩個流
strm.Close();
strm.Dispose();
fs.Close();
fs.Dispose();
return true;
}
catch (Exception ex)
{
return false;
}
}
/// <summary>
/// 新建目錄
/// </summary>
/// <param name="ftpPath"></param>
/// <param name="dirName"></param>
public void MakeDir(string ftpPath, string dirName, string username, string password)
{
try
{
//實例化FTP連接
FtpWebRequest request = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpPath + dirName));
// ftp用戶名和密碼
request.Credentials = new NetworkCredential(username, password);
// 默認為true，連接不會被關(guān)閉
request.KeepAlive = false;
//指定FTP操作類型為創(chuàng)建目錄
request.Method = WebRequestMethods.Ftp.MakeDirectory;
//獲取FTP服務(wù)器的響應(yīng)
FtpWebResponse response = (FtpWebResponse)request.GetResponse();
response.Close();
}
catch (Exception ex)
{
//Respons
}
}
/// <summary>
/// 刪除指定文件
/// </summary>
/// <param name="ftpPath"></param>
/// <param name="dirName"></param>
/// <param name="username"></param>
/// <param name="password"></param>
public void DeleteFile(string ftpPath, string username, string password)
{
try
{
// string uri = "ftp://" + ftpServerIP + "/" + ftpPath + "/" + fileInf.Name;
//ftpPath = "ftp://192.168.1.111:2005/2012-12-05/20121206O5CATICE.docx";
//password = "111";
//username = "yuanluluoli";
//實例化FTP連接
FtpWebRequest request = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpPath));
request.Method = WebRequestMethods.Ftp.DeleteFile;
// ftp用戶名和密碼
request.Credentials = new NetworkCredential(username, password);
// 默認為true，連接不會被關(guān)閉
request.KeepAlive = false;
//獲取FTP服務(wù)器的響應(yīng)
FtpWebResponse response = (FtpWebResponse)request.GetResponse();
response.Close();
}
catch (Exception ex)
{
//Respons
}
}
/// <summary>
/// 檢查目錄是否存在
/// </summary>
/// <param name="ftpPath">要檢查的目錄的路徑</param>
/// <param name="dirName">要檢查的目錄名</param>
/// <returns>存在返回true，否則false</returns>
public bool CheckDirectoryExist(string ftpPath, string dirName, string username, string password)
{
bool result = false;
try
{
//實例化FTP連接
FtpWebRequest request = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpPath));
// ftp用戶名和密碼
request.Credentials = new NetworkCredential(username, password);
request.KeepAlive = false;
//指定FTP操作類型為創(chuàng)建目錄
request.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
//獲取FTP服務(wù)器的響應(yīng)
FtpWebResponse response = (FtpWebResponse)request.GetResponse();
StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.Default);
StringBuilder str = new StringBuilder();
string line = sr.ReadLine();
while (line != null)
{
str.Append(line);
str.Append("|");
line = sr.ReadLine();
}
string[] datas = str.ToString().Split('|');
for (int i = 0; i < datas.Length; i++)
{
if (datas[i].Contains("<DIR>"))
{
int index = datas[i].IndexOf("<DIR>");
string name = datas[i].Substring(index + 5).Trim();
if (name == dirName)
{
result = true;
break;
}
}
}
sr.Close();
sr.Dispose();
response.Close();
}
catch (Exception)
{
return false;
}
return result;
}
/// <summary>
/// 上傳文件
/// </summary>
/// <param name="buffer">文件的Byte數(shù)組</param>
/// <param name="originalName">文件原始名字(帶后綴名)</param>
/// <param name="perStr">新文件名的前綴</param>
/// <returns></returns>
public string UpFile(byte[] buffer, string originalName, string perStr = "")
{
if (buffer == null || buffer.Length <= 0 || string.IsNullOrEmpty(originalName))
throw new ArgumentException("參數(shù)錯誤！");
string filePathstr = string.Empty;
string filepathsql = null;
try
{
string pathstr = perStr + DateTime.Now.ToString().Replace("/", "").Replace("-", "").Replace(":", "").Replace(" ", "");
string rodumlist = GeneralHelper.GetMixPwd(10);//10位隨機數(shù)
filePathstr = "~/File/" + pathstr + rodumlist + Path.GetExtension(originalName);
//Stream sr = upfile.PostedFile.InputStream;
//byte[] file = new byte[sr.Length];
//sr.Read(file, 0, file.Length);
StreamWriter sw = new StreamWriter(HttpContext.Current.Server.MapPath(filePathstr));
sw.BaseStream.Write(buffer, 0, buffer.Length);
sw.Flush(); sw.Close();
// file.SaveAs(HttpContext.Current.Server.MapPath(filePathstr));//把文件上傳到服務(wù)器的絕對路徑上
bool check;
string ftpPath = DateTime.Now.ToString("yyyy-MM-dd");
string uri = @"ftp://" + ipaddress + "/";
//檢查是否存在此目錄文件夾
if (CheckDirectoryExist(uri, ftpPath, Username, Password))
{
//存在此文件夾就直接上傳
check = Upload(HttpContext.Current.Server.MapPath(filePathstr), ipaddress, ftpPath, Username, Password);
}
else
{
MakeDir(uri, ftpPath, Username, Password);//創(chuàng)建
check = Upload(HttpContext.Current.Server.MapPath(filePathstr), ipaddress, ftpPath, Username, Password);
}
//成功就更新
if (check)
{
filepathsql = ftpPath + "/" + pathstr + rodumlist + Path.GetExtension(originalName);
}
//檢查是否存在此文件
if (File.Exists(HttpContext.Current.Server.MapPath(filePathstr)))
{
File.Delete(HttpContext.Current.Server.MapPath(filePathstr));
}
return filepathsql;
}
catch (Exception ex)
{
File.Delete(HttpContext.Current.Server.MapPath(filePathstr));
throw ex;
}
}
/// <summary>
/// 上傳文件
/// 不修改名字及后綴名
/// </summary>
/// <param name="originalFilePath">上傳文件的絕對路徑</param>
/// <returns></returns>
public string UpFile(string originalFilePath)
{
if (string.IsNullOrEmpty(originalFilePath))
throw new ArgumentException("參數(shù)錯誤！");
string filepathsql = null;
try
{
//檢查是否存在此文件
if (!File.Exists(originalFilePath))
throw new Exception("文件不存在！");
//Stream sr = upfile.PostedFile.InputStream;
//byte[] file = new byte[sr.Length];
//sr.Read(file, 0, file.Length);
// file.SaveAs(HttpContext.Current.Server.MapPath(filePathstr));//把文件上傳到服務(wù)器的絕對路徑上
bool check;
string ftpPath = DateTime.Now.ToString("yyyy-MM-dd");
string uri = @"ftp://" + ipaddress + "/";
//檢查是否存在此目錄文件夾
if (CheckDirectoryExist(uri, ftpPath, Username, Password))
{
//存在此文件夾就直接上傳
check = Upload(originalFilePath, ipaddress, ftpPath, Username, Password);
}
else
{
MakeDir(uri, ftpPath, Username, Password);//創(chuàng)建
check = Upload(originalFilePath, ipaddress, ftpPath, Username, Password);
}
//成功就更新
if (check)
{
filepathsql = ftpPath + "/" + Path.GetFileName(originalFilePath);
}
//檢查是否存在此文件
if (File.Exists(originalFilePath))
{
File.Delete(originalFilePath);
}
return filepathsql;
}
catch (Exception ex)
{
//File.Delete(originalFilePath);
throw ex;
}
}
public string Ftp_Up(HtmlInputFile upfile)
{
//Encrypt En = new Encrypt();
string filePathstr = string.Empty;
string filepathsql = null;
try
{
string pathstr = DateTime.Now.ToString().Replace("/", "").Replace("-", "").Replace(":", "").Replace(" ", "");
string rodumlist = GeneralHelper.GetMixPwd(10);//10位隨機數(shù)
filePathstr = "~/File/" + pathstr + rodumlist + Path.GetExtension(upfile.PostedFile.FileName);
Stream sr = upfile.PostedFile.InputStream;
byte[] file = new byte[sr.Length];
sr.Read(file, 0, file.Length);
StreamWriter sw = new StreamWriter(HttpContext.Current.Server.MapPath(filePathstr));
sw.BaseStream.Write(file, 0, file.Length);
sw.Flush(); sw.Close(); sr.Flush(); sr.Close();
// file.SaveAs(HttpContext.Current.Server.MapPath(filePathstr));//把文件上傳到服務(wù)器的絕對路徑上
bool check;
string ftpPath = DateTime.Now.ToString("yyyy-MM-dd");
string uri = @"ftp://" + ipaddress + "/";
//檢查是否存在此目錄文件夾
if (CheckDirectoryExist(uri, ftpPath, Username, Password))
{
//存在此文件夾就直接上傳
check = Upload(HttpContext.Current.Server.MapPath(filePathstr), ipaddress, ftpPath, Username, Password);
}
else
{
MakeDir(uri, ftpPath, Username, Password);//創(chuàng)建
check = Upload(HttpContext.Current.Server.MapPath(filePathstr), ipaddress, ftpPath, Username, Password);
}
//成功就更新
if (check)
{
filepathsql = ftpPath + "/" + pathstr + rodumlist + Path.GetExtension(upfile.PostedFile.FileName);
}
//檢查是否存在此文件
if (File.Exists(HttpContext.Current.Server.MapPath(filePathstr)))
{
File.Delete(HttpContext.Current.Server.MapPath(filePathstr));
}
return filepathsql;
}
catch (Exception)
{
File.Delete(HttpContext.Current.Server.MapPath(filePathstr));
return filepathsql;
// Response.Write("<script>alert(" + ex.Message + ");</script>");
}
}
/// <summary>
/// 上傳
/// </summary>
/// <param name="file"></param>
/// <returns></returns>
public string Ftp_Up(HttpPostedFileBase postedFile)
{
string filePathstr = string.Empty;
string filepathsql = null;
try
{
string pathstr = DateTime.Now.ToString("yyyyMMddHHmmss");
string rodumlist = GeneralHelper.GetMixPwd(10);//10位隨機數(shù)
string filename = System.IO.Path.GetFileName(postedFile.FileName);
string eExtension = Path.GetExtension(filename);
string strLocation = HttpContext.Current.Server.MapPath("~/File/");
filePathstr = strLocation + pathstr + rodumlist + eExtension;
postedFile.SaveAs(filePathstr);
bool check;
string ftpPath = DateTime.Now.ToString("yyyy-MM-dd");
string uri = @"ftp://" + ipaddress + "/";
//檢查是否存在此目錄文件夾
if (CheckDirectoryExist(uri, ftpPath, Username, Password))
{
//存在此文件夾就直接上傳
check = Upload(filePathstr, ipaddress, ftpPath, Username, Password);
}
else
{
MakeDir(uri, ftpPath, Username, Password);//創(chuàng)建
check = Upload(filePathstr, ipaddress, ftpPath, Username, Password);
}
//成功就更新
if (check)
{
filepathsql = ftpPath + "/" + pathstr + rodumlist + eExtension;
}
//檢查是否存在此文件
if (File.Exists(filePathstr))
{
File.Delete(filePathstr);
}
return filepathsql;
}
catch (Exception ex)
{
//檢查是否存在此文件
if (File.Exists(filePathstr))
{
File.Delete(filePathstr);
}
return "";
// Response.Write("<script>alert(" + ex.Message + ");</script>");
}
}
/// <summary>
/// FTP下載文件在服務(wù)器目錄
/// </summary>
/// <param name="pathname">本地保存目錄路徑和文件名稱</param>
/// <param name="filename">FTP目錄路徑和文件名稱</param>
/// <returns></returns>
public bool FileDown(string pathname, string filename)
{
string uri = "ftp://" + ipaddress + "/" + filename;
string FileName = pathname;//本地保存目錄
//創(chuàng)建一個文件流
FileStream fs = null;
Stream responseStream = null;
try
{
//創(chuàng)建一個與FTP服務(wù)器聯(lián)系的FtpWebRequest對象
FtpWebRequest request = (FtpWebRequest)WebRequest.Create(new Uri(uri));
//連接登錄FTP服務(wù)器
request.Credentials = new NetworkCredential(Username, Password);
request.KeepAlive = false;
//設(shè)置請求的方法是FTP文件下載
request.Method = WebRequestMethods.Ftp.DownloadFile;
//獲取一個請求響應(yīng)對象
FtpWebResponse response = (FtpWebResponse)request.GetResponse();
//獲取請求的響應(yīng)流
responseStream = response.GetResponseStream();
//判斷本地文件是否存在，如果存在，則打開和重寫本地文件
if (File.Exists(FileName))
fs = File.Open(FileName, FileMode.Open, FileAccess.ReadWrite);
//判斷本地文件是否存在，如果不存在，則創(chuàng)建本地文件
else
{
fs = File.Create(FileName);
}
if (fs != null)
{
int buffer_count = 65536;
byte[] buffer = new byte[buffer_count];
int size = 0;
while ((size = responseStream.Read(buffer, 0, buffer_count)) > 0)
{
fs.Write(buffer, 0, size);
}
fs.Flush();
fs.Close();
responseStream.Close();
}
return true;
}
catch (Exception ex)
{
return false;
}
finally
{
if (fs != null)
fs.Close();
if (responseStream != null)
responseStream.Close();
}
}
/// <summary>
/// 保存和上傳圖片
/// </summary>
/// <param name="imgtwo">需要上傳圖片</param>
/// <param name="date"></param>
/// <returns>文件路徑</returns>
public string SaveUploadImg(Bitmap imgtwo)
{
string filePathstr = string.Empty;
string filepathsql = null;
try
{
string pathstr = DateTime.Now.ToString().Replace("/", "").Replace("-", "").Replace(":", "").Replace(" ", "");
string rodumlist = GeneralHelper.GetMixPwd(10);//10位隨機數(shù)
filePathstr = "~/File/" + pathstr + rodumlist + ".jpg";
imgtwo.Save(HttpContext.Current.Server.MapPath(filePathstr));//把文件上傳到服務(wù)器的絕對路徑上
bool check;
string ftpPath = DateTime.Now.ToString("yyyy-MM-dd");
string uri = @"ftp://" + ipaddress + "/";
//檢查是否存在此目錄文件夾
if (CheckDirectoryExist(uri, ftpPath, Username, Password))
{
//存在此文件夾就直接上傳
check = Upload(HttpContext.Current.Server.MapPath(filePathstr), ipaddress, ftpPath, Username, Password);
}
else
{
MakeDir(uri, ftpPath, Username, Password);//創(chuàng)建
check = Upload(HttpContext.Current.Server.MapPath(filePathstr), ipaddress, ftpPath, Username, Password);
}
//成功就更新
if (check)
{
filepathsql = ftpPath + "/" + pathstr + rodumlist + ".jpg";
}
//檢查是否存在此文件
if (File.Exists(HttpContext.Current.Server.MapPath(filePathstr)))
{
File.Delete(HttpContext.Current.Server.MapPath(filePathstr));
}
imgtwo.Dispose();
return filepathsql;
}
catch (Exception ex)
{
File.Delete(HttpContext.Current.Server.MapPath(filePathstr));
return filepathsql;
}
}
#region
/// <summary>
/// 文件大小
/// </summary>
public bool _File_Length(int ContentLength)
{
bool length = false;
int FileLen = ContentLength;
if (FileLen > 2048 * 1024 == false)//不能超過2M
{
length = true;
}
return length;
}
#endregion
//用來獲取文件類型
public bool File_PastFileName(string fileName)
{
//bmp, doc, docx, gif, jpg, jpeg, pdf, png, tif, tiff
bool isnot = true;
string ext = Path.GetExtension(fileName);
string[] type = Filetype.Split(';');
for (int i = 0; i < type.Length; i++)
{
if (type[i].ToLower() == ext.ToLower())
{
isnot = false;
break;
}
}
return isnot;
}
}
值得注意的是：幫助類中也從配置文件中讀取了存放地址、文件類型、用戶名、密碼等必要信息。這個大家可以自己再配置文件中配置，配置好了如下所示：
<add key="FileSizem" value="10"></add> <add key="FileType" value=".bmp;.gif;.jpg;.jpeg;.png;.pdf" /> <!---本地測試--> <add key="IPaddress" value="路徑" /> <!--FTP上傳文件的帳號--> <add key="UserName" value="賬號" /> <!--FTP上傳文件的密碼--> <add key="Password" value="密碼" /> <!--后臺顯示圖片地址--> <add key="PathSrc" value="路徑" />
還有一個類是圖片幫助類，代碼如下：
public class ImageHelper
{
/// <summary>
/// 圖片壓縮
/// </summary>
/// <param name="sFile">原圖路徑</param>
/// <param name="dFile">保存路徑</param>
/// <param name="flag">壓縮質(zhì)量(數(shù)字越小壓縮率越高) 1-100</param>
/// <param name="dWidth">寬度</param>
/// <param name="dHeight">高度</param>
/// <returns></returns>
public static bool SavePicThumbnail(string sFile, string dFile, int flag, int dWidth = 0, int dHeight = 0)
{
System.Drawing.Image iSource = System.Drawing.Image.FromFile(sFile);
return SavePicThumbnail(dFile, flag, iSource, dWidth, dHeight);
}
/// <summary>
/// 圖片壓縮
/// </summary>
/// <param name="sFile">原圖流</param>
/// <param name="dFile">保存路徑</param>
/// <param name="flag">壓縮質(zhì)量(數(shù)字越小壓縮率越高) 1-100</param>
/// <param name="dWidth">寬度</param>
/// <param name="dHeight">高度</param>
/// <returns></returns>
public static bool SavePicThumbnail(Stream stream, string dFile, int flag, int dWidth = 0, int dHeight = 0)
{
System.Drawing.Image iSource = System.Drawing.Image.FromStream(stream);
return SavePicThumbnail(dFile, flag, iSource, dWidth, dHeight);
}
#region GetPicThumbnail
public static Stream GetPicThumbnail(Stream stream ,int flag, int dWidth = 0, int dHeight = 0)
{
System.Drawing.Image iSource = System.Drawing.Image.FromStream(stream);
ImageFormat tFormat = iSource.RawFormat;
int sW = 0, sH = 0;
if (dHeight == 0 && dWidth == 0)
{
sW = iSource.Width;
sH = iSource.Height;
}
else if (dWidth != 0)
{
sW = dWidth;
sH = iSource.Height * dWidth / iSource.Width;
}
else if (dHeight != 0)
{
sH = dHeight;
sW = iSource.Width * dHeight / iSource.Height;
}
Bitmap ob = new Bitmap(sW, sH);
Graphics g = Graphics.FromImage(ob);
g.Clear(Color.WhiteSmoke);
g.CompositingQuality = CompositingQuality.HighQuality;
g.SmoothingMode = SmoothingMode.HighQuality;
g.InterpolationMode = InterpolationMode.HighQualityBicubic;
g.DrawImage(iSource, new Rectangle(0, 0, sW, sH), 0, 0, iSource.Width, iSource.Height, GraphicsUnit.Pixel);
g.Dispose();
//以下代碼為保存圖片時，設(shè)置壓縮質(zhì)量
EncoderParameters ep = new EncoderParameters();
long[] qy = new long[1];
qy[0] = flag;//設(shè)置壓縮的比例1-100
EncoderParameter eParam = new EncoderParameter(System.Drawing.Imaging.Encoder.Quality, qy);
ep.Param[0] = eParam;
MemoryStream ms = new MemoryStream();
try
{
ImageCodecInfo[] arrayICI = ImageCodecInfo.GetImageEncoders();
ImageCodecInfo jpegICIinfo = null;
for (int x = 0; x < arrayICI.Length; x++)
{
if (arrayICI[x].FormatDescription.Equals("JPEG"))
{
jpegICIinfo = arrayICI[x];
break;
}
}
if (jpegICIinfo != null)
{
ob.Save(ms, jpegICIinfo, ep);//dFile是壓縮后的新路徑
}
else
{
ob.Save(ms, tFormat);
}
return stream;
}
catch
{
return null;
}
finally
{
iSource.Dispose();
ob.Dispose();
}
}
public static bool SavePicThumbnail(string dFile, int flag, System.Drawing.Image iSource, int dWidth = 0, int dHeight = 0)
{
ImageFormat tFormat = iSource.RawFormat;
int sW = 0, sH = 0;
if (dHeight == 0 && dWidth == 0)
{
sW = iSource.Width;
sH = iSource.Height;
}
else if (dWidth != 0)
{
sW = dWidth;
sH = iSource.Height * dWidth / iSource.Width;
}
else if (dHeight != 0)
{
sH = dHeight;
sW = iSource.Width * dHeight / iSource.Height;
}
Bitmap ob = new Bitmap(sW, sH);
Graphics g = Graphics.FromImage(ob);
g.Clear(Color.WhiteSmoke);
g.CompositingQuality = CompositingQuality.HighQuality;
g.SmoothingMode = SmoothingMode.HighQuality;
g.InterpolationMode = InterpolationMode.HighQualityBicubic;
g.DrawImage(iSource, new Rectangle(0, 0, sW, sH), 0, 0, iSource.Width, iSource.Height, GraphicsUnit.Pixel);
g.Dispose();
//以下代碼為保存圖片時，設(shè)置壓縮質(zhì)量
EncoderParameters ep = new EncoderParameters();
long[] qy = new long[1];
qy[0] = flag;//設(shè)置壓縮的比例1-100
EncoderParameter eParam = new EncoderParameter(System.Drawing.Imaging.Encoder.Quality, qy);
ep.Param[0] = eParam;
try
{
ImageCodecInfo[] arrayICI = ImageCodecInfo.GetImageEncoders();
ImageCodecInfo jpegICIinfo = null;
for (int x = 0; x < arrayICI.Length; x++)
{
if (arrayICI[x].FormatDescription.Equals("JPEG"))
{
jpegICIinfo = arrayICI[x];
break;
}
}
if (jpegICIinfo != null)
{
ob.Save(dFile, jpegICIinfo, ep);//dFile是壓縮后的新路徑
}
else
{
ob.Save(dFile, tFormat);
}
return true;
}
catch
{
return false;
}
finally
{
iSource.Dispose();
ob.Dispose();
}
}
#endregion
}
然后我們通過在fileuploaded的回調(diào)函數(shù)中綁定url即可顯示上傳后的圖片，效果如下圖：
不過這個只是上傳到ftp服務(wù)器上了，并沒有保存到數(shù)據(jù)庫，現(xiàn)在我們要做的就是通過EF的方式將上傳的圖片保存到數(shù)據(jù)庫。
保存圖片
首先我們要建一個操作的接口基類，并且還要約束成BaseEntity,代碼如下
public interface IRepository<T> where T : BaseEntity
{
/// <summary>
/// 根據(jù)過濾條件，獲取記錄
/// </summary>
/// <param name="exp"></param>
/// <param name="isNoTracking">(默認不跟蹤實體狀態(tài))使用NoTracking的查詢會在性能方面得到改善</param>
/// <returns></returns>
IQueryable<T> Find(Expression<Func<T, bool>> exp = null, bool isNoTracking = true);
/// <summary>
/// 根據(jù)過濾條件，獲取記錄
/// </summary>
/// <param name="whereLambda"></param>
/// <param name="isNoTracking">(默認不跟蹤實體狀態(tài))使用NoTracking的查詢會在性能方面得到改善</param>
/// <param name="values"></param>
/// <returns></returns>
IQueryable<T> Find(string whereLambda = null, bool isNoTracking = true, params object[] values);
IQueryable<TEntity> OtherTable<TEntity>() where TEntity : BaseEntity;
IDbSet<TEntity> Set<TEntity>() where TEntity : BaseEntity;
/// <summary>
/// 判斷記錄是否存在
/// </summary>
/// <param name="exp"></param>
/// <returns></returns>
bool IsExist(Expression<Func<T, bool>> exp);
/// <summary>
/// 查找單個(如果沒找到則返回為NULL)
/// </summary>
/// <param name="exp"></param>
/// <param name="isNoTracking">(默認不跟蹤實體狀態(tài))使用NoTracking的查詢會在性能方面得到改善</param>
/// <returns></returns>
T FindSingle(Expression<Func<T, bool>> exp, bool isNoTracking = true);
/// <summary>
/// 得到分頁記錄
/// </summary>
/// <param name="pageIndex">The pageindex.</param>
/// <param name="pageSize">The pagesize.</param>
/// <param name="total">總條數(shù)</param>
/// <param name="exp">條件謂詞</param>
/// <param name="orderBy">排序，格式如："Id"/"Id descending"</param>
IQueryable<T> Find(int pageIndex, int pageSize, out int total, Expression<Func<T, bool>> exp = null, string orderBy = "");
/// <summary>
/// 得到分頁記錄
/// </summary>
/// <param name="pageIndex">The pageindex.</param>
/// <param name="pageSize">The pagesize.</param>
/// <param name="total">總條數(shù)</param>
/// <param name="whereLambda">條件謂詞</param>
/// <param name="orderBy">排序，格式如："Id"/"Id descending"</param>
IQueryable<T> Find(int pageIndex, int pageSize, out int total, string whereLambda = "", string orderBy = "", params object[] values);
/// <summary>
/// 根據(jù)過濾條件獲取記錄數(shù)
/// </summary>
int GetCount(Expression<Func<T, bool>> exp = null);
/// <summary>
/// 添加實體
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
/// <returns></returns>
int Add(T entity, bool isComit = true);
/// <summary>
/// 批量添加
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
int Adds(List<T> entitis, bool isComit = true);
/// <summary>
/// 更新實體（會更新實體的所有屬性）
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
/// <returns></returns>
int Update(T entity, bool isComit = true);
/// <summary>
/// 刪除實體
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
/// <returns></returns>
int Delete(T entity, bool isComit = true);
/// <summary>
/// 實現(xiàn)按需要只更新部分更新
/// <para>如：Update(u =>u.Id==1,u =>new User{Name="ok"});</para>
/// </summary>
/// <param name="where">The where.</param>
/// <param name="entity">The entity.</param>
int Update(Expression<Func<T, bool>> where, Expression<Func<T, T>> entity);
/// <summary>
/// 批量按條件刪除
/// </summary>
/// <param name="exp"></param>
int Delete(Expression<Func<T, bool>> exp);
/// <summary>
/// 對數(shù)據(jù)庫執(zhí)行給定的 DDL/DML 命令。
/// </summary>
/// <param name="sql">sql</param>
/// <param name="parameters">參數(shù)</param>
/// <returns></returns>
int ExecuteSqlCommand(string sql, params SqlParameter[] parameters);
/// <summary>
/// 執(zhí)行SQL查詢語句
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
DbRawSqlQuery<int> ExecuteSqlQuery(string sql);
/// <summary>
/// 執(zhí)行原始的sql查詢
/// </summary>
/// <typeparam name="TElement">返回的泛型類型</typeparam>
/// <param name="sql">sql</param>
/// <param name="parameters">參數(shù)</param>
/// <returns></returns>
IList<TElement> SqlQuery<TElement>(string sql, params SqlParameter[] parameters);
/// <summary>
/// 開啟一個事務(wù)
/// </summary>
/// <param name="fun"></param>
bool BeginTransaction(Func<bool> fun);
/// <summary>
/// 執(zhí)行SQL語句或存儲過程
/// 返回Datatable數(shù)據(jù)集
/// </summary>
/// <param name="sql">SQL語句或存儲過程 例如：exec usp_procedure</param>
/// <param name="parameters">參數(shù)列表</param>
/// <returns></returns>
DataTable SqlQueryForDataTable(string sql, DbParameter[] parameters);
/// <summary>
/// 返回Datatable數(shù)據(jù)集
/// </summary>
/// <param name="proName">存儲過程名</param>
/// <param name="parameters">參數(shù)列表</param>
/// <returns></returns>
[Obsolete("此方法已過時,請改用SqlQueryForDataTable")]
DataTable ExecuteForDataTable(string proName, IDataParameter[] parameters);
}
然后需要實現(xiàn)這個基類接口，代碼如下：
public class BaseRepository<T> : IRepository<T> where T : BaseEntity
{
private DbContext Context
{
get
{
DbContext db = (DbContext)CallContext.GetData("DbContext");
if (db == null)
{
db = new DbContext();
// db.Database.Log = o => LoggingHelper.Instance.Logging(LogLevel.Debug, o);
CallContext.SetData("DbContext", db);
}
return db;
}
}
/// <summary>
/// 根據(jù)過濾條件，獲取記錄
/// </summary>
/// <param name="exp"></param>
/// <param name="isNoTracking">(默認不跟蹤實體狀態(tài))使用NoTracking的查詢會在性能方面得到改善</param>
/// <returns></returns>
public IQueryable<T> Find(Expression<Func<T, bool>> exp = null, bool isNoTracking = true)
{
return Filter(exp, isNoTracking);
}
/// <summary>
/// 根據(jù)過濾條件，獲取記錄
/// </summary>
/// <param name="whereLambda"></param>
/// <param name="isNoTracking">(默認不跟蹤實體狀態(tài))使用NoTracking的查詢會在性能方面得到改善</param>
/// <param name="values"></param>
/// <returns></returns>
public IQueryable<T> Find(string whereLambda = null, bool isNoTracking = true, params object[] values)
{
return Filter(whereLambda, isNoTracking, values);
}
/// <summary>
/// 判斷記錄是否存在
/// </summary>
/// <param name="exp"></param>
/// <returns></returns>
public bool IsExist(Expression<Func<T, bool>> exp)
{
return Context.Set<T>().Any(exp);
}
/// <summary>
/// 查找單個(如果沒找到則返回為NULL)
/// </summary>
/// <param name="exp"></param>
/// <param name="isNoTracking">(默認不跟蹤實體狀態(tài))使用NoTracking的查詢會在性能方面得到改善</param>
/// <returns></returns>
public T FindSingle(Expression<Func<T, bool>> exp, bool isNoTracking = true)
{
return Filter(exp, isNoTracking).FirstOrDefault();
}
/// <summary>
/// 得到分頁記錄
/// </summary>
/// <param name="pageIndex">The pageindex.</param>
/// <param name="pageSize">The pagesize.</param>
/// <param name="total">總條數(shù)</param>
/// <param name="exp">條件謂詞</param>
/// <param name="orderBy">排序，格式如："Id"/"Id descending"</param>
public IQueryable<T> Find(int pageIndex, int pageSize, out int total, Expression<Func<T, bool>> exp = null, string orderBy = "")
{
if (pageIndex < 1) pageIndex = 1;
var query = Filter(exp);
if (!string.IsNullOrEmpty(orderBy))
query = query.OrderBy(orderBy);
total = query.Count();
///return query.Skip(pageSize * (pageIndex - 1)).Take(pageSize);
return null;
}
/// <summary>
/// 得到分頁記錄
/// </summary>
/// <param name="pageIndex">The pageindex.</param>
/// <param name="pageSize">The pagesize.</param>
/// <param name="total">總條數(shù)</param>
/// <param name="whereLambda">條件謂詞</param>
/// <param name="orderBy">排序，格式如："Id"/"Id descending"</param>
public IQueryable<T> Find(int pageIndex, int pageSize, out int total, string whereLambda = "", string orderBy = "", params object[] values)
{
if (pageIndex < 1) pageIndex = 1;
var query = Filter(whereLambda);
if (string.IsNullOrEmpty(orderBy))
query = query.OrderBy(orderBy);
total = query.Count();
// return query.Skip(pageSize * (pageIndex - 1)).Take(pageSize);
return null;
}
/// <summary>
/// 根據(jù)過濾條件獲取記錄數(shù)
/// </summary>
public int GetCount(Expression<Func<T, bool>> exp = null)
{
return Filter(exp).Count();
}
/// <summary>
/// 添加書體
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
/// <returns></returns>
public int Add(T entity, bool isComit = true)
{
Context.Entry<T>(entity).State = System.Data.Entity.EntityState.Added;
return isComit ? Context.SaveChanges() : 0;
}
/// <summary>
/// 批量添加
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
public int Adds(List<T> entitis, bool isComit = true)
{
foreach (T item in entitis)
{
Context.Entry<T>(item).State = System.Data.Entity.EntityState.Added;
}
return isComit ? Context.SaveChanges() : 0;
}
/// <summary>
/// 更新實體（會更新實體的所有屬性）
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
/// <returns></returns>
public int Update(T entity, bool isComit = true)
{
Context.Entry(entity).State = System.Data.Entity.EntityState.Modified;
return isComit ? Context.SaveChanges() : 0;
}
/// <summary>
/// 刪除實體
/// </summary>
/// <param name="entity">The entities.</param>
/// <param name="isComit">是否提交（true）</param>
/// <returns></returns>
public int Delete(T entity, bool isComit = true)
{
Context.Set<T>().Remove(entity);
return isComit ? Context.SaveChanges() : 0;
}
/// <summary>
/// 實現(xiàn)按需要只更新部分更新
/// <para>如：Update(u =>u.Id==1,u =>new User{Name="ok"});</para>
/// </summary>
/// <param name="where">The where.</param>
/// <param name="entity">The entity.</param>
public int Update(Expression<Func<T, bool>> where, Expression<Func<T, T>> entity)
{
return Context.Set<T>().Where(where).Update(entity);
}
/// <summary>
/// 批量按條件刪除
/// </summary>
/// <param name="exp"></param>
public int Delete(Expression<Func<T, bool>> exp)
{
return Context.Set<T>().Where(exp).Delete();
}
/// <summary>
/// 對數(shù)據(jù)庫執(zhí)行給定的 DDL/DML 命令。
/// </summary>
/// <param name="sql">sql</param>
/// <param name="parameters">參數(shù)</param>
/// <returns></returns>
public int ExecuteSqlCommand(string sql, params SqlParameter[] parameters)
{
return Context.Database.ExecuteSqlCommand(sql, parameters);
}
/// <summary>
/// 執(zhí)行原始的sql查詢
/// </summary>
/// <typeparam name="TElement">返回的泛型類型</typeparam>
/// <param name="sql">sql</param>
/// <param name="parameters">參數(shù)</param>
/// <returns></returns>
public IList<TElement> SqlQuery<TElement>(string sql, params SqlParameter[] parameters)
{
return Context.Database.SqlQuery<TElement>(sql, parameters).ToList();
}
public bool BeginTransaction(Func<bool> fun)
{
using (var trans = Context.Database.BeginTransaction())
{
try
{
var result = fun();
trans.Commit();
return result;
}
catch (Exception)
{
trans.Rollback();
return false;
}
}
}
private IQueryable<T> Filter(Expression<Func<T, bool>> exp = null, bool isNoTracking = true)
{
var dbSet = Context.Set<T>().AsQueryable();
if (exp != null)
dbSet = dbSet.Where(exp);
if (isNoTracking)
dbSet = dbSet.AsNoTracking();
return dbSet;
}
private IQueryable<T> Filter(string whereLambda = null, bool isNoTracking = true, params object[] values)
{
var dbSet = Context.Set<T>().AsQueryable();
if (whereLambda != null)
dbSet = dbSet.Where(whereLambda, values);
if (isNoTracking)
dbSet = dbSet.AsNoTracking();
return dbSet;
}
public IQueryable<T> Table
{
get
{
return Find(whereLambda: null);
}
}
public IQueryable<TEntity> OtherTable<TEntity>() where TEntity : BaseEntity
{
return Context.Set<TEntity>().AsNoTracking().AsQueryable();
}
public IDbSet<TEntity> Set<TEntity>() where TEntity : BaseEntity
{
return Context.Set<TEntity>();
}
/// <summary>
/// 執(zhí)行SQL查詢語句
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public DbRawSqlQuery<int> ExecuteSqlQuery(string sql)
{
try
{
return Context.Database.SqlQuery<int>(sql);
}
catch (Exception ex)
{
throw ex;
}
}
/// <summary>
/// 執(zhí)行SQL語句或存儲過程
/// 返回Datatable數(shù)據(jù)集
/// </summary>
/// <param name="sql">SQL語句或存儲過程 例如：exec usp_procedure</param>
/// <param name="parameters">參數(shù)列表</param>
/// <returns></returns>
public System.Data.DataTable SqlQueryForDataTable(string sql, params System.Data.Common.DbParameter[] parameters)
{
SqlConnection conn = new System.Data.SqlClient.SqlConnection();
try
{
conn = (SqlConnection)Context.Database.Connection;
if (conn.State != ConnectionState.Open)
{
conn.Open();
}
SqlCommand cmd = new SqlCommand();
StringBuilder sb = new StringBuilder(sql);
if (parameters != null && parameters.Length > 0)
{
if (sql.StartsWith("exec ", StringComparison.OrdinalIgnoreCase))
sb.AppendFormat(" {0}", string.Join(",", parameters.Select(o => o.ParameterName).ToArray()));
foreach (var item in parameters)
{
cmd.Parameters.Add(item);
}
}
cmd.Connection = conn;
cmd.CommandText = sb.ToString();
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
DataTable table = new DataTable();
adapter.Fill(table);
conn.Close();//連接需要關(guān)閉
return table;
}
catch (Exception ex)
{
throw ex;
}
finally
{
if (conn.State == ConnectionState.Open)
conn.Close();
}
}
/// <summary>
/// 返回Datatable數(shù)據(jù)集
/// </summary>
/// <param name="proName">存儲過程名</param>
/// <param name="parameters">參數(shù)列表</param>
/// <returns></returns>
[Obsolete("此方法已過時,請改用SqlQueryForDataTable")]
public System.Data.DataTable ExecuteForDataTable(string proName, IDataParameter[] parameters)
{
try
{
SqlConnection conn = new System.Data.SqlClient.SqlConnection();
conn.ConnectionString = Context.Database.Connection.ConnectionString;
if (conn.State != ConnectionState.Open)
{
conn.Open();
}
SqlCommand cmd = new SqlCommand(proName, conn);
cmd.CommandType = CommandType.StoredProcedure;
if (parameters != null && parameters.Length > 0)
{
foreach (var item in parameters)
{
cmd.Parameters.Add(item);
}
}
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
DataTable table = new DataTable();
adapter.Fill(table);
return table;
}
catch (Exception ex)
{
throw ex;
}
}
}
注意，我們在
這個實現(xiàn)類中定義了一個私有方法，指明了數(shù)據(jù)庫訪問的上下文DbContext
DbContext類如下：
public class DbContext : System.Data.Entity.DbContext
{
static DbContext()
{
//Database.SetInitializer(new CreateDatabaseIfNotExists<PersonalDbContext>());
}
public DbContext()
: base("Name=DbContext")
{
}
protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
var typesToRegister = Assembly.GetExecutingAssembly().GetTypes()
.Where(type => !String.IsNullOrEmpty(type.Namespace))
.Where(type => type.BaseType != null && type.BaseType.IsGenericType &&
type.BaseType.GetGenericTypeDefinition() == typeof(EntityTypeConfiguration<>));
foreach (var type in typesToRegister)
{
dynamic configurationInstance = Activator.CreateInstance(type);
modelBuilder.Configurations.Add(configurationInstance);
}
}
}
我們將Name=DbContext 意思是去尋找webconfig中具有相同名稱的值 ，所以，我們在配置文件中配置該項如下：
再configuration節(jié)點下面新建
<connectionStrings> <add name="DbContext" providerName="System.Data.SqlClient" connectionString="Server=.;Database=Test;Uid=sa;Pwd=sa;"/> </connectionStrings>
忘了說，這里對實現(xiàn)類中的一些擴展方法做了延伸，新建一個DynamicQueryable類，代碼如下：
public static class DynamicQueryable
{
public static IQueryable<T> Where<T>(this IQueryable<T> source, string predicate, params object[] values)
{
return (IQueryable<T>)Where((IQueryable)source, predicate, values);
}
public static IQueryable Where(this IQueryable source, string predicate, params object[] values)
{
if (source == null) throw new ArgumentNullException("source");
if (predicate == null) throw new ArgumentNullException("predicate");
LambdaExpression lambda = DynamicExpression.ParseLambda(source.ElementType, typeof(bool), predicate, values);
return source.Provider.CreateQuery(
Expression.Call(
typeof(Queryable), "Where",
new Type[] { source.ElementType },
source.Expression, Expression.Quote(lambda)));
}
public static IQueryable Select(this IQueryable source, string selector, params object[] values)
{
if (source == null) throw new ArgumentNullException("source");
if (selector == null) throw new ArgumentNullException("selector");
LambdaExpression lambda = DynamicExpression.ParseLambda(source.ElementType, null, selector, values);
return source.Provider.CreateQuery(
Expression.Call(
typeof(Queryable), "Select",
new Type[] { source.ElementType, lambda.Body.Type },
source.Expression, Expression.Quote(lambda)));
}
public static IQueryable<dynamic> Select<T>(this IQueryable<T> source, string selector, params object[] values)
{
return (IQueryable<dynamic>)Select((IQueryable)source, selector, values);
}
public static IQueryable<T> OrderBy<T>(this IQueryable<T> source, string ordering, params object[] values)
{
return (IQueryable<T>)OrderBy((IQueryable)source, ordering, values);
}
public static IQueryable<T> ThenBy<T>(this IQueryable<T> source, string ordering, params object[] values)
{
return (IQueryable<T>)ThenBy((IQueryable)source, ordering, values);
}
public static IQueryable ThenBy(this IQueryable source, string ordering, params object[] values)
{
if (source == null) throw new ArgumentNullException("source");
if (ordering == null) throw new ArgumentNullException("ordering");
ParameterExpression[] parameters = new ParameterExpression[] {
Expression.Parameter(source.ElementType, "") };
ExpressionParser parser = new ExpressionParser(parameters, ordering, values);
IEnumerable<DynamicOrdering> orderings = parser.ParseOrdering();
Expression queryExpr = source.Expression;
string methodAsc = "ThenBy";
string methodDesc = "ThenByDescending";
foreach (DynamicOrdering o in orderings)
{
queryExpr = Expression.Call(
typeof(Queryable), o.Ascending ? methodAsc : methodDesc,
new Type[] { source.ElementType, o.Selector.Type },
queryExpr, Expression.Quote(Expression.Lambda(o.Selector, parameters)));
}
return source.Provider.CreateQuery(queryExpr);
}
public static IQueryable OrderBy(this IQueryable source, string ordering, params object[] values)
{
if (source == null) throw new ArgumentNullException("source");
if (ordering == null) throw new ArgumentNullException("ordering");
ParameterExpression[] parameters = new ParameterExpression[] {
Expression.Parameter(source.ElementType, "") };
ExpressionParser parser = new ExpressionParser(parameters, ordering, values);
IEnumerable<DynamicOrdering> orderings = parser.ParseOrdering();
Expression queryExpr = source.Expression;
string methodAsc = "OrderBy";
string methodDesc = "OrderByDescending";
foreach (DynamicOrdering o in orderings)
{
queryExpr = Expression.Call(
typeof(Queryable), o.Ascending ? methodAsc : methodDesc,
new Type[] { source.ElementType, o.Selector.Type },
queryExpr, Expression.Quote(Expression.Lambda(o.Selector, parameters)));
methodAsc = "ThenBy";
methodDesc = "ThenByDescending";
}
return source.Provider.CreateQuery(queryExpr);
}
public static IQueryable<T> OrderBy<T>(this IQueryable<T> source, string propertyName, bool ascending)
where T : class
{
Type type = typeof(T);
PropertyInfo property = type.GetProperty(propertyName);
if (property == null)
throw new ArgumentException("propertyName", "Not Exist");
ParameterExpression param = Expression.Parameter(type, "p");
Expression propertyAccessExpression = Expression.MakeMemberAccess(param, property);
LambdaExpression orderByExpression = Expression.Lambda(propertyAccessExpression, param);
string methodName = ascending ? "OrderBy" : "OrderByDescending";
MethodCallExpression resultExp = Expression.Call(typeof(Queryable), methodName,
new Type[] { type, property.PropertyType }, source.Expression, Expression.Quote(orderByExpression));
return source.Provider.CreateQuery<T>(resultExp);
}
public static IQueryable Take(this IQueryable source, int count)
{
if (source == null) throw new ArgumentNullException("source");
return source.Provider.CreateQuery(
Expression.Call(
typeof(Queryable), "Take",
new Type[] { source.ElementType },
source.Expression, Expression.Constant(count)));
}
public static IQueryable Skip(this IQueryable source, int count)
{
if (source == null) throw new ArgumentNullException("source");
return source.Provider.CreateQuery(
Expression.Call(
typeof(Queryable), "Skip",
new Type[] { source.ElementType },
source.Expression, Expression.Constant(count)));
}
public static IQueryable GroupBy(this IQueryable source, string keySelector, string elementSelector, params object[] values)
{
if (source == null) throw new ArgumentNullException("source");
if (keySelector == null) throw new ArgumentNullException("keySelector");
if (elementSelector == null) throw new ArgumentNullException("elementSelector");
LambdaExpression keyLambda = DynamicExpression.ParseLambda(source.ElementType, null, keySelector, values);
LambdaExpression elementLambda = DynamicExpression.ParseLambda(source.ElementType, null, elementSelector, values);
return source.Provider.CreateQuery(
Expression.Call(
typeof(Queryable), "GroupBy",
new Type[] { source.ElementType, keyLambda.Body.Type, elementLambda.Body.Type },
source.Expression, Expression.Quote(keyLambda), Expression.Quote(elementLambda)));
}
public static bool Any(this IQueryable source)
{
if (source == null) throw new ArgumentNullException("source");
return (bool)source.Provider.Execute(
Expression.Call(
typeof(Queryable), "Any",
new Type[] { source.ElementType }, source.Expression));
}
public static int Count(this IQueryable source)
{
if (source == null) throw new ArgumentNullException("source");
return (int)source.Provider.Execute(
Expression.Call(
typeof(Queryable), "Count",
new Type[] { source.ElementType }, source.Expression));
}
}
public abstract class DynamicClass
{
public override string ToString()
{
PropertyInfo[] props = this.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public);
StringBuilder sb = new StringBuilder();
sb.Append("{");
for (int i = 0; i < props.Length; i++)
{
if (i > 0) sb.Append(", ");
sb.Append(props[i].Name);
sb.Append("=");
sb.Append(props[i].GetValue(this, null));
}
sb.Append("}");
return sb.ToString();
}
}
public class DynamicProperty
{
string name;
Type type;
public DynamicProperty(string name, Type type)
{
if (name == null) throw new ArgumentNullException("name");
if (type == null) throw new ArgumentNullException("type");
this.name = name;
this.type = type;
}
public string Name
{
get { return name; }
}
public Type Type
{
get { return type; }
}
}
public static class DynamicExpression
{
public static Expression Parse(Type resultType, string expression, params object[] values)
{
ExpressionParser parser = new ExpressionParser(null, expression, values);
return parser.Parse(resultType);
}
public static LambdaExpression ParseLambda(Type itType, Type resultType, string expression, params object[] values)
{
return ParseLambda(new ParameterExpression[] { Expression.Parameter(itType, "") }, resultType, expression, values);
}
public static LambdaExpression ParseLambda(ParameterExpression[] parameters, Type resultType, string expression, params object[] values)
{
ExpressionParser parser = new ExpressionParser(parameters, expression, values);
return Expression.Lambda(parser.Parse(resultType), parameters);
}
public static Expression<Func<T, S>> ParseLambda<T, S>(string expression, params object[] values)
{
return (Expression<Func<T, S>>)ParseLambda(typeof(T), typeof(S), expression, values);
}
public static Type CreateClass(params DynamicProperty[] properties)
{
return ClassFactory.Instance.GetDynamicClass(properties);
}
public static Type CreateClass(IEnumerable<DynamicProperty> properties)
{
return ClassFactory.Instance.GetDynamicClass(properties);
}
}
internal class DynamicOrdering
{
public Expression Selector;
public bool Ascending;
}
internal class Signature : IEquatable<Signature>
{
public DynamicProperty[] properties;
public int hashCode;
public Signature(IEnumerable<DynamicProperty> properties)
{
this.properties = properties.ToArray();
hashCode = 0;
foreach (DynamicProperty p in properties)
{
hashCode ^= p.Name.GetHashCode() ^ p.Type.GetHashCode();
}
}
public override int GetHashCode()
{
return hashCode;
}
public override bool Equals(object obj)
{
return obj is Signature ? Equals((Signature)obj) : false;
}
public bool Equals(Signature other)
{
if (properties.Length != other.properties.Length) return false;
for (int i = 0; i < properties.Length; i++)
{
if (properties[i].Name != other.properties[i].Name ||
properties[i].Type != other.properties[i].Type) return false;
}
return true;
}
}
internal class ClassFactory
{
public static readonly ClassFactory Instance = new ClassFactory();
static ClassFactory() { } // Trigger lazy initialization of static fields
ModuleBuilder module;
Dictionary<Signature, Type> classes;
int classCount;
ReaderWriterLock rwLock;
private ClassFactory()
{
AssemblyName name = new AssemblyName("DynamicClasses");
AssemblyBuilder assembly = AppDomain.CurrentDomain.DefineDynamicAssembly(name, AssemblyBuilderAccess.Run);
#if ENABLE_LINQ_PARTIAL_TRUST
new ReflectionPermission(PermissionState.Unrestricted).Assert();
#endif
try
{
module = assembly.DefineDynamicModule("Module");
}
finally
{
#if ENABLE_LINQ_PARTIAL_TRUST
PermissionSet.RevertAssert();
#endif
}
classes = new Dictionary<Signature, Type>();
rwLock = new ReaderWriterLock();
}
public Type GetDynamicClass(IEnumerable<DynamicProperty> properties)
{
rwLock.AcquireReaderLock(Timeout.Infinite);
try
{
Signature signature = new Signature(properties);
Type type;
if (!classes.TryGetValue(signature, out type))
{
type = CreateDynamicClass(signature.properties);
classes.Add(signature, type);
}
return type;
}
finally
{
rwLock.ReleaseReaderLock();
}
}
Type CreateDynamicClass(DynamicProperty[] properties)
{
LockCookie cookie = rwLock.UpgradeToWriterLock(Timeout.Infinite);
try
{
string typeName = "DynamicClass" + (classCount + 1);
#if ENABLE_LINQ_PARTIAL_TRUST
new ReflectionPermission(PermissionState.Unrestricted).Assert();
#endif
try
{
TypeBuilder tb = this.module.DefineType(typeName, TypeAttributes.Class |
TypeAttributes.Public, typeof(DynamicClass));
FieldInfo[] fields = GenerateProperties(tb, properties);
GenerateEquals(tb, fields);
GenerateGetHashCode(tb, fields);
Type result = tb.CreateType();
classCount++;
return result;
}
finally
{
#if ENABLE_LINQ_PARTIAL_TRUST
PermissionSet.RevertAssert();
#endif
}
}
finally
{
rwLock.DowngradeFromWriterLock(ref cookie);
}
}
FieldInfo[] GenerateProperties(TypeBuilder tb, DynamicProperty[] properties)
{
FieldInfo[] fields = new FieldBuilder[properties.Length];
for (int i = 0; i < properties.Length; i++)
{
DynamicProperty dp = properties[i];
FieldBuilder fb = tb.DefineField("_" + dp.Name, dp.Type, FieldAttributes.Private);
PropertyBuilder pb = tb.DefineProperty(dp.Name, PropertyAttributes.HasDefault, dp.Type, null);
MethodBuilder mbGet = tb.DefineMethod("get_" + dp.Name,
MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.HideBySig,
dp.Type, Type.EmptyTypes);
ILGenerator genGet = mbGet.GetILGenerator();
genGet.Emit(OpCodes.Ldarg_0);
genGet.Emit(OpCodes.Ldfld, fb);
genGet.Emit(OpCodes.Ret);
MethodBuilder mbSet = tb.DefineMethod("set_" + dp.Name,
MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.HideBySig,
null, new Type[] { dp.Type });
ILGenerator genSet = mbSet.GetILGenerator();
genSet.Emit(OpCodes.Ldarg_0);
genSet.Emit(OpCodes.Ldarg_1);
genSet.Emit(OpCodes.Stfld, fb);
genSet.Emit(OpCodes.Ret);
pb.SetGetMethod(mbGet);
pb.SetSetMethod(mbSet);
fields[i] = fb;
}
return fields;
}
void GenerateEquals(TypeBuilder tb, FieldInfo[] fields)
{
MethodBuilder mb = tb.DefineMethod("Equals",
MethodAttributes.Public | MethodAttributes.ReuseSlot |
MethodAttributes.Virtual | MethodAttributes.HideBySig,
typeof(bool), new Type[] { typeof(object) });
ILGenerator gen = mb.GetILGenerator();
LocalBuilder other = gen.DeclareLocal(tb);
Label next = gen.DefineLabel();
gen.Emit(OpCodes.Ldarg_1);
gen.Emit(OpCodes.Isinst, tb);
gen.Emit(OpCodes.Stloc, other);
gen.Emit(OpCodes.Ldloc, other);
gen.Emit(OpCodes.Brtrue_S, next);
gen.Emit(OpCodes.Ldc_I4_0);
gen.Emit(OpCodes.Ret);
gen.MarkLabel(next);
foreach (FieldInfo field in fields)
{
Type ft = field.FieldType;
Type ct = typeof(EqualityComparer<>).MakeGenericType(ft);
next = gen.DefineLabel();
gen.EmitCall(OpCodes.Call, ct.GetMethod("get_Default"), null);
gen.Emit(OpCodes.Ldarg_0);
gen.Emit(OpCodes.Ldfld, field);
gen.Emit(OpCodes.Ldloc, other);
gen.Emit(OpCodes.Ldfld, field);
gen.EmitCall(OpCodes.Callvirt, ct.GetMethod("Equals", new Type[] { ft, ft }), null);
gen.Emit(OpCodes.Brtrue_S, next);
gen.Emit(OpCodes.Ldc_I4_0);
gen.Emit(OpCodes.Ret);
gen.MarkLabel(next);
}
gen.Emit(OpCodes.Ldc_I4_1);
gen.Emit(OpCodes.Ret);
}
void GenerateGetHashCode(TypeBuilder tb, FieldInfo[] fields)
{
MethodBuilder mb = tb.DefineMethod("GetHashCode",
MethodAttributes.Public | MethodAttributes.ReuseSlot |
MethodAttributes.Virtual | MethodAttributes.HideBySig,
typeof(int), Type.EmptyTypes);
ILGenerator gen = mb.GetILGenerator();
gen.Emit(OpCodes.Ldc_I4_0);
foreach (FieldInfo field in fields)
{
Type ft = field.FieldType;
Type ct = typeof(EqualityComparer<>).MakeGenericType(ft);
gen.EmitCall(OpCodes.Call, ct.GetMethod("get_Default"), null);
gen.Emit(OpCodes.Ldarg_0);
gen.Emit(OpCodes.Ldfld, field);
gen.EmitCall(OpCodes.Callvirt, ct.GetMethod("GetHashCode", new Type[] { ft }), null);
gen.Emit(OpCodes.Xor);
}
gen.Emit(OpCodes.Ret);
}
}
public sealed class ParseException : Exception
{
int position;
public ParseException(string message, int position)
: base(message)
{
this.position = position;
}
public int Position
{
get { return position; }
}
public override string ToString()
{
return string.Format(Res.ParseExceptionFormat, Message, position);
}
}
internal class ExpressionParser
{
struct Token
{
public TokenId id;
public string text;
public int pos;
}
enum TokenId
{
Unknown,
End,
Identifier,
StringLiteral,
IntegerLiteral,
RealLiteral,
Exclamation,
Percent,
Amphersand,
OpenParen,
CloseParen,
Asterisk,
Plus,
Comma,
Minus,
Dot,
Slash,
Colon,
LessThan,
Equal,
GreaterThan,
Question,
OpenBracket,
CloseBracket,
Bar,
ExclamationEqual,
DoubleAmphersand,
LessThanEqual,
LessGreater,
DoubleEqual,
GreaterThanEqual,
DoubleBar
}
interface ILogicalSignatures
{
void F(bool x, bool y);
void F(bool? x, bool? y);
}
interface IArithmeticSignatures
{
void F(int x, int y);
void F(uint x, uint y);
void F(long x, long y);
void F(ulong x, ulong y);
void F(float x, float y);
void F(double x, double y);
void F(decimal x, decimal y);
void F(int? x, int? y);
void F(uint? x, uint? y);
void F(long? x, long? y);
void F(ulong? x, ulong? y);
void F(float? x, float? y);
void F(double? x, double? y);
void F(decimal? x, decimal? y);
}
interface IRelationalSignatures : IArithmeticSignatures
{
void F(string x, string y);
void F(char x, char y);
void F(DateTime x, DateTime y);
void F(TimeSpan x, TimeSpan y);
void F(char? x, char? y);
void F(DateTime? x, DateTime? y);
void F(TimeSpan? x, TimeSpan? y);
}
interface IEqualitySignatures : IRelationalSignatures
{
void F(bool x, bool y);
void F(bool? x, bool? y);
}
interface IAddSignatures : IArithmeticSignatures
{
void F(DateTime x, TimeSpan y);
void F(TimeSpan x, TimeSpan y);
void F(DateTime? x, TimeSpan? y);
void F(TimeSpan? x, TimeSpan? y);
}
interface ISubtractSignatures : IAddSignatures
{
void F(DateTime x, DateTime y);
void F(DateTime? x, DateTime? y);
}
interface INegationSignatures
{
void F(int x);
void F(long x);
void F(float x);
void F(double x);
void F(decimal x);
void F(int? x);
void F(long? x);
void F(float? x);
void F(double? x);
void F(decimal? x);
}
interface INotSignatures
{
void F(bool x);
void F(bool? x);
}
interface IEnumerableSignatures
{
void Where(bool predicate);
void Any();
void Any(bool predicate);
void All(bool predicate);
void Count();
void Count(bool predicate);
void Min(object selector);
void Max(object selector);
void Sum(int selector);
void Sum(int? selector);
void Sum(long selector);
void Sum(long? selector);
void Sum(float selector);
void Sum(float? selector);
void Sum(double selector);
void Sum(double? selector);
void Sum(decimal selector);
void Sum(decimal? selector);
void Average(int selector);
void Average(int? selector);
void Average(long selector);
void Average(long? selector);
void Average(float selector);
void Average(float? selector);
void Average(double selector);
void Average(double? selector);
void Average(decimal selector);
void Average(decimal? selector);
}
static readonly Type[] predefinedTypes = {
typeof(Object),
typeof(Boolean),
typeof(Char),
typeof(String),
typeof(SByte),
typeof(Byte),
typeof(Int16),
typeof(UInt16),
typeof(Int32),
typeof(UInt32),
typeof(Int64),
typeof(UInt64),
typeof(Single),
typeof(Double),
typeof(Decimal),
typeof(DateTime),
typeof(TimeSpan),
typeof(Guid),
typeof(Math),
typeof(Convert)
};
static readonly Expression trueLiteral = Expression.Constant(true);
static readonly Expression falseLiteral = Expression.Constant(false);
static readonly Expression nullLiteral = Expression.Constant(null);
static readonly string keywordIt = "it";
static readonly string keywordIif = "iif";
static readonly string keywordNew = "new";
static Dictionary<string, object> keywords;
Dictionary<string, object> symbols;
IDictionary<string, object> externals;
Dictionary<Expression, string> literals;
ParameterExpression it;
string text;
int textPos;
int textLen;
char ch;
Token token;
public ExpressionParser(ParameterExpression[] parameters, string expression, object[] values)
{
if (expression == null) throw new ArgumentNullException("expression");
if (keywords == null) keywords = CreateKeywords();
symbols = new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase);
literals = new Dictionary<Expression, string>();
if (parameters != null) ProcessParameters(parameters);
if (values != null) ProcessValues(values);
text = expression;
textLen = text.Length;
SetTextPos(0);
NextToken();
}
void ProcessParameters(ParameterExpression[] parameters)
{
foreach (ParameterExpression pe in parameters)
if (!String.IsNullOrEmpty(pe.Name))
AddSymbol(pe.Name, pe);
if (parameters.Length == 1 && String.IsNullOrEmpty(parameters[0].Name))
it = parameters[0];
}
void ProcessValues(object[] values)
{
for (int i = 0; i < values.Length; i++)
{
object value = values[i];
if (i == values.Length - 1 && value is IDictionary<string, object>)
{
externals = (IDictionary<string, object>)value;
}
else
{
AddSymbol("@" + i.ToString(System.Globalization.CultureInfo.InvariantCulture), value);
}
}
}
void AddSymbol(string name, object value)
{
if (symbols.ContainsKey(name))
throw ParseError(Res.DuplicateIdentifier, name);
symbols.Add(name, value);
}
public Expression Parse(Type resultType)
{
int exprPos = token.pos;
Expression expr = ParseExpression();
if (resultType != null)
if ((expr = PromoteExpression(expr, resultType, true)) == null)
throw ParseError(exprPos, Res.ExpressionTypeMismatch, GetTypeName(resultType));
ValidateToken(TokenId.End, Res.SyntaxError);
return expr;
}
#pragma warning disable 0219
public IEnumerable<DynamicOrdering> ParseOrdering()
{
List<DynamicOrdering> orderings = new List<DynamicOrdering>();
while (true)
{
Expression expr = ParseExpression();
bool ascending = true;
if (TokenIdentifierIs("asc") || TokenIdentifierIs("ascending"))
{
NextToken();
}
else if (TokenIdentifierIs("desc") || TokenIdentifierIs("descending"))
{
NextToken();
ascending = false;
}
orderings.Add(new DynamicOrdering { Selector = expr, Ascending = ascending });
if (token.id != TokenId.Comma) break;
NextToken();
}
ValidateToken(TokenId.End, Res.SyntaxError);
return orderings;
}
#pragma warning restore 0219
// ?: operator
Expression ParseExpression()
{
int errorPos = token.pos;
Expression expr = ParseLogicalOr();
if (token.id == TokenId.Question)
{
NextToken();
Expression expr1 = ParseExpression();
ValidateToken(TokenId.Colon, Res.ColonExpected);
NextToken();
Expression expr2 = ParseExpression();
expr = GenerateConditional(expr, expr1, expr2, errorPos);
}
return expr;
}
// ||, or operator
Expression ParseLogicalOr()
{
Expression left = ParseLogicalAnd();
while (token.id == TokenId.DoubleBar || TokenIdentifierIs("or"))
{
Token op = token;
NextToken();
Expression right = ParseLogicalAnd();
CheckAndPromoteOperands(typeof(ILogicalSignatures), op.text, ref left, ref right, op.pos);
left = Expression.OrElse(left, right);
}
return left;
}
// &&, and operator
Expression ParseLogicalAnd()
{
Expression left = ParseComparison();
while (token.id == TokenId.DoubleAmphersand || TokenIdentifierIs("and"))
{
Token op = token;
NextToken();
Expression right = ParseComparison();
CheckAndPromoteOperands(typeof(ILogicalSignatures), op.text, ref left, ref right, op.pos);
left = Expression.AndAlso(left, right);
}
return left;
}
// =, ==, !=, <>, >, >=, <, <= operators
Expression ParseComparison()
{
Expression left = ParseAdditive();
while (token.id == TokenId.Equal || token.id == TokenId.DoubleEqual ||
token.id == TokenId.ExclamationEqual || token.id == TokenId.LessGreater ||
token.id == TokenId.GreaterThan || token.id == TokenId.GreaterThanEqual ||
token.id == TokenId.LessThan || token.id == TokenId.LessThanEqual)
{
Token op = token;
NextToken();
Expression right = ParseAdditive();
bool isEquality = op.id == TokenId.Equal || op.id == TokenId.DoubleEqual ||
op.id == TokenId.ExclamationEqual || op.id == TokenId.LessGreater;
if (isEquality && !left.Type.IsValueType && !right.Type.IsValueType)
{
if (left.Type != right.Type)
{
if (left.Type.IsAssignableFrom(right.Type))
{
right = Expression.Convert(right, left.Type);
}
else if (right.Type.IsAssignableFrom(left.Type))
{
left = Expression.Convert(left, right.Type);
}
else
{
throw IncompatibleOperandsError(op.text, left, right, op.pos);
}
}
}
else if (IsEnumType(left.Type) || IsEnumType(right.Type))
{
if (left.Type != right.Type)
{
Expression e;
if ((e = PromoteExpression(right, left.Type, true)) != null)
{
right = e;
}
else if ((e = PromoteExpression(left, right.Type, true)) != null)
{
left = e;
}
else
{
throw IncompatibleOperandsError(op.text, left, right, op.pos);
}
}
}
else
{
CheckAndPromoteOperands(isEquality ? typeof(IEqualitySignatures) : typeof(IRelationalSignatures),
op.text, ref left, ref right, op.pos);
}
switch (op.id)
{
case TokenId.Equal:
case TokenId.DoubleEqual:
left = GenerateEqual(left, right);
break;
case TokenId.ExclamationEqual:
case TokenId.LessGreater:
left = GenerateNotEqual(left, right);
break;
case TokenId.GreaterThan:
left = GenerateGreaterThan(left, right);
break;
case TokenId.GreaterThanEqual:
left = GenerateGreaterThanEqual(left, right);
break;
case TokenId.LessThan:
left = GenerateLessThan(left, right);
break;
case TokenId.LessThanEqual:
left = GenerateLessThanEqual(left, right);
break;
}
}
return left;
}
// +, -, & operators
Expression ParseAdditive()
{
Expression left = ParseMultiplicative();
while (token.id == TokenId.Plus || token.id == TokenId.Minus ||
token.id == TokenId.Amphersand)
{
Token op = token;
NextToken();
Expression right = ParseMultiplicative();
switch (op.id)
{
case TokenId.Plus:
if (left.Type == typeof(string) || right.Type == typeof(string))
goto case TokenId.Amphersand;
CheckAndPromoteOperands(typeof(IAddSignatures), op.text, ref left, ref right, op.pos);
left = GenerateAdd(left, right);
break;
case TokenId.Minus:
CheckAndPromoteOperands(typeof(ISubtractSignatures), op.text, ref left, ref right, op.pos);
left = GenerateSubtract(left, right);
break;
case TokenId.Amphersand:
left = GenerateStringConcat(left, right);
break;
}
}
return left;
}
// *, /, %, mod operators
Expression ParseMultiplicative()
{
Expression left = ParseUnary();
while (token.id == TokenId.Asterisk || token.id == TokenId.Slash ||
token.id == TokenId.Percent || TokenIdentifierIs("mod"))
{
Token op = token;
NextToken();
Expression right = ParseUnary();
CheckAndPromoteOperands(typeof(IArithmeticSignatures), op.text, ref left, ref right, op.pos);
switch (op.id)
{
case TokenId.Asterisk:
left = Expression.Multiply(left, right);
break;
case TokenId.Slash:
left = Expression.Divide(left, right);
break;
case TokenId.Percent:
case TokenId.Identifier:
left = Expression.Modulo(left, right);
break;
}
}
return left;
}
// -, !, not unary operators
Expression ParseUnary()
{
if (token.id == TokenId.Minus || token.id == TokenId.Exclamation ||
TokenIdentifierIs("not"))
{
Token op = token;
NextToken();
if (op.id == TokenId.Minus && (token.id == TokenId.IntegerLiteral ||
token.id == TokenId.RealLiteral))
{
token.text = "-" + token.text;
token.pos = op.pos;
return ParsePrimary();
}
Expression expr = ParseUnary();
if (op.id == TokenId.Minus)
{
CheckAndPromoteOperand(typeof(INegationSignatures), op.text, ref expr, op.pos);
expr = Expression.Negate(expr);
}
else
{
CheckAndPromoteOperand(typeof(INotSignatures), op.text, ref expr, op.pos);
expr = Expression.Not(expr);
}
return expr;
}
return ParsePrimary();
}
Expression ParsePrimary()
{
Expression expr = ParsePrimaryStart();
while (true)
{
if (token.id == TokenId.Dot)
{
NextToken();
expr = ParseMemberAccess(null, expr);
}
else if (token.id == TokenId.OpenBracket)
{
expr = ParseElementAccess(expr);
}
else
{
break;
}
}
return expr;
}
Expression ParsePrimaryStart()
{
switch (token.id)
{
case TokenId.Identifier:
return ParseIdentifier();
case TokenId.StringLiteral:
return ParseStringLiteral();
case TokenId.IntegerLiteral:
return ParseIntegerLiteral();
case TokenId.RealLiteral:
return ParseRealLiteral();
case TokenId.OpenParen:
return ParseParenExpression();
default:
throw ParseError(Res.ExpressionExpected);
}
}
Expression ParseStringLiteral()
{
ValidateToken(TokenId.StringLiteral);
char quote = token.text[0];
string s = token.text.Substring(1, token.text.Length - 2);
int start = 0;
while (true)
{
int i = s.IndexOf(quote, start);
if (i < 0) break;
s = s.Remove(i, 1);
start = i + 1;
}
//if (quote == '\'') {
// if (s.Length != 1)
// throw ParseError(Res.InvalidCharacterLiteral);
// NextToken();
// return CreateLiteral(s[0], s);
//}
NextToken();
return CreateLiteral(s, s);
}
Expression ParseIntegerLiteral()
{
ValidateToken(TokenId.IntegerLiteral);
string text = token.text;
if (text[0] != '-')
{
ulong value;
if (!UInt64.TryParse(text, out value))
throw ParseError(Res.InvalidIntegerLiteral, text);
NextToken();
if (value <= (ulong)Int32.MaxValue) return CreateLiteral((int)value, text);
if (value <= (ulong)UInt32.MaxValue) return CreateLiteral((uint)value, text);
if (value <= (ulong)Int64.MaxValue) return CreateLiteral((long)value, text);
return CreateLiteral(value, text);
}
else
{
long value;
if (!Int64.TryParse(text, out value))
throw ParseError(Res.InvalidIntegerLiteral, text);
NextToken();
if (value >= Int32.MinValue && value <= Int32.MaxValue)
return CreateLiteral((int)value, text);
return CreateLiteral(value, text);
}
}
Expression ParseRealLiteral()
{
ValidateToken(TokenId.RealLiteral);
string text = token.text;
object value = null;
char last = text[text.Length - 1];
if (last == 'F' || last == 'f')
{
float f;
if (Single.TryParse(text.Substring(0, text.Length - 1), out f)) value = f;
}
else
{
double d;
if (Double.TryParse(text, out d)) value = d;
}
if (value == null) throw ParseError(Res.InvalidRealLiteral, text);
NextToken();
return CreateLiteral(value, text);
}
Expression CreateLiteral(object value, string text)
{
ConstantExpression expr = Expression.Constant(value);
literals.Add(expr, text);
return expr;
}
Expression ParseParenExpression()
{
ValidateToken(TokenId.OpenParen, Res.OpenParenExpected);
NextToken();
Expression e = ParseExpression();
ValidateToken(TokenId.CloseParen, Res.CloseParenOrOperatorExpected);
NextToken();
return e;
}
Expression ParseIdentifier()
{
ValidateToken(TokenId.Identifier);
object value;
if (keywords.TryGetValue(token.text, out value))
{
if (value is Type) return ParseTypeAccess((Type)value);
if (value == (object)keywordIt) return ParseIt();
if (value == (object)keywordIif) return ParseIif();
if (value == (object)keywordNew) return ParseNew();
NextToken();
return (Expression)value;
}
if (symbols.TryGetValue(token.text, out value) ||
externals != null && externals.TryGetValue(token.text, out value))
{
Expression expr = value as Expression;
if (expr == null)
{
expr = Expression.Constant(value);
}
else
{
LambdaExpression lambda = expr as LambdaExpression;
if (lambda != null) return ParseLambdaInvocation(lambda);
}
NextToken();
return expr;
}
if (it != null) return ParseMemberAccess(null, it);
throw ParseError(Res.UnknownIdentifier, token.text);
}
Expression ParseIt()
{
if (it == null)
throw ParseError(Res.NoItInScope);
NextToken();
return it;
}
Expression ParseIif()
{
int errorPos = token.pos;
NextToken();
Expression[] args = ParseArgumentList();
if (args.Length != 3)
throw ParseError(errorPos, Res.IifRequiresThreeArgs);
return GenerateConditional(args[0], args[1], args[2], errorPos);
}
Expression GenerateConditional(Expression test, Expression expr1, Expression expr2, int errorPos)
{
if (test.Type != typeof(bool))
throw ParseError(errorPos, Res.FirstExprMustBeBool);
if (expr1.Type != expr2.Type)
{
Expression expr1as2 = expr2 != nullLiteral ? PromoteExpression(expr1, expr2.Type, true) : null;
Expression expr2as1 = expr1 != nullLiteral ? PromoteExpression(expr2, expr1.Type, true) : null;
if (expr1as2 != null && expr2as1 == null)
{
expr1 = expr1as2;
}
else if (expr2as1 != null && expr1as2 == null)
{
expr2 = expr2as1;
}
else
{
string type1 = expr1 != nullLiteral ? expr1.Type.Name : "null";
string type2 = expr2 != nullLiteral ? expr2.Type.Name : "null";
if (expr1as2 != null && expr2as1 != null)
throw ParseError(errorPos, Res.BothTypesConvertToOther, type1, type2);
throw ParseError(errorPos, Res.NeitherTypeConvertsToOther, type1, type2);
}
}
return Expression.Condition(test, expr1, expr2);
}
Expression ParseNew()
{
NextToken();
ValidateToken(TokenId.OpenParen, Res.OpenParenExpected);
NextToken();
List<DynamicProperty> properties = new List<DynamicProperty>();
List<Expression> expressions = new List<Expression>();
while (true)
{
int exprPos = token.pos;
Expression expr = ParseExpression();
string propName;
if (TokenIdentifierIs("as"))
{
NextToken();
propName = GetIdentifier();
NextToken();
}
else
{
MemberExpression me = expr as MemberExpression;
if (me == null) throw ParseError(exprPos, Res.MissingAsClause);
propName = me.Member.Name;
}
expressions.Add(expr);
properties.Add(new DynamicProperty(propName, expr.Type));
if (token.id != TokenId.Comma) break;
NextToken();
}
ValidateToken(TokenId.CloseParen, Res.CloseParenOrCommaExpected);
NextToken();
Type type = DynamicExpression.CreateClass(properties);
MemberBinding[] bindings = new MemberBinding[properties.Count];
for (int i = 0; i < bindings.Length; i++)
bindings[i] = Expression.Bind(type.GetProperty(properties[i].Name), expressions[i]);
return Expression.MemberInit(Expression.New(type), bindings);
}
Expression ParseLambdaInvocation(LambdaExpression lambda)
{
int errorPos = token.pos;
NextToken();
Expression[] args = ParseArgumentList();
MethodBase method;
if (FindMethod(lambda.Type, "Invoke", false, args, out method) != 1)
throw ParseError(errorPos, Res.ArgsIncompatibleWithLambda);
return Expression.Invoke(lambda, args);
}
Expression ParseTypeAccess(Type type)
{
int errorPos = token.pos;
NextToken();
if (token.id == TokenId.Question)
{
if (!type.IsValueType || IsNullableType(type))
throw ParseError(errorPos, Res.TypeHasNoNullableForm, GetTypeName(type));
type = typeof(Nullable<>).MakeGenericType(type);
NextToken();
}
if (token.id == TokenId.OpenParen)
{
Expression[] args = ParseArgumentList();
MethodBase method;
switch (FindBestMethod(type.GetConstructors(), args, out method))
{
case 0:
if (args.Length == 1)
return GenerateConversion(args[0], type, errorPos);
throw ParseError(errorPos, Res.NoMatchingConstructor, GetTypeName(type));
case 1:
return Expression.New((ConstructorInfo)method, args);
default:
throw ParseError(errorPos, Res.AmbiguousConstructorInvocation, GetTypeName(type));
}
}
ValidateToken(TokenId.Dot, Res.DotOrOpenParenExpected);
NextToken();
return ParseMemberAccess(type, null);
}
Expression GenerateConversion(Expression expr, Type type, int errorPos)
{
Type exprType = expr.Type;
if (exprType == type) return expr;
if (exprType.IsValueType && type.IsValueType)
{
if ((IsNullableType(exprType) || IsNullableType(type)) &&
GetNonNullableType(exprType) == GetNonNullableType(type))
return Expression.Convert(expr, type);
if ((IsNumericType(exprType) || IsEnumType(exprType)) &&
(IsNumericType(type)) || IsEnumType(type))
return Expression.ConvertChecked(expr, type);
}
if (exprType.IsAssignableFrom(type) || type.IsAssignableFrom(exprType) ||
exprType.IsInterface || type.IsInterface)
return Expression.Convert(expr, type);
throw ParseError(errorPos, Res.CannotConvertValue,
GetTypeName(exprType), GetTypeName(type));
}
Expression ParseMemberAccess(Type type, Expression instance)
{
if (instance != null) type = instance.Type;
int errorPos = token.pos;
string id = GetIdentifier();
NextToken();
if (token.id == TokenId.OpenParen)
{
if (instance != null && type != typeof(string))
{
Type enumerableType = FindGenericType(typeof(IEnumerable<>), type);
if (enumerableType != null)
{
Type elementType = enumerableType.GetGenericArguments()[0];
return ParseAggregate(instance, elementType, id, errorPos);
}
}
Expression[] args = ParseArgumentList();
MethodBase mb;
switch (FindMethod(type, id, instance == null, args, out mb))
{
case 0:
throw ParseError(errorPos, Res.NoApplicableMethod,
id, GetTypeName(type));
case 1:
MethodInfo method = (MethodInfo)mb;
if (!IsPredefinedType(method.DeclaringType))
throw ParseError(errorPos, Res.MethodsAreInaccessible, GetTypeName(method.DeclaringType));
if (method.ReturnType == typeof(void))
throw ParseError(errorPos, Res.MethodIsVoid,
id, GetTypeName(method.DeclaringType));
return Expression.Call(instance, (MethodInfo)method, args);
default:
throw ParseError(errorPos, Res.AmbiguousMethodInvocation,
id, GetTypeName(type));
}
}
else
{
MemberInfo member = FindPropertyOrField(type, id, instance == null);
if (member == null)
throw ParseError(errorPos, Res.UnknownPropertyOrField,
id, GetTypeName(type));
return member is PropertyInfo ?
Expression.Property(instance, (PropertyInfo)member) :
Expression.Field(instance, (FieldInfo)member);
}
}
static Type FindGenericType(Type generic, Type type)
{
while (type != null && type != typeof(object))
{
if (type.IsGenericType && type.GetGenericTypeDefinition() == generic) return type;
if (generic.IsInterface)
{
foreach (Type intfType in type.GetInterfaces())
{
Type found = FindGenericType(generic, intfType);
if (found != null) return found;
}
}
type = type.BaseType;
}
return null;
}
Expression ParseAggregate(Expression instance, Type elementType, string methodName, int errorPos)
{
ParameterExpression outerIt = it;
ParameterExpression innerIt = Expression.Parameter(elementType, "");
it = innerIt;
Expression[] args = ParseArgumentList();
it = outerIt;
MethodBase signature;
if (FindMethod(typeof(IEnumerableSignatures), methodName, false, args, out signature) != 1)
throw ParseError(errorPos, Res.NoApplicableAggregate, methodName);
Type[] typeArgs;
if (signature.Name == "Min" || signature.Name == "Max")
{
typeArgs = new Type[] { elementType, args[0].Type };
}
else
{
typeArgs = new Type[] { elementType };
}
if (args.Length == 0)
{
args = new Expression[] { instance };
}
else
{
args = new Expression[] { instance, Expression.Lambda(args[0], innerIt) };
}
return Expression.Call(typeof(Enumerable), signature.Name, typeArgs, args);
}
Expression[] ParseArgumentList()
{
ValidateToken(TokenId.OpenParen, Res.OpenParenExpected);
NextToken();
Expression[] args = token.id != TokenId.CloseParen ? ParseArguments() : new Expression[0];
ValidateToken(TokenId.CloseParen, Res.CloseParenOrCommaExpected);
NextToken();
return args;
}
Expression[] ParseArguments()
{
List<Expression> argList = new List<Expression>();
while (true)
{
argList.Add(ParseExpression());
if (token.id != TokenId.Comma) break;
NextToken();
}
return argList.ToArray();
}
Expression ParseElementAccess(Expression expr)
{
int errorPos = token.pos;
ValidateToken(TokenId.OpenBracket, Res.OpenParenExpected);
NextToken();
Expression[] args = ParseArguments();
ValidateToken(TokenId.CloseBracket, Res.CloseBracketOrCommaExpected);
NextToken();
if (expr.Type.IsArray)
{
if (expr.Type.GetArrayRank() != 1 || args.Length != 1)
throw ParseError(errorPos, Res.CannotIndexMultiDimArray);
Expression index = PromoteExpression(args[0], typeof(int), true);
if (index == null)
throw ParseError(errorPos, Res.InvalidIndex);
return Expression.ArrayIndex(expr, index);
}
else
{
MethodBase mb;
switch (FindIndexer(expr.Type, args, out mb))
{
case 0:
throw ParseError(errorPos, Res.NoApplicableIndexer,
GetTypeName(expr.Type));
case 1:
return Expression.Call(expr, (MethodInfo)mb, args);
default:
throw ParseError(errorPos, Res.AmbiguousIndexerInvocation,
GetTypeName(expr.Type));
}
}
}
static bool IsPredefinedType(Type type)
{
foreach (Type t in predefinedTypes) if (t == type) return true;
return false;
}
static bool IsNullableType(Type type)
{
return type.IsGenericType && type.GetGenericTypeDefinition() == typeof(Nullable<>);
}
static Type GetNonNullableType(Type type)
{
return IsNullableType(type) ? type.GetGenericArguments()[0] : type;
}
static string GetTypeName(Type type)
{
Type baseType = GetNonNullableType(type);
string s = baseType.Name;
if (type != baseType) s += '?';
return s;
}
static bool IsNumericType(Type type)
{
return GetNumericTypeKind(type) != 0;
}
static bool IsSignedIntegralType(Type type)
{
return GetNumericTypeKind(type) == 2;
}
static bool IsUnsignedIntegralType(Type type)
{
return GetNumericTypeKind(type) == 3;
}
static int GetNumericTypeKind(Type type)
{
type = GetNonNullableType(type);
if (type.IsEnum) return 0;
switch (Type.GetTypeCode(type))
{
case TypeCode.Char:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return 1;
case TypeCode.SByte:
case TypeCode.Int16:
case TypeCode.Int32:
case TypeCode.Int64:
return 2;
case TypeCode.Byte:
case TypeCode.UInt16:
case TypeCode.UInt32:
case TypeCode.UInt64:
return 3;
default:
return 0;
}
}
static bool IsEnumType(Type type)
{
return GetNonNullableType(type).IsEnum;
}
void CheckAndPromoteOperand(Type signatures, string opName, ref Expression expr, int errorPos)
{
Expression[] args = new Expression[] { expr };
MethodBase method;
if (FindMethod(signatures, "F", false, args, out method) != 1)
throw ParseError(errorPos, Res.IncompatibleOperand,
opName, GetTypeName(args[0].Type));
expr = args[0];
}
void CheckAndPromoteOperands(Type signatures, string opName, ref Expression left, ref Expression right, int errorPos)
{
Expression[] args = new Expression[] { left, right };
MethodBase method;
if (FindMethod(signatures, "F", false, args, out method) != 1)
throw IncompatibleOperandsError(opName, left, right, errorPos);
left = args[0];
right = args[1];
}
Exception IncompatibleOperandsError(string opName, Expression left, Expression right, int pos)
{
return ParseError(pos, Res.IncompatibleOperands,
opName, GetTypeName(left.Type), GetTypeName(right.Type));
}
MemberInfo FindPropertyOrField(Type type, string memberName, bool staticAccess)
{
BindingFlags flags = BindingFlags.Public | BindingFlags.DeclaredOnly |
(staticAccess ? BindingFlags.Static : BindingFlags.Instance);
foreach (Type t in SelfAndBaseTypes(type))
{
MemberInfo[] members = t.FindMembers(MemberTypes.Property | MemberTypes.Field,
flags, Type.FilterNameIgnoreCase, memberName);
if (members.Length != 0) return members[0];
}
return null;
}
int FindMethod(Type type, string methodName, bool staticAccess, Expression[] args, out MethodBase method)
{
BindingFlags flags = BindingFlags.Public | BindingFlags.DeclaredOnly |
(staticAccess ? BindingFlags.Static : BindingFlags.Instance);
foreach (Type t in SelfAndBaseTypes(type))
{
MemberInfo[] members = t.FindMembers(MemberTypes.Method,
flags, Type.FilterNameIgnoreCase, methodName);
int count = FindBestMethod(members.Cast<MethodBase>(), args, out method);
if (count != 0) return count;
}
method = null;
return 0;
}
int FindIndexer(Type type, Expression[] args, out MethodBase method)
{
foreach (Type t in SelfAndBaseTypes(type))
{
MemberInfo[] members = t.GetDefaultMembers();
if (members.Length != 0)
{
IEnumerable<MethodBase> methods = members.
OfType<PropertyInfo>().
Select(p => (MethodBase)p.GetGetMethod()).
Where(m => m != null);
int count = FindBestMethod(methods, args, out method);
if (count != 0) return count;
}
}
method = null;
return 0;
}
static IEnumerable<Type> SelfAndBaseTypes(Type type)
{
if (type.IsInterface)
{
List<Type> types = new List<Type>();
AddInterface(types, type);
return types;
}
return SelfAndBaseClasses(type);
}
static IEnumerable<Type> SelfAndBaseClasses(Type type)
{
while (type != null)
{
yield return type;
type = type.BaseType;
}
}
static void AddInterface(List<Type> types, Type type)
{
if (!types.Contains(type))
{
types.Add(type);
foreach (Type t in type.GetInterfaces()) AddInterface(types, t);
}
}
class MethodData
{
public MethodBase MethodBase;
public ParameterInfo[] Parameters;
public Expression[] Args;
}
int FindBestMethod(IEnumerable<MethodBase> methods, Expression[] args, out MethodBase method)
{
MethodData[] applicable = methods.
Select(m => new MethodData { MethodBase = m, Parameters = m.GetParameters() }).
Where(m => IsApplicable(m, args)).
ToArray();
if (applicable.Length > 1)
{
applicable = applicable.
Where(m => applicable.All(n => m == n || IsBetterThan(args, m, n))).
ToArray();
}
if (applicable.Length == 1)
{
MethodData md = applicable[0];
for (int i = 0; i < args.Length; i++) args[i] = md.Args[i];
method = md.MethodBase;
}
else
{
method = null;
}
return applicable.Length;
}
bool IsApplicable(MethodData method, Expression[] args)
{
if (method.Parameters.Length != args.Length) return false;
Expression[] promotedArgs = new Expression[args.Length];
for (int i = 0; i < args.Length; i++)
{
ParameterInfo pi = method.Parameters[i];
if (pi.IsOut) return false;
Expression promoted = PromoteExpression(args[i], pi.ParameterType, false);
if (promoted == null) return false;
promotedArgs[i] = promoted;
}
method.Args = promotedArgs;
return true;
}
Expression PromoteExpression(Expression expr, Type type, bool exact)
{
if (expr.Type == type) return expr;
if (expr is ConstantExpression)
{
ConstantExpression ce = (ConstantExpression)expr;
if (ce == nullLiteral)
{
if (!type.IsValueType || IsNullableType(type))
return Expression.Constant(null, type);
}
else
{
string text;
if (literals.TryGetValue(ce, out text))
{
Type target = GetNonNullableType(type);
Object value = null;
switch (Type.GetTypeCode(ce.Type))
{
case TypeCode.Int32:
case TypeCode.UInt32:
case TypeCode.Int64:
case TypeCode.UInt64:
value = ParseNumber(text, target);
break;
case TypeCode.Double:
if (target == typeof(decimal)) value = ParseNumber(text, target);
break;
case TypeCode.String:
value = ParseEnum(text, target);
break;
}
if (value != null)
return Expression.Constant(value, type);
}
}
}
if (IsCompatibleWith(expr.Type, type))
{
if (type.IsValueType || exact) return Expression.Convert(expr, type);
return expr;
}
return null;
}
static object ParseNumber(string text, Type type)
{
switch (Type.GetTypeCode(GetNonNullableType(type)))
{
case TypeCode.SByte:
sbyte sb;
if (sbyte.TryParse(text, out sb)) return sb;
break;
case TypeCode.Byte:
byte b;
if (byte.TryParse(text, out b)) return b;
break;
case TypeCode.Int16:
short s;
if (short.TryParse(text, out s)) return s;
break;
case TypeCode.UInt16:
ushort us;
if (ushort.TryParse(text, out us)) return us;
break;
case TypeCode.Int32:
int i;
if (int.TryParse(text, out i)) return i;
break;
case TypeCode.UInt32:
uint ui;
if (uint.TryParse(text, out ui)) return ui;
break;
case TypeCode.Int64:
long l;
if (long.TryParse(text, out l)) return l;
break;
case TypeCode.UInt64:
ulong ul;
if (ulong.TryParse(text, out ul)) return ul;
break;
case TypeCode.Single:
float f;
if (float.TryParse(text, out f)) return f;
break;
case TypeCode.Double:
double d;
if (double.TryParse(text, out d)) return d;
break;
case TypeCode.Decimal:
decimal e;
if (decimal.TryParse(text, out e)) return e;
break;
}
return null;
}
static object ParseEnum(string name, Type type)
{
if (type.IsEnum)
{
MemberInfo[] memberInfos = type.FindMembers(MemberTypes.Field,
BindingFlags.Public | BindingFlags.DeclaredOnly | BindingFlags.Static,
Type.FilterNameIgnoreCase, name);
if (memberInfos.Length != 0) return ((FieldInfo)memberInfos[0]).GetValue(null);
}
return null;
}
static bool IsCompatibleWith(Type source, Type target)
{
if (source == target) return true;
if (!target.IsValueType) return target.IsAssignableFrom(source);
Type st = GetNonNullableType(source);
Type tt = GetNonNullableType(target);
if (st != source && tt == target) return false;
TypeCode sc = st.IsEnum ? TypeCode.Object : Type.GetTypeCode(st);
TypeCode tc = tt.IsEnum ? TypeCode.Object : Type.GetTypeCode(tt);
switch (sc)
{
case TypeCode.SByte:
switch (tc)
{
case TypeCode.SByte:
case TypeCode.Int16:
case TypeCode.Int32:
case TypeCode.Int64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.Byte:
switch (tc)
{
case TypeCode.Byte:
case TypeCode.Int16:
case TypeCode.UInt16:
case TypeCode.Int32:
case TypeCode.UInt32:
case TypeCode.Int64:
case TypeCode.UInt64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.Int16:
switch (tc)
{
case TypeCode.Int16:
case TypeCode.Int32:
case TypeCode.Int64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.UInt16:
switch (tc)
{
case TypeCode.UInt16:
case TypeCode.Int32:
case TypeCode.UInt32:
case TypeCode.Int64:
case TypeCode.UInt64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.Int32:
switch (tc)
{
case TypeCode.Int32:
case TypeCode.Int64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.UInt32:
switch (tc)
{
case TypeCode.UInt32:
case TypeCode.Int64:
case TypeCode.UInt64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.Int64:
switch (tc)
{
case TypeCode.Int64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.UInt64:
switch (tc)
{
case TypeCode.UInt64:
case TypeCode.Single:
case TypeCode.Double:
case TypeCode.Decimal:
return true;
}
break;
case TypeCode.Single:
switch (tc)
{
case TypeCode.Single:
case TypeCode.Double:
return true;
}
break;
default:
if (st == tt) return true;
break;
}
return false;
}
static bool IsBetterThan(Expression[] args, MethodData m1, MethodData m2)
{
bool better = false;
for (int i = 0; i < args.Length; i++)
{
int c = CompareConversions(args[i].Type,
m1.Parameters[i].ParameterType,
m2.Parameters[i].ParameterType);
if (c < 0) return false;
if (c > 0) better = true;
}
return better;
}
// Return 1 if s -> t1 is a better conversion than s -> t2
// Return -1 if s -> t2 is a better conversion than s -> t1
// Return 0 if neither conversion is better
static int CompareConversions(Type s, Type t1, Type t2)
{
if (t1 == t2) return 0;
if (s == t1) return 1;
if (s == t2) return -1;
bool t1t2 = IsCompatibleWith(t1, t2);
bool t2t1 = IsCompatibleWith(t2, t1);
if (t1t2 && !t2t1) return 1;
if (t2t1 && !t1t2) return -1;
if (IsSignedIntegralType(t1) && IsUnsignedIntegralType(t2)) return 1;
if (IsSignedIntegralType(t2) && IsUnsignedIntegralType(t1)) return -1;
return 0;
}
Expression GenerateEqual(Expression left, Expression right)
{
return Expression.Equal(left, right);
}
Expression GenerateNotEqual(Expression left, Expression right)
{
return Expression.NotEqual(left, right);
}
Expression GenerateGreaterThan(Expression left, Expression right)
{
if (left.Type == typeof(string))
{
return Expression.GreaterThan(
GenerateStaticMethodCall("Compare", left, right),
Expression.Constant(0)
);
}
return Expression.GreaterThan(left, right);
}
Expression GenerateGreaterThanEqual(Expression left, Expression right)
{
if (left.Type == typeof(string))
{
return Expression.GreaterThanOrEqual(
GenerateStaticMethodCall("Compare", left, right),
Expression.Constant(0)
);
}
return Expression.GreaterThanOrEqual(left, right);
}
Expression GenerateLessThan(Expression left, Expression right)
{
if (left.Type == typeof(string))
{
return Expression.LessThan(
GenerateStaticMethodCall("Compare", left, right),
Expression.Constant(0)
);
}
return Expression.LessThan(left, right);
}
Expression GenerateLessThanEqual(Expression left, Expression right)
{
if (left.Type == typeof(string))
{
return Expression.LessThanOrEqual(
GenerateStaticMethodCall("Compare", left, right),
Expression.Constant(0)
);
}
return Expression.LessThanOrEqual(left, right);
}
Expression GenerateAdd(Expression left, Expression right)
{
if (left.Type == typeof(string) && right.Type == typeof(string))
{
return GenerateStaticMethodCall("Concat", left, right);
}
return Expression.Add(left, right);
}
Expression GenerateSubtract(Expression left, Expression right)
{
return Expression.Subtract(left, right);
}
Expression GenerateStringConcat(Expression left, Expression right)
{
return Expression.Call(
null,
typeof(string).GetMethod("Concat", new[] { typeof(object), typeof(object) }),
new[] { left, right });
}
MethodInfo GetStaticMethod(string methodName, Expression left, Expression right)
{
return left.Type.GetMethod(methodName, new[] { left.Type, right.Type });
}
Expression GenerateStaticMethodCall(string methodName, Expression left, Expression right)
{
return Expression.Call(null, GetStaticMethod(methodName, left, right), new[] { left, right });
}
void SetTextPos(int pos)
{
textPos = pos;
ch = textPos < textLen ? text[textPos] : '\0';
}
void NextChar()
{
if (textPos < textLen) textPos++;
ch = textPos < textLen ? text[textPos] : '\0';
}
void NextToken()
{
while (Char.IsWhiteSpace(ch)) NextChar();
TokenId t;
int tokenPos = textPos;
switch (ch)
{
case '!':
NextChar();
if (ch == '=')
{
NextChar();
t = TokenId.ExclamationEqual;
}
else
{
t = TokenId.Exclamation;
}
break;
case '%':
NextChar();
t = TokenId.Percent;
break;
case '&':
NextChar();
if (ch == '&')
{
NextChar();
t = TokenId.DoubleAmphersand;
}
else
{
t = TokenId.Amphersand;
}
break;
case '(':
NextChar();
t = TokenId.OpenParen;
break;
case ')':
NextChar();
t = TokenId.CloseParen;
break;
case '*':
NextChar();
t = TokenId.Asterisk;
break;
case '+':
NextChar();
t = TokenId.Plus;
break;
case ',':
NextChar();
t = TokenId.Comma;
break;
case '-':
NextChar();
t = TokenId.Minus;
break;
case '.':
NextChar();
t = TokenId.Dot;
break;
case '/':
NextChar();
t = TokenId.Slash;
break;
case ':':
NextChar();
t = TokenId.Colon;
break;
case '<':
NextChar();
if (ch == '=')
{
NextChar();
t = TokenId.LessThanEqual;
}
else if (ch == '>')
{
NextChar();
t = TokenId.LessGreater;
}
else
{
t = TokenId.LessThan;
}
break;
case '=':
NextChar();
if (ch == '=')
{
NextChar();
t = TokenId.DoubleEqual;
}
else
{
t = TokenId.Equal;
}
break;
case '>':
NextChar();
if (ch == '=')
{
NextChar();
t = TokenId.GreaterThanEqual;
}
else
{
t = TokenId.GreaterThan;
}
break;
case '?':
NextChar();
t = TokenId.Question;
break;
case '[':
NextChar();
t = TokenId.OpenBracket;
break;
case ']':
NextChar();
t = TokenId.CloseBracket;
break;
case '|':
NextChar();
if (ch == '|')
{
NextChar();
t = TokenId.DoubleBar;
}
else
{
t = TokenId.Bar;
}
break;
case '"':
case '\'':
char quote = ch;
do
{
NextChar();
while (textPos < textLen && ch != quote) NextChar();
if (textPos == textLen)
throw ParseError(textPos, Res.UnterminatedStringLiteral);
NextChar();
} while (ch == quote);
t = TokenId.StringLiteral;
break;
default:
if (Char.IsLetter(ch) || ch == '@' || ch == '_')
{
do
{
NextChar();
} while (Char.IsLetterOrDigit(ch) || ch == '_');
t = TokenId.Identifier;
break;
}
if (Char.IsDigit(ch))
{
t = TokenId.IntegerLiteral;
do
{
NextChar();
} while (Char.IsDigit(ch));
if (ch == '.')
{
t = TokenId.RealLiteral;
NextChar();
ValidateDigit();
do
{
NextChar();
} while (Char.IsDigit(ch));
}
if (ch == 'E' || ch == 'e')
{
t = TokenId.RealLiteral;
NextChar();
if (ch == '+' || ch == '-') NextChar();
ValidateDigit();
do
{
NextChar();
} while (Char.IsDigit(ch));
}
if (ch == 'F' || ch == 'f') NextChar();
break;
}
if (textPos == textLen)
{
t = TokenId.End;
break;
}
throw ParseError(textPos, Res.InvalidCharacter, ch);
}
token.id = t;
token.text = text.Substring(tokenPos, textPos - tokenPos);
token.pos = tokenPos;
}
bool TokenIdentifierIs(string id)
{
return token.id == TokenId.Identifier && String.Equals(id, token.text, StringComparison.OrdinalIgnoreCase);
}
string GetIdentifier()
{
ValidateToken(TokenId.Identifier, Res.IdentifierExpected);
string id = token.text;
if (id.Length > 1 && id[0] == '@') id = id.Substring(1);
return id;
}
void ValidateDigit()
{
if (!Char.IsDigit(ch)) throw ParseError(textPos, Res.DigitExpected);
}
void ValidateToken(TokenId t, string errorMessage)
{
if (token.id != t) throw ParseError(errorMessage);
}
void ValidateToken(TokenId t)
{
if (token.id != t) throw ParseError(Res.SyntaxError);
}
Exception ParseError(string format, params object[] args)
{
return ParseError(token.pos, format, args);
}
Exception ParseError(int pos, string format, params object[] args)
{
return new ParseException(string.Format(System.Globalization.CultureInfo.CurrentCulture, format, args), pos);
}
static Dictionary<string, object> CreateKeywords()
{
Dictionary<string, object> d = new Dictionary<string, object>(StringComparer.OrdinalIgnoreCase);
d.Add("true", trueLiteral);
d.Add("false", falseLiteral);
d.Add("null", nullLiteral);
d.Add(keywordIt, keywordIt);
d.Add(keywordIif, keywordIif);
d.Add(keywordNew, keywordNew);
foreach (Type type in predefinedTypes) d.Add(type.Name, type);
return d;
}
}
static class Res
{
public const string DuplicateIdentifier = "The identifier '{0}' was defined more than once";
public const string ExpressionTypeMismatch = "Expression of type '{0}' expected";
public const string ExpressionExpected = "Expression expected";
public const string InvalidCharacterLiteral = "Character literal must contain exactly one character";
public const string InvalidIntegerLiteral = "Invalid integer literal '{0}'";
public const string InvalidRealLiteral = "Invalid real literal '{0}'";
public const string UnknownIdentifier = "Unknown identifier '{0}'";
public const string NoItInScope = "No 'it' is in scope";
public const string IifRequiresThreeArgs = "The 'iif' function requires three arguments";
public const string FirstExprMustBeBool = "The first expression must be of type 'Boolean'";
public const string BothTypesConvertToOther = "Both of the types '{0}' and '{1}' convert to the other";
public const string NeitherTypeConvertsToOther = "Neither of the types '{0}' and '{1}' converts to the other";
public const string MissingAsClause = "Expression is missing an 'as' clause";
public const string ArgsIncompatibleWithLambda = "Argument list incompatible with lambda expression";
public const string TypeHasNoNullableForm = "Type '{0}' has no nullable form";
public const string NoMatchingConstructor = "No matching constructor in type '{0}'";
public const string AmbiguousConstructorInvocation = "Ambiguous invocation of '{0}' constructor";
public const string CannotConvertValue = "A value of type '{0}' cannot be converted to type '{1}'";
public const string NoApplicableMethod = "No applicable method '{0}' exists in type '{1}'";
public const string MethodsAreInaccessible = "Methods on type '{0}' are not accessible";
public const string MethodIsVoid = "Method '{0}' in type '{1}' does not return a value";
public const string AmbiguousMethodInvocation = "Ambiguous invocation of method '{0}' in type '{1}'";
public const string UnknownPropertyOrField = "No property or field '{0}' exists in type '{1}'";
public const string NoApplicableAggregate = "No applicable aggregate method '{0}' exists";
public const string CannotIndexMultiDimArray = "Indexing of multi-dimensional arrays is not supported";
public const string InvalidIndex = "Array index must be an integer expression";
public const string NoApplicableIndexer = "No applicable indexer exists in type '{0}'";
public const string AmbiguousIndexerInvocation = "Ambiguous invocation of indexer in type '{0}'";
public const string IncompatibleOperand = "Operator '{0}' incompatible with operand type '{1}'";
public const string IncompatibleOperands = "Operator '{0}' incompatible with operand types '{1}' and '{2}'";
public const string UnterminatedStringLiteral = "Unterminated string literal";
public const string InvalidCharacter = "Syntax error '{0}'";
public const string DigitExpected = "Digit expected";
public const string SyntaxError = "Syntax error";
public const string TokenExpected = "{0} expected";
public const string ParseExceptionFormat = "{0} (at index {1})";
public const string ColonExpected = "':' expected";
public const string OpenParenExpected = "'(' expected";
public const string CloseParenOrOperatorExpected = "')' or operator expected";
public const string CloseParenOrCommaExpected = "')' or ',' expected";
public const string DotOrOpenParenExpected = "'.' or '(' expected";
public const string OpenBracketExpected = "'[' expected";
public const string CloseBracketOrCommaExpected = "']' or ',' expected";
public const string IdentifierExpected = "Identifier expected";
}
此時，我們需要將我們的實體和數(shù)據(jù)庫字段映射對應(yīng)起來，新建一個ImageMap類代碼如下：
public class ImageMap : EntityTypeConfiguration<ImageModel>
{
public ImageMap()
{
// Primary Key
this.HasKey(t => t.ID);
// Properties
this.Property(t => t.IDProofFront)
.HasMaxLength(100);
this.Property(t => t.IDProofBack)
.HasMaxLength(100);
// Table & Column Mappings
this.ToTable("ImageModel");
this.Property(t => t.ID).HasColumnName("ID");
this.Property(t => t.IDProofFront).HasColumnName("IDProofFront");
this.Property(t => t.IDProofBack).HasColumnName("IDProofBack");
}
}
其中ToTable就是指明數(shù)據(jù)庫表名，
那么如何將上傳的圖片保存更新到數(shù)據(jù)庫呢？
接下來我們新建一個接口類IResourcesImage 并繼承操作基類 IRepository<ImageModel>
定義一個上傳身份信息的規(guī)則如下：
bool UpdateIDProof(string IDProofFront, string IDProofBack, int pId);
接下來我們新建一個ResourcesImage 實現(xiàn)上述接口。代碼如下：
public ResourcesImage() { }
/// <summary>
/// 上傳身份信息采用此種方式
/// </summary>
/// <param name="IDProofBack"></param>
/// <param name="IDProofBack"></param>
/// <param name="pId"></param>
/// <returns></returns>
public bool UpdateIDProof(string IDProofFront, string IDProofBack, int pId)
{
int flag = 0;
if (IDProofFront != "" && IDProofFront != null)
{
flag = this.Update(m => m.ID == pId, u => new ImageModel { IDProofFront = IDProofFront });
if (flag == 1)
{
if (IDProofBack != "" && IDProofBack != null)
flag = this.Update(m => m.ID == pId, u => new ImageModel { IDProofBack = IDProofBack });
}
}
else
{
if (IDProofBack != "" && IDProofBack != null)
flag = this.Update(m => m.ID == pId, u => new ImageModel { IDProofBack = IDProofBack });
}
return flag == 0 ? false : true;
}
我們在中間層做一下這個操作：
private readonly IResourcesImage _resourcesImage;
public CodeBLL()
{
this._resourcesImage = new ResourcesImage();
}
/// <summary>
/// 根據(jù)字段更新用戶的文件資料信息
/// </summary>
/// <param name="fileNameField">字段</param>
/// <param name="fileNameValue">字段值</param>
/// <param name="pId"></param>
/// <returns></returns>
public bool UpdateFileName(string IDProofFront, string IDProofBack, int pId)
{
bool flag = false;
flag = _resourcesImage.UpdateIDProof(IDProofFront, IDProofBack, pId);
return flag;
}
這樣做其實并不科學(xué)，需要手動實例化這種倉儲操作，科學(xué)的方式可以使用IOC（控制反轉(zhuǎn)）.
中間層做好之后，我們只需要在HomeController中調(diào)用此方法即可，代碼如下：
至此，我們就實現(xiàn)了本地通過ftp方式上傳圖片代碼，并將圖片以相對路徑保存在數(shù)據(jù)庫中，數(shù)據(jù)庫存放格式如下：
Demo下載
以上所述是小編給大家介紹的C# 中實現(xiàn)ftp 圖片上傳功能，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
相關(guān)文章
這篇文章主要介紹了C#中讀寫INI配置文件的方法，非常不錯，具有一定的參考借鑒價值,需要的朋友可以參考下2018-07-07
本文主要介紹了C#集合查詢Linq在項目中使用詳解，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05
這篇文章主要介紹了c# 字符串操作的相關(guān)知識，文中講解的非常詳細，代碼幫助大家更好的學(xué)習(xí)，感興趣的朋友可以參考下，希望能給你帶來幫助2021-07-07
這篇文章主要介紹了C#中的匿名函數(shù)、lambda表達式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-01-01
這篇文章主要介紹了C#異步原理，C#異步在C#5便發(fā)布了，是利用async關(guān)鍵字和await表達式表達的異步操作，下面文章下邊將詳細向大家介紹C#異步原理，感興趣得小伙伴可以參考一下2021-10-10
C#實現(xiàn)3步手動建DataGridView的方法
這篇文章主要介紹了C#實現(xiàn)3步手動建DataGridView的方法,實例分析了C#實現(xiàn)手動創(chuàng)建DataGridView的原理與技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-09-09
這篇文章主要介紹了C#如何將Excel轉(zhuǎn)換為PDF問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-01-01
這篇文章主要介紹了C#服務(wù)端圖片打包下載實現(xiàn)代碼解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-07-07
這篇文章主要為大家詳細介紹了Unity實現(xiàn)虛擬鍵盤，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-03-03
C#控制臺程序如何發(fā)布到服務(wù)器Linux上運行
這篇文章主要給大家介紹了關(guān)于C#控制臺程序如何發(fā)布到服務(wù)器Linux上運行的相關(guān)資料,文中通過圖文介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2021-11-11