").append(c.replace(bP, "")).find(g) : c)), d && i.each(d, [c, b, a]) } }); return this }, serialize: function () { return f.param(this.serializeArray()) }, serializeArray: function () { return this.map(function () { return this.elements ? f.makeArray(this.elements) : this }).filter(function () { return this.name && !this.disabled && (this.checked || bQ.test(this.nodeName) || bK.test(this.type)) }).map(function (a, b) { var c = f(this).val(); return c == null ? null : f.isArray(c) ? f.map(c, function (a, c) { return { name: b.name, value: a.replace(bH, "\r\n") } }) : { name: b.name, value: c.replace(bH, "\r\n") } }).get() } }), f.each("ajaxStart ajaxStop ajaxComplete ajaxError ajaxSuccess ajaxSend".split(" "), function (a, b) { f.fn[b] = function (a) { return this.bind(b, a) } }), f.each(["get", "post"], function (a, c) { f[c] = function (a, d, e, g) { f.isFunction(d) && (g = g || e, e = d, d = b); return f.ajax({ type: c, url: a, data: d, success: e, dataType: g }) } }), f.extend({ getScript: function (a, c) { return f.get(a, b, c, "script") }, getJSON: function (a, b, c) { return f.get(a, b, c, "json") }, ajaxSetup: function (a, b) { b ? cb(a, f.ajaxSettings) : (b = a, a = f.ajaxSettings), cb(a, b); return a }, ajaxSettings: { url: bX, isLocal: bL.test(bY[1]), global: !0, type: "GET", contentType: "application/x-www-form-urlencoded", processData: !0, async: !0, accepts: { xml: "application/xml, text/xml", html: "text/html", text: "text/plain", json: "application/json, text/javascript", "*": bZ }, contents: { xml: /xml/, html: /html/, json: /json/ }, responseFields: { xml: "responseXML", text: "responseText" }, converters: { "* text": a.String, "text html": !0, "text json": f.parseJSON, "text xml": f.parseXML }, flatOptions: { context: !0, url: !0 } }, ajaxPrefilter: b_(bV), ajaxTransport: b_(bW), ajax: function (a, c) { function w(a, c, l, m) { if (s !== 2) { s = 2, q && clearTimeout(q), p = b, n = m || "", v.readyState = a > 0 ? 4 : 0; var o, r, u, w = c, x = l ? cd(d, v, l) : b, y, z; if (a >= 200 && a < 300 || a === 304) { if (d.ifModified) { if (y = v.getResponseHeader("Last-Modified")) f.lastModified[k] = y; if (z = v.getResponseHeader("Etag")) f.etag[k] = z } if (a === 304) w = "notmodified", o = !0; else try { r = ce(d, x), w = "success", o = !0 } catch (A) { w = "parsererror", u = A } } else { u = w; if (!w || a) w = "error", a < 0 && (a = 0) } v.status = a, v.statusText = "" + (c || w), o ? h.resolveWith(e, [r, w, v]) : h.rejectWith(e, [v, w, u]), v.statusCode(j), j = b, t && g.trigger("ajax" + (o ? "Success" : "Error"), [v, d, o ? r : u]), i.fireWith(e, [v, w]), t && (g.trigger("ajaxComplete", [v, d]), --f.active || f.event.trigger("ajaxStop")) } } typeof a == "object" && (c = a, a = b), c = c || {}; var d = f.ajaxSetup({}, c), e = d.context || d, g = e !== d && (e.nodeType || e instanceof f) ? f(e) : f.event, h = f.Deferred(), i = f.Callbacks("once memory"), j = d.statusCode || {}, k, l = {}, m = {}, n, o, p, q, r, s = 0, t, u, v = { readyState: 0, setRequestHeader: function (a, b) { if (!s) { var c = a.toLowerCase(); a = m[c] = m[c] || a, l[a] = b } return this }, getAllResponseHeaders: function () { return s === 2 ? n : null }, getResponseHeader: function (a) { var c; if (s === 2) { if (!o) { o = {}; while (c = bJ.exec(n)) o[c[1].toLowerCase()] = c[2] } c = o[a.toLowerCase()] } return c === b ? null : c }, overrideMimeType: function (a) { s || (d.mimeType = a); return this }, abort: function (a) { a = a || "abort", p && p.abort(a), w(0, a); return this } }; h.promise(v), v.success = v.done, v.error = v.fail, v.complete = i.add, v.statusCode = function (a) { if (a) { var b; if (s < 2) for (b in a) j[b] = [j[b], a[b]]; else b = a[v.status], v.then(b, b) } return this }, d.url = ((a || d.url) + "").replace(bI, "").replace(bN, bY[1] + "//"), d.dataTypes = f.trim(d.dataType || "*").toLowerCase().split(bR), d.crossDomain == null && (r = bT.exec(d.url.toLowerCase()), d.crossDomain = !(!r || r[1] == bY[1] && r[2] == bY[2] && (r[3] || (r[1] === "http:" ? 80 : 443)) == (bY[3] || (bY[1] === "http:" ? 80 : 443)))), d.data && d.processData && typeof d.data != "string" && (d.data = f.param(d.data, d.traditional)), ca(bV, d, c, v); if (s === 2) return !1; t = d.global, d.type = d.type.toUpperCase(), d.hasContent = !bM.test(d.type), t && f.active++ === 0 && f.event.trigger("ajaxStart"); if (!d.hasContent) { d.data && (d.url += (bO.test(d.url) ? "&" : "?") + d.data, delete d.data), k = d.url; if (d.cache === !1) { var x = f.now(), y = d.url.replace(bS, "$1_=" + x); d.url = y + (y === d.url ? (bO.test(d.url) ? "&" : "?") + "_=" + x : "") } } (d.data && d.hasContent && d.contentType !== !1 || c.contentType) && v.setRequestHeader("Content-Type", d.contentType), d.ifModified && (k = k || d.url, f.lastModified[k] && v.setRequestHeader("If-Modified-Since", f.lastModified[k]), f.etag[k] && v.setRequestHeader("If-None-Match", f.etag[k])), v.setRequestHeader("Accept", d.dataTypes[0] && d.accepts[d.dataTypes[0]] ? d.accepts[d.dataTypes[0]] + (d.dataTypes[0] !== "*" ? ", " + bZ + "; q=0.01" : "") : d.accepts["*"]); for (u in d.headers) v.setRequestHeader(u, d.headers[u]); if (d.beforeSend && (d.beforeSend.call(e, v, d) === !1 || s === 2)) { v.abort(); return !1 } for (u in { success: 1, error: 1, complete: 1 }) v[u](d[u]); p = ca(bW, d, c, v); if (!p) w(-1, "No Transport"); else { v.readyState = 1, t && g.trigger("ajaxSend", [v, d]), d.async && d.timeout > 0 && (q = setTimeout(function () { v.abort("timeout") }, d.timeout)); try { s = 1, p.send(l, w) } catch (z) { s < 2 ? w(-1, z) : f.error(z) } } return v }, param: function (a, c) { var d = [], e = function (a, b) { b = f.isFunction(b) ? b() : b, d[d.length] = encodeURIComponent(a) + "=" + encodeURIComponent(b) }; c === b && (c = f.ajaxSettings.traditional); if (f.isArray(a) || a.jquery && !f.isPlainObject(a)) f.each(a, function () { e(this.name, this.value) }); else for (var g in a) cc(g, a[g], c, e); return d.join("&").replace(bF, "+") } }), f.extend({ active: 0, lastModified: {}, etag: {} }); var cf = f.now(), cg = /(\=)\?(&|$)|\?\?/i; f.ajaxSetup({ jsonp: "callback", jsonpCallback: function () { return f.expando + "_" + cf++ } }), f.ajaxPrefilter("json jsonp", function (b, c, d) { var e = b.contentType === "application/x-www-form-urlencoded" && typeof b.data == "string"; if (b.dataTypes[0] === "jsonp" || b.jsonp !== !1 && (cg.test(b.url) || e && cg.test(b.data))) { var g, h = b.jsonpCallback = f.isFunction(b.jsonpCallback) ? b.jsonpCallback() : b.jsonpCallback, i = a[h], j = b.url, k = b.data, l = "$1" + h + "$2"; b.jsonp !== !1 && (j = j.replace(cg, l), b.url === j && (e && (k = k.replace(cg, l)), b.data === k && (j += (/\?/.test(j) ? "&" : "?") + b.jsonp + "=" + h))), b.url = j, b.data = k, a[h] = function (a) { g = [a] }, d.always(function () { a[h] = i, g && f.isFunction(i) && a[h](g[0]) }), b.converters["script json"] = function () { g || f.error(h + " was not called"); return g[0] }, b.dataTypes[0] = "json"; return "script" } }), f.ajaxSetup({ accepts: { script: "text/javascript, application/javascript, application/ecmascript, application/x-ecmascript" }, contents: { script: /javascript|ecmascript/ }, converters: { "text script": function (a) { f.globalEval(a); return a } } }), f.ajaxPrefilter("script", function (a) { a.cache === b && (a.cache = !1), a.crossDomain && (a.type = "GET", a.global = !1) }), f.ajaxTransport("script", function (a) { if (a.crossDomain) { var d, e = c.head || c.getElementsByTagName("head")[0] || c.documentElement; return { send: function (f, g) { d = c.createElement("script"), d.async = "async", a.scriptCharset && (d.charset = a.scriptCharset), d.src = a.url, d.onload = d.onreadystatechange = function (a, c) { if (c || !d.readyState || /loaded|complete/.test(d.readyState)) d.onload = d.onreadystatechange = null, e && d.parentNode && e.removeChild(d), d = b, c || g(200, "success") }, e.insertBefore(d, e.firstChild) }, abort: function () { d && d.onload(0, 1) } } } }); var ch = a.ActiveXObject ? function () { for (var a in cj) cj[a](0, 1) } : !1, ci = 0, cj; f.ajaxSettings.xhr = a.ActiveXObject ? function () { return !this.isLocal && ck() || cl() } : ck, function (a) { f.extend(f.support, { ajax: !!a, cors: !!a && "withCredentials" in a }) }(f.ajaxSettings.xhr()), f.support.ajax && f.ajaxTransport(function (c) { if (!c.crossDomain || f.support.cors) { var d; return { send: function (e, g) { var h = c.xhr(), i, j; c.username ? h.open(c.type, c.url, c.async, c.username, c.password) : h.open(c.type, c.url, c.async); if (c.xhrFields) for (j in c.xhrFields) h[j] = c.xhrFields[j]; c.mimeType && h.overrideMimeType && h.overrideMimeType(c.mimeType), !c.crossDomain && !e["X-Requested-With"] && (e["X-Requested-With"] = "XMLHttpRequest"); try { for (j in e) h.setRequestHeader(j, e[j]) } catch (k) { } h.send(c.hasContent && c.data || null), d = function (a, e) { var j, k, l, m, n; try { if (d && (e || h.readyState === 4)) { d = b, i && (h.onreadystatechange = f.noop, ch && delete cj[i]); if (e) h.readyState !== 4 && h.abort(); else { j = h.status, l = h.getAllResponseHeaders(), m = {}, n = h.responseXML, n && n.documentElement && (m.xml = n), m.text = h.responseText; try { k = h.statusText } catch (o) { k = "" } !j && c.isLocal && !c.crossDomain ? j = m.text ? 200 : 404 : j === 1223 && (j = 204) } } } catch (p) { e || g(-1, p) } m && g(j, k, m, l) }, !c.async || h.readyState === 4 ? d() : (i = ++ci, ch && (cj || (cj = {}, f(a).unload(ch)), cj[i] = d), h.onreadystatechange = d) }, abort: function () { d && d(0, 1) } } } }); var cm = {}, cn, co, cp = /^(?:toggle|show|hide)$/, cq = /^([+\-]=)?([\d+.\-]+)([a-z%]*)$/i, cr, cs = [["height", "marginTop", "marginBottom", "paddingTop", "paddingBottom"], ["width", "marginLeft", "marginRight", "paddingLeft", "paddingRight"], ["opacity"]], ct; f.fn.extend({ show: function (a, b, c) { var d, e; if (a || a === 0) return this.animate(cw("show", 3), a, b, c); for (var g = 0, h = this.length; g < h; g++)d = this[g], d.style && (e = d.style.display, !f._data(d, "olddisplay") && e === "none" && (e = d.style.display = ""), e === "" && f.css(d, "display") === "none" && f._data(d, "olddisplay", cx(d.nodeName))); for (g = 0; g < h; g++) { d = this[g]; if (d.style) { e = d.style.display; if (e === "" || e === "none") d.style.display = f._data(d, "olddisplay") || "" } } return this }, hide: function (a, b, c) { if (a || a === 0) return this.animate(cw("hide", 3), a, b, c); var d, e, g = 0, h = this.length; for (; g < h; g++)d = this[g], d.style && (e = f.css(d, "display"), e !== "none" && !f._data(d, "olddisplay") && f._data(d, "olddisplay", e)); for (g = 0; g < h; g++)this[g].style && (this[g].style.display = "none"); return this }, _toggle: f.fn.toggle, toggle: function (a, b, c) { var d = typeof a == "boolean"; f.isFunction(a) && f.isFunction(b) ? this._toggle.apply(this, arguments) : a == null || d ? this.each(function () { var b = d ? a : f(this).is(":hidden"); f(this)[b ? "show" : "hide"]() }) : this.animate(cw("toggle", 3), a, b, c); return this }, fadeTo: function (a, b, c, d) { return this.filter(":hidden").css("opacity", 0).show().end().animate({ opacity: b }, a, c, d) }, animate: function (a, b, c, d) { function g() { e.queue === !1 && f._mark(this); var b = f.extend({}, e), c = this.nodeType === 1, d = c && f(this).is(":hidden"), g, h, i, j, k, l, m, n, o; b.animatedProperties = {}; for (i in a) { g = f.camelCase(i), i !== g && (a[g] = a[i], delete a[i]), h = a[g], f.isArray(h) ? (b.animatedProperties[g] = h[1], h = a[g] = h[0]) : b.animatedProperties[g] = b.specialEasing && b.specialEasing[g] || b.easing || "swing"; if (h === "hide" && d || h === "show" && !d) return b.complete.call(this); c && (g === "height" || g === "width") && (b.overflow = [this.style.overflow, this.style.overflowX, this.style.overflowY], f.css(this, "display") === "inline" && f.css(this, "float") === "none" && (!f.support.inlineBlockNeedsLayout || cx(this.nodeName) === "inline" ? this.style.display = "inline-block" : this.style.zoom = 1)) } b.overflow != null && (this.style.overflow = "hidden"); for (i in a) j = new f.fx(this, b, i), h = a[i], cp.test(h) ? (o = f._data(this, "toggle" + i) || (h === "toggle" ? d ? "show" : "hide" : 0), o ? (f._data(this, "toggle" + i, o === "show" ? "hide" : "show"), j[o]()) : j[h]()) : (k = cq.exec(h), l = j.cur(), k ? (m = parseFloat(k[2]), n = k[3] || (f.cssNumber[i] ? "" : "px"), n !== "px" && (f.style(this, i, (m || 1) + n), l = (m || 1) / j.cur() * l, f.style(this, i, l + n)), k[1] && (m = (k[1] === "-=" ? -1 : 1) * m + l), j.custom(l, m, n)) : j.custom(l, h, "")); return !0 } var e = f.speed(b, c, d); if (f.isEmptyObject(a)) return this.each(e.complete, [!1]); a = f.extend({}, a); return e.queue === !1 ? this.each(g) : this.queue(e.queue, g) }, stop: function (a, c, d) { typeof a != "string" && (d = c, c = a, a = b), c && a !== !1 && this.queue(a || "fx", []); return this.each(function () { function h(a, b, c) { var e = b[c]; f.removeData(a, c, !0), e.stop(d) } var b, c = !1, e = f.timers, g = f._data(this); d || f._unmark(!0, this); if (a == null) for (b in g) g[b].stop && b.indexOf(".run") === b.length - 4 && h(this, g, b); else g[b = a + ".run"] && g[b].stop && h(this, g, b); for (b = e.length; b--;)e[b].elem === this && (a == null || e[b].queue === a) && (d ? e[b](!0) : e[b].saveState(), c = !0, e.splice(b, 1)); (!d || !c) && f.dequeue(this, a) }) } }), f.each({ slideDown: cw("show", 1), slideUp: cw("hide", 1), slideToggle: cw("toggle", 1), fadeIn: { opacity: "show" }, fadeOut: { opacity: "hide" }, fadeToggle: { opacity: "toggle" } }, function (a, b) { f.fn[a] = function (a, c, d) { return this.animate(b, a, c, d) } }), f.extend({ speed: function (a, b, c) { var d = a && typeof a == "object" ? f.extend({}, a) : { complete: c || !c && b || f.isFunction(a) && a, duration: a, easing: c && b || b && !f.isFunction(b) && b }; d.duration = f.fx.off ? 0 : typeof d.duration == "number" ? d.duration : d.duration in f.fx.speeds ? f.fx.speeds[d.duration] : f.fx.speeds._default; if (d.queue == null || d.queue === !0) d.queue = "fx"; d.old = d.complete, d.complete = function (a) { f.isFunction(d.old) && d.old.call(this), d.queue ? f.dequeue(this, d.queue) : a !== !1 && f._unmark(this) }; return d }, easing: { linear: function (a, b, c, d) { return c + d * a }, swing: function (a, b, c, d) { return (-Math.cos(a * Math.PI) / 2 + .5) * d + c } }, timers: [], fx: function (a, b, c) { this.options = b, this.elem = a, this.prop = c, b.orig = b.orig || {} } }), f.fx.prototype = { update: function () { this.options.step && this.options.step.call(this.elem, this.now, this), (f.fx.step[this.prop] || f.fx.step._default)(this) }, cur: function () { if (this.elem[this.prop] != null && (!this.elem.style || this.elem.style[this.prop] == null)) return this.elem[this.prop]; var a, b = f.css(this.elem, this.prop); return isNaN(a = parseFloat(b)) ? !b || b === "auto" ? 0 : b : a }, custom: function (a, c, d) { function h(a) { return e.step(a) } var e = this, g = f.fx; this.startTime = ct || cu(), this.end = c, this.now = this.start = a, this.pos = this.state = 0, this.unit = d || this.unit || (f.cssNumber[this.prop] ? "" : "px"), h.queue = this.options.queue, h.elem = this.elem, h.saveState = function () { e.options.hide && f._data(e.elem, "fxshow" + e.prop) === b && f._data(e.elem, "fxshow" + e.prop, e.start) }, h() && f.timers.push(h) && !cr && (cr = setInterval(g.tick, g.interval)) }, show: function () { var a = f._data(this.elem, "fxshow" + this.prop); this.options.orig[this.prop] = a || f.style(this.elem, this.prop), this.options.show = !0, a !== b ? this.custom(this.cur(), a) : this.custom(this.prop === "width" || this.prop === "height" ? 1 : 0, this.cur()), f(this.elem).show() }, hide: function () { this.options.orig[this.prop] = f._data(this.elem, "fxshow" + this.prop) || f.style(this.elem, this.prop), this.options.hide = !0, this.custom(this.cur(), 0) }, step: function (a) { var b, c, d, e = ct || cu(), g = !0, h = this.elem, i = this.options; if (a || e >= i.duration + this.startTime) { this.now = this.end, this.pos = this.state = 1, this.update(), i.animatedProperties[this.prop] = !0; for (b in i.animatedProperties) i.animatedProperties[b] !== !0 && (g = !1); if (g) { i.overflow != null && !f.support.shrinkWrapBlocks && f.each(["", "X", "Y"], function (a, b) { h.style["overflow" + b] = i.overflow[a] }), i.hide && f(h).hide(); if (i.hide || i.show) for (b in i.animatedProperties) f.style(h, b, i.orig[b]), f.removeData(h, "fxshow" + b, !0), f.removeData(h, "toggle" + b, !0); d = i.complete, d && (i.complete = !1, d.call(h)) } return !1 } i.duration == Infinity ? this.now = e : (c = e - this.startTime, this.state = c / i.duration, this.pos = f.easing[i.animatedProperties[this.prop]](this.state, c, 0, 1, i.duration), this.now = this.start + (this.end - this.start) * this.pos), this.update(); return !0 } }, f.extend(f.fx, { tick: function () { var a, b = f.timers, c = 0; for (; c < b.length; c++)a = b[c], !a() && b[c] === a && b.splice(c--, 1); b.length || f.fx.stop() }, interval: 13, stop: function () { clearInterval(cr), cr = null }, speeds: { slow: 600, fast: 200, _default: 400 }, step: { opacity: function (a) { f.style(a.elem, "opacity", a.now) }, _default: function (a) { a.elem.style && a.elem.style[a.prop] != null ? a.elem.style[a.prop] = a.now + a.unit : a.elem[a.prop] = a.now } } }), f.each(["width", "height"], function (a, b) { f.fx.step[b] = function (a) { f.style(a.elem, b, Math.max(0, a.now)) } }), f.expr && f.expr.filters && (f.expr.filters.animated = function (a) { return f.grep(f.timers, function (b) { return a === b.elem }).length }); var cy = /^t(?:able|d|h)$/i, cz = /^(?:body|html)$/i; "getBoundingClientRect" in c.documentElement ? f.fn.offset = function (a) { var b = this[0], c; if (a) return this.each(function (b) { f.offset.setOffset(this, a, b) }); if (!b || !b.ownerDocument) return null; if (b === b.ownerDocument.body) return f.offset.bodyOffset(b); try { c = b.getBoundingClientRect() } catch (d) { } var e = b.ownerDocument, g = e.documentElement; if (!c || !f.contains(g, b)) return c ? { top: c.top, left: c.left } : { top: 0, left: 0 }; var h = e.body, i = cA(e), j = g.clientTop || h.clientTop || 0, k = g.clientLeft || h.clientLeft || 0, l = i.pageYOffset || f.support.boxModel && g.scrollTop || h.scrollTop, m = i.pageXOffset || f.support.boxModel && g.scrollLeft || h.scrollLeft, n = c.top + l - j, o = c.left + m - k; return { top: n, left: o } } : f.fn.offset = function (a) { var b = this[0]; if (a) return this.each(function (b) { f.offset.setOffset(this, a, b) }); if (!b || !b.ownerDocument) return null; if (b === b.ownerDocument.body) return f.offset.bodyOffset(b); var c, d = b.offsetParent, e = b, g = b.ownerDocument, h = g.documentElement, i = g.body, j = g.defaultView, k = j ? j.getComputedStyle(b, null) : b.currentStyle, l = b.offsetTop, m = b.offsetLeft; while ((b = b.parentNode) && b !== i && b !== h) { if (f.support.fixedPosition && k.position === "fixed") break; c = j ? j.getComputedStyle(b, null) : b.currentStyle, l -= b.scrollTop, m -= b.scrollLeft, b === d && (l += b.offsetTop, m += b.offsetLeft, f.support.doesNotAddBorder && (!f.support.doesAddBorderForTableAndCells || !cy.test(b.nodeName)) && (l += parseFloat(c.borderTopWidth) || 0, m += parseFloat(c.borderLeftWidth) || 0), e = d, d = b.offsetParent), f.support.subtractsBorderForOverflowNotVisible && c.overflow !== "visible" && (l += parseFloat(c.borderTopWidth) || 0, m += parseFloat(c.borderLeftWidth) || 0), k = c } if (k.position === "relative" || k.position === "static") l += i.offsetTop, m += i.offsetLeft; f.support.fixedPosition && k.position === "fixed" && (l += Math.max(h.scrollTop, i.scrollTop), m += Math.max(h.scrollLeft, i.scrollLeft)); return { top: l, left: m } }, f.offset = { bodyOffset: function (a) { var b = a.offsetTop, c = a.offsetLeft; f.support.doesNotIncludeMarginInBodyOffset && (b += parseFloat(f.css(a, "marginTop")) || 0, c += parseFloat(f.css(a, "marginLeft")) || 0); return { top: b, left: c } }, setOffset: function (a, b, c) { var d = f.css(a, "position"); d === "static" && (a.style.position = "relative"); var e = f(a), g = e.offset(), h = f.css(a, "top"), i = f.css(a, "left"), j = (d === "absolute" || d === "fixed") && f.inArray("auto", [h, i]) > -1, k = {}, l = {}, m, n; j ? (l = e.position(), m = l.top, n = l.left) : (m = parseFloat(h) || 0, n = parseFloat(i) || 0), f.isFunction(b) && (b = b.call(a, c, g)), b.top != null && (k.top = b.top - g.top + m), b.left != null && (k.left = b.left - g.left + n), "using" in b ? b.using.call(a, k) : e.css(k) } }, f.fn.extend({ position: function () { if (!this[0]) return null; var a = this[0], b = this.offsetParent(), c = this.offset(), d = cz.test(b[0].nodeName) ? { top: 0, left: 0 } : b.offset(); c.top -= parseFloat(f.css(a, "marginTop")) || 0, c.left -= parseFloat(f.css(a, "marginLeft")) || 0, d.top += parseFloat(f.css(b[0], "borderTopWidth")) || 0, d.left += parseFloat(f.css(b[0], "borderLeftWidth")) || 0; return { top: c.top - d.top, left: c.left - d.left } }, offsetParent: function () { return this.map(function () { var a = this.offsetParent || c.body; while (a && !cz.test(a.nodeName) && f.css(a, "position") === "static") a = a.offsetParent; return a }) } }), f.each(["Left", "Top"], function (a, c) { var d = "scroll" + c; f.fn[d] = function (c) { var e, g; if (c === b) { e = this[0]; if (!e) return null; g = cA(e); return g ? "pageXOffset" in g ? g[a ? "pageYOffset" : "pageXOffset"] : f.support.boxModel && g.document.documentElement[d] || g.document.body[d] : e[d] } return this.each(function () { g = cA(this), g ? g.scrollTo(a ? f(g).scrollLeft() : c, a ? c : f(g).scrollTop()) : this[d] = c }) } }), f.each(["Height", "Width"], function (a, c) { var d = c.toLowerCase(); f.fn["inner" + c] = function () { var a = this[0]; return a ? a.style ? parseFloat(f.css(a, d, "padding")) : this[d]() : null }, f.fn["outer" + c] = function (a) { var b = this[0]; return b ? b.style ? parseFloat(f.css(b, d, a ? "margin" : "border")) : this[d]() : null }, f.fn[d] = function (a) { var e = this[0]; if (!e) return a == null ? null : this; if (f.isFunction(a)) return this.each(function (b) { var c = f(this); c[d](a.call(this, b, c[d]())) }); if (f.isWindow(e)) { var g = e.document.documentElement["client" + c], h = e.document.body; return e.document.compatMode === "CSS1Compat" && g || h && h["client" + c] || g } if (e.nodeType === 9) return Math.max(e.documentElement["client" + c], e.body["scroll" + c], e.documentElement["scroll" + c], e.body["offset" + c], e.documentElement["offset" + c]); if (a === b) { var i = f.css(e, d), j = parseFloat(i); return f.isNumeric(j) ? j : i } return this.css(d, typeof a == "string" ? a : a + "px") } }), a.jQuery = a.$ = f
+})(window);
diff --git a/DocTools/TplFile/chm/list.cshtml b/DocTools/TplFile/chm/list.cshtml
new file mode 100644
index 0000000..1f7773a
--- /dev/null
+++ b/DocTools/TplFile/chm/list.cshtml
@@ -0,0 +1,159 @@
+
+
+
+
+
数据库目录
+
+
+
+
+ @if (Model.Tables != null && Model.Tables.Count > 0)
+ {
+
+
+ 表
+
+
+ | 序号 |
+ 表名 |
+ 表说明 |
+
+
+ @foreach (var item in Model.Tables)
+ {
+
+ | @item.TableOrder |
+
+ @item.TableName
+ |
+ @(string.IsNullOrEmpty(item.Comment)?" " : item.Comment) |
+
+ }
+
+ }
+
+ @if (Model.Views != null && Model.Views.Count > 0)
+ {
+
+
+ 视图
+
+
+ | 序号 |
+ 视图名称 |
+
+
+ @{ var vwIndex = 1; }
+ @foreach (var item in Model.Views)
+ {
+
+ | @vwIndex |
+
+ @item.Key
+ |
+
+ vwIndex++;
+ }
+
+
+ }
+
+ @if (Model.Procs != null && Model.Procs.Count > 0)
+ {
+
+
+ 存储过程
+
+
+ | 序号 |
+ 存储过程名称 |
+
+
+ @{ var procIndex = 1; }
+ @foreach (var item in Model.Procs)
+ {
+
+ | @procIndex |
+
+ @item.Key
+ |
+
+ procIndex++;
+ }
+
+
+ }
+
+
+
+
+
diff --git a/DocTools/TplFile/chm/sqlcode.cshtml b/DocTools/TplFile/chm/sqlcode.cshtml
new file mode 100644
index 0000000..8e3ec7c
--- /dev/null
+++ b/DocTools/TplFile/chm/sqlcode.cshtml
@@ -0,0 +1,84 @@
+
+
+
+
+
@Model.CodeName
+
+
+
+
+
+
@Model.CodeName
+
@Model.StyleContent
+
+
+
diff --git a/DocTools/TplFile/chm/table.cshtml b/DocTools/TplFile/chm/table.cshtml
new file mode 100644
index 0000000..485f875
--- /dev/null
+++ b/DocTools/TplFile/chm/table.cshtml
@@ -0,0 +1,134 @@
+
+
+
+
+
@Model.TableName
+
+
+
+
+
+
+
+
+
+
+
+ @Model.TableName
+ @Model.Comment
+
+ 返回目录
+
+
+
+ | 序号 |
+ 列名 |
+ 数据类型 |
+ 长度 |
+ 小数位数 |
+ 主键 |
+ @if (!Model.DBType.StartsWith("Oracle"))
+ {
+ 自增 |
+ }
+ 允许空 |
+ 默认值 |
+ 列说明 |
+
+ @{
+ var index = 1;
+ }
+ @foreach (var item in Model.Columns)
+ {
+
+ | @index |
+ @item.ColumnName |
+ @item.ColumnTypeName |
+ @(string.IsNullOrWhiteSpace(item.Length)? " ":item.Length) |
+ @(string.IsNullOrWhiteSpace(item.Scale)? " ":item.Scale) |
+ @(string.IsNullOrWhiteSpace(item.IsPK)?" ": item.IsPK) |
+
+ @if (!Model.DBType.StartsWith("Oracle"))
+ {
+ @(string.IsNullOrWhiteSpace(item.IsIdentity) ?" ": item.IsIdentity) |
+ }
+
+ @(string.IsNullOrWhiteSpace(item.CanNull) ?" ": item.CanNull) |
+ @(string.IsNullOrWhiteSpace(item.DefaultVal) ?" ": item.DefaultVal) |
+ @(string.IsNullOrWhiteSpace(item.Comment) ?" ": item.Comment) |
+
+ index++;
+ }
+
+ |
+
+
+
+
+
+
diff --git a/DocTools/TplFile/html/html.cshtml b/DocTools/TplFile/html/html.cshtml
new file mode 100644
index 0000000..534c6e3
--- /dev/null
+++ b/DocTools/TplFile/html/html.cshtml
@@ -0,0 +1,825 @@
+
+
+
+
+
@Model.DBName 数据库文档_v1.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
数据库表目录
+
+
+
+ 表
+ | 序号 | 表名 | 表说明 |
+ @for (int j = 0; j < Model.Tables.Count; j++)
+ {
+ var item = Model.Tables[j];
+
+ | @( j + 1 ) |
+ @item.TableName |
+ @(!string.IsNullOrWhiteSpace(item.Comment) ? item.Comment : " ") |
+
+ }
+
+
+ @if (Model.Views.Count > 0)
+ {
+
+ 视图
+ | 序号 | 视图名称 |
+
+ @{ var index = 1; }
+ @foreach (var item in Model.Views)
+ {
+
+ | @index |
+ @item.Key |
+
+ index++;
+ }
+
+
+ }
+
+ @if (Model.Procs.Count > 0)
+ {
+
+ 存储过程
+ | 序号 | 存储过程名称 |
+
+ @{ var index = 1; }
+ @foreach (var item in Model.Procs)
+ {
+
+ | @index |
+ @item.Key |
+
+ index++;
+ }
+
+
+ }
+
+
+
+
+ @foreach (var item in Model.Tables)
+ {
+
+
+ 表名：@item.TableName
+
返回目录
+
+
表注释：@item.Comment
+
+
+
+
+ | 序号 |
+ 列名 |
+ 数据类型 |
+ 长度 |
+ 小数位数 |
+ 主键 |
+
+ @if (!item.DBType.StartsWith("Oracle"))
+ {
+ 自增 |
+ }
+
+ 允许空 |
+ 默认值 |
+ 列说明 |
+
+
+ @foreach (var column in item.Columns)
+ {
+
+ | @column.ColumnOrder |
+ @column.ColumnName |
+ @column.ColumnTypeName |
+ @column.Length |
+ @column.Scale |
+ @column.IsPK |
+
+ @if (!item.DBType.StartsWith("Oracle"))
+ {
+ @column.IsIdentity |
+ }
+
+ @column.CanNull |
+ @column.DefaultVal |
+ @column.Comment |
+
+ }
+
+
+
+
+ }
+
+ @if (Model.Views.Count > 0)
+ {
+ foreach (var item in Model.Views)
+ {
+
+
+ 视图名称：@item.Key
+
返回目录
+
+
+
+ }
+ }
+
+ @if (Model.Procs.Count > 0)
+ {
+ foreach (var item in Model.Procs)
+ {
+
+
+ 存储过程名称：@item.Key
+
返回目录
+
+
+
+ }
+ }
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/DocTools/TplFile/pdf/msyh.ttf b/DocTools/TplFile/pdf/msyh.ttf
new file mode 100644
index 0000000..ea3c090
Binary files /dev/null and b/DocTools/TplFile/pdf/msyh.ttf differ
diff --git a/DocTools/app.config b/DocTools/app.config
new file mode 100644
index 0000000..ef94230
--- /dev/null
+++ b/DocTools/app.config
@@ -0,0 +1,19 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/DocTools/lib/Aspose.Words.dll b/DocTools/lib/Aspose.Words.dll
new file mode 100644
index 0000000..807bc9e
Binary files /dev/null and b/DocTools/lib/Aspose.Words.dll differ
diff --git a/DocTools/lib/EPPlus.dll b/DocTools/lib/EPPlus.dll
new file mode 100644
index 0000000..39e6295
Binary files /dev/null and b/DocTools/lib/EPPlus.dll differ
diff --git a/DocTools/packages.config b/DocTools/packages.config
new file mode 100644
index 0000000..1bed050
--- /dev/null
+++ b/DocTools/packages.config
@@ -0,0 +1,17 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/LICENSE b/LICENSE
new file mode 100644
index 0000000..a842010
--- /dev/null
+++ b/LICENSE
@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2018 51try.top
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
diff --git a/MJTop.Data/BWofter.Converters/Collections/Generic/DictionaryConverter.cs b/MJTop.Data/BWofter.Converters/Collections/Generic/DictionaryConverter.cs
new file mode 100644
index 0000000..8e26233
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Collections/Generic/DictionaryConverter.cs
@@ -0,0 +1,116 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Collections.Generic
+{
+ using BWofter.Converters.Data;
+ using BWofter.Converters.Extensions;
+ using System;
+ using System.Collections.Generic;
+ using System.Data;
+ using System.Linq;
+ ///
A static class used to convert dictionaries into entities.
+ ///
The entity type to convert to.
+ public static class DictionaryConverter
where TEntity : class, new()
+ {
+ /// Iterates over the of keys and values in the
+ /// , mapping their fields to the entity type.
+ /// The instance of keys and values
+ /// to map to the entity type.
+ /// An instance of the entity type.
+ public static TEntity ToEntity(IDictionary dictionary)
+ {
+ if (dictionary == null) throw new ArgumentNullException(nameof(dictionary));
+ return ToEntities(new[] { dictionary }).FirstOrDefault();
+ }
+ /// Iterates over the of keys and values in the
+ /// , mapping their fields to the entity type.
+ /// The instance of keys and values
+ /// to map to the entity type.
+ /// The to map the keys to properties.
+ /// An instance of the entity type.
+ public static TEntity ToEntity(IDictionary dictionary, IDictionary columnToMemberMap)
+ {
+ if (dictionary == null) throw new ArgumentNullException(nameof(dictionary));
+ if (columnToMemberMap == null) throw new ArgumentNullException(nameof(columnToMemberMap));
+ return ToEntities(new[] { dictionary }, columnToMemberMap).FirstOrDefault();
+ }
+ /// Iterates over the of keys and values in the
+ /// , mapping their fields to the entity type.
+ /// The instances of keys and values
+ /// to map to the entity type.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(IEnumerable> dictionaries)
+ {
+ IDictionary first = dictionaries?.FirstOrDefault();
+ if (dictionaries == null) throw new ArgumentNullException(nameof(dictionaries));
+ if (first == null) throw new ArgumentException($"Parameter {nameof(dictionaries)} should have at least 1 value, 0 given.");
+ //Get a table definition for the dictionaries then call the data table converter.
+ DataTable dataTable = first.AsDataTableDefinition();
+ return DataTableConverter.ToEntities(dictionaries.Select(d => DictionaryToDataRow(d, dataTable)));
+ }
+ /// Iterates over the of keys and values in the
+ /// , mapping their fields to the entity type.
+ /// The instances of keys and values
+ /// to map to the entity type.
+ /// The to map the keys to properties.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(IEnumerable> dictionaries, IDictionary columnToMemberMap)
+ {
+ IDictionary first = dictionaries?.FirstOrDefault();
+ if (dictionaries == null) throw new ArgumentNullException(nameof(dictionaries));
+ if (columnToMemberMap == null) throw new ArgumentNullException(nameof(columnToMemberMap));
+ if (first == null) throw new ArgumentException($"Parameter {nameof(dictionaries)} should have at least 1 value, 0 given.");
+ //Get a table definition for the dictionaries then call the data table converter.
+ DataTable dataTable = first.AsDataTableDefinition();
+ //Converts the sting/string column to member map into a data column/string column to member map.
+ Dictionary translatedColumnToMemberMap = new Dictionary();
+ foreach (KeyValuePair entry in columnToMemberMap)
+ {
+ translatedColumnToMemberMap.Add(dataTable.Columns[entry.Key], entry.Value);
+ }
+ return DataTableConverter.ToEntities(dictionaries.Select(d => DictionaryToDataRow(d, dataTable)), translatedColumnToMemberMap);
+ }
+ //Generates a new data row for each dictionary in the the ienumerable.
+ private static DataRow DictionaryToDataRow(IDictionary rowData, DataTable dataTable)
+ {
+ //Create a new data row and add it to the data table.
+ DataRow dataRow = dataTable.NewRow();
+ dataTable.Rows.Add(dataRow);
+ //Iterate over the entries in the dictionary and add them to the row.
+ foreach (KeyValuePair entry in rowData)
+ {
+ dataRow[entry.Key] = entry.Value;
+ }
+ return dataRow;
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Data/DataTableConverter.cs b/MJTop.Data/BWofter.Converters/Data/DataTableConverter.cs
new file mode 100644
index 0000000..c855f7c
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Data/DataTableConverter.cs
@@ -0,0 +1,279 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Data
+{
+ using BWofter.Converters.EqualityComparers;
+ using BWofter.Converters.Expressions;
+ using BWofter.Converters.Extensions;
+ using System;
+ using System.Collections.Concurrent;
+ using System.Collections.Generic;
+ using System.Data;
+ using System.Linq;
+ using System.Linq.Expressions;
+ using System.Reflection;
+ /// A static class used to convert data tables into entities.
+ /// The entity type to convert to.
+ public static class DataTableConverter where TEntity : class, new()
+ {
+ private static readonly Type type = typeof(TEntity);
+ private static readonly ConcurrentDictionary, Func> converters = new ConcurrentDictionary, Func>(StringCollectionComparer.GetInstance());
+ /// Iterates over the values in the , mapping their fields
+ /// to the entity type.
+ /// The to map to the entity type.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(DataTable dataTable)
+ {
+ if (dataTable == null) throw new ArgumentNullException(nameof(dataTable));
+ return ToEntities(dataTable, new Dictionary(dataTable.Columns.Select(GetDataColumnKeyValuePair).ToDictionary()));
+ }
+ /// Iterates over the values in the , mapping their fields
+ /// to the entity type.
+ /// The to map to the entity type.
+ /// The to map the values to properties.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(DataTable dataTable, IDictionary columnToMemberMap)
+ {
+ if (dataTable == null) throw new ArgumentNullException(nameof(dataTable));
+ if (columnToMemberMap == null) throw new ArgumentNullException(nameof(columnToMemberMap));
+ Func converter = GetConverter(columnToMemberMap);
+ if (converter == null) throw new InvalidOperationException($"Unable to generate a converter for the data table. This could be due to a bug in the expression generator.");
+ //Iterate over the data rows in the data table, yielding the results back to the caller.
+ foreach (DataRow row in dataTable.Rows)
+ {
+ yield return converter(row);
+ }
+ }
+ /// Iterates over the values in , mapping their fields
+ /// to the entity type.
+ /// The to map to the entity type.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(DataRowCollection dataRows)
+ {
+ if (dataRows == null) throw new ArgumentNullException(nameof(dataRows));
+ if (dataRows.Count == 0) throw new ArgumentException($"Parameter {nameof(dataRows)} should have at least 1 value, 0 given.");
+ return ToEntities(dataRows, dataRows[0].Table.Columns.Select(GetDataColumnKeyValuePair).ToDictionary());
+ }
+ /// Iterates over the values in , mapping their fields
+ /// to the entity type.
+ /// The to map to the entity type.
+ /// The to map the values to properties.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(DataRowCollection dataRows, IDictionary columnToMemberMap)
+ {
+ if (dataRows == null) throw new ArgumentNullException(nameof(dataRows));
+ if (columnToMemberMap == null) throw new ArgumentNullException(nameof(columnToMemberMap));
+ Func converter = GetConverter(columnToMemberMap);
+ if (converter == null) throw new InvalidOperationException($"Unable to generate a converter for the data table. This could be due to a bug in the expression generator.");
+ //Iterate over the data rows in the data table, yielding the results back to the caller.
+ foreach (DataRow row in dataRows)
+ {
+ yield return converter(row);
+ }
+ }
+ /// Iterates over the values in , mapping their fields
+ /// to the entity type.
+ /// The of values to map to the entity type.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(IEnumerable dataRows)
+ {
+ DataRow first = dataRows?.FirstOrDefault();
+ if (dataRows == null) throw new ArgumentNullException(nameof(dataRows));
+ if (first == null) throw new ArgumentException($"Parameter {nameof(dataRows)} should have at least 1 value, 0 given.");
+ return ToEntities(dataRows, first.Table.Columns.Select(GetDataColumnKeyValuePair).ToDictionary());
+ }
+ /// Iterates over the values in , mapping their fields
+ /// to the entity type.
+ /// The of values to map to the entity type.
+ /// The to map the values to properties.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(IEnumerable dataRows, IDictionary columnToMemberMap)
+ {
+ if (dataRows == null) throw new ArgumentNullException(nameof(dataRows));
+ if (columnToMemberMap == null) throw new ArgumentNullException(nameof(columnToMemberMap));
+ Func converter = GetConverter(columnToMemberMap);
+ if (converter == null) throw new InvalidOperationException($"Unable to generate a converter for the data table. This could be due to a bug in the expression generator.");
+ //Iterate over the data rows in the data table, yielding the results back to the caller.
+ foreach (DataRow row in dataRows)
+ {
+ yield return converter(row);
+ }
+ }
+ /// Iterates over the values in , mapping their fields
+ /// to the entity type.
+ /// The of values to map to the entity type.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(params DataRow[] dataRows)
+ {
+ if (dataRows == null) throw new ArgumentNullException(nameof(dataRows));
+ if (dataRows.Length == 0) throw new ArgumentException($"Parameter {nameof(dataRows)} should have at least 1 value, 0 given.");
+ return ToEntities(dataRows, dataRows[0].Table.Columns.Select(GetDataColumnKeyValuePair).ToDictionary());
+ }
+ /// Iterates over the values in , mapping their fields
+ /// to the entity type.
+ /// The to map the values to properties.
+ /// The of values to map to the entity type.
+ /// A yielded instance of the entity type.
+ public static IEnumerable ToEntities(IDictionary columnToMemberMap, params DataRow[] dataRows)
+ {
+ if (dataRows == null) throw new ArgumentNullException(nameof(dataRows));
+ if (columnToMemberMap == null) throw new ArgumentNullException(nameof(columnToMemberMap));
+ Func converter = GetConverter(columnToMemberMap);
+ if (converter == null) throw new InvalidOperationException($"Unable to generate a converter for the data table. This could be due to a bug in the expression generator.");
+ //Iterate over the data rows in the data table, yielding the results back to the caller.
+ foreach (DataRow row in dataRows)
+ {
+ yield return converter(row);
+ }
+ }
+ //Creates a cached generator for the converter to use for all data tables with a matching set of data columns. Due to our assumption that data types are loose in
+ //data tables, this will generate an extremely generic converter that doesn't statically use the data table's data typing.
+ private static Func GetConverter(IDictionary columnToMemberMap)
+ {
+ List columnNames = columnToMemberMap.Select(k => k.Key.ColumnName).ToList();
+ if (!converters.TryGetValue(columnNames, out Func value))
+ {
+ NewExpression instantiate = Expression.New(type);
+ ParameterExpression dataRow = Expression.Parameter(typeof(DataRow), "dataRow");
+ //Declare a dictionary to prevent creating more than 1 instance of a temporary parser type.
+ ConcurrentDictionary parameters = new ConcurrentDictionary();
+ List memberBindings = new List();
+ //Iterate over the column map and generate the expressions needed.
+ foreach (KeyValuePair columnToMember in columnToMemberMap)
+ {
+ if (TryGetMemberInfo(columnToMember.Value, columnToMember.Key.Table.CaseSensitive, out MemberInfo memberInfo))
+ {
+ //Get a member expression. This is used for type resolution.
+ Type memberType = Expression.MakeMemberAccess(instantiate, memberInfo).Type,
+ realType = Nullable.GetUnderlyingType(memberType) ?? memberType;
+ //Get the data column expression used to access the data row field.
+ DataColumnExpression dataColumn = DataExpression.DataColumn(DataExpression.DataTable(dataRow), columnToMember.Key.ColumnName);
+ //Get the is null expression used to determine if the data field is null.
+ DataFieldIsNullExpression callDataFieldIsNull = DataExpression.DataFieldIsNull(dataRow, dataColumn);
+ ConditionalExpression dataFieldIsNull = Expression.Condition(callDataFieldIsNull, Expression.Default(memberType),
+ Expression.Default(memberType));
+ //Get the is assignable from expression used to determine if the data column can be converted to the member type.
+ IsAssignableFromExpression callIsAssignableFrom = DataExpression.IsAssignableFrom(DataExpression.DataType(dataColumn), memberType);
+ //Get the is assignable from true result. If member type is string, then call the trim method on the string.
+ Expression isAssignableFromTrue = Expression.Convert(DataExpression.DataField(dataRow, dataColumn), memberType);
+ if (typeof(string).IsAssignableFrom(memberType))
+ {
+ isAssignableFromTrue = Expression.Call(isAssignableFromTrue, "Trim", Type.EmptyTypes);
+ }
+ //Get the conditional expression used to process the data column type conversion.
+ ConditionalExpression isAssignableFrom = Expression.Condition(callIsAssignableFrom,
+ isAssignableFromTrue, Expression.Default(memberType));
+ if (realType.GetMethods().Any(m => m.Name == "TryParse"))
+ {
+ //Get the is string parameter expression used for try parsing.
+ ParameterExpression stringLocal = parameters.GetOrAdd(typeof(string), Expression.Variable(typeof(string))),
+ outLocal = parameters.GetOrAdd(realType, Expression.Variable(realType));
+ //Get the type is assign and try parse expressions used for try parsing.
+ TypeIsAssignExpression typeIsAssign = DataExpression.TypeIsAssign(
+ DataExpression.DataField(dataRow, dataColumn), stringLocal);
+ TryParseExpression callTryParse = DataExpression.TryParse(stringLocal, outLocal);
+ //Get the conditional expression used to process the try parse conversion.
+ ConditionalExpression tryParse = Expression.Condition(
+ Expression.AndAlso(typeIsAssign, callTryParse),
+ Expression.Convert(outLocal, memberType), Expression.Default(memberType));
+ //Update is assignable from with the try parse method.
+ isAssignableFrom = isAssignableFrom.Update(isAssignableFrom.Test, isAssignableFrom.IfTrue, tryParse);
+ }
+ if (typeof(IConvertible).IsAssignableFrom(realType))
+ {
+ //Get the change type expression.
+ ChangeTypeExpression callChangeType = DataExpression.ChangeType(
+ DataExpression.DataField(dataRow, dataColumn), realType);
+ //Get the conversion expression for the change type. If member type is string, then call the trim method on the string.
+ Expression changeType = Expression.Convert(callChangeType, memberType);
+ if (typeof(string).IsAssignableFrom(memberType))
+ {
+ changeType = Expression.Call(changeType, "Trim", Type.EmptyTypes);
+ }
+ //Determine if try parse is set. If so, update it and is assignable from. Otherwise, add change type to is assignable from.
+ if (isAssignableFrom.IfFalse is ConditionalExpression tryParse)
+ {
+ tryParse = tryParse.Update(tryParse.Test, tryParse.IfTrue, changeType);
+ isAssignableFrom = isAssignableFrom.Update(isAssignableFrom.Test, isAssignableFrom.IfTrue, tryParse);
+ }
+ else
+ {
+ isAssignableFrom = isAssignableFrom.Update(isAssignableFrom.Test, isAssignableFrom.IfTrue, changeType);
+ }
+ }
+ dataFieldIsNull = dataFieldIsNull.Update(dataFieldIsNull.Test, dataFieldIsNull.IfTrue, isAssignableFrom);
+ //Silently ignore conversion errors with the try catch expression. This is mostly for testing purposes and might be removed
+ //in the future.
+ memberBindings.Add(Expression.Bind(memberInfo, Expression.TryCatch(dataFieldIsNull,
+ Expression.Catch(typeof(Exception), Expression.Default(memberType)))));
+ }
+ }
+ //Get the converter lambda expression, creating the initialization block with its parameters.
+ Expression> converter = Expression.Lambda>(
+ Expression.Block(parameters.Values, Expression.MemberInit(instantiate, memberBindings)), dataRow);
+ //Use expression reducer to reduce the conversion lambda expression, then compile and return the delegate.
+ converter = (Expression>)new ExpressionReducer().Visit(converter);
+ value = converters.GetOrAdd(new HashSet(columnNames), converter.Compile());
+ }
+ return value;
+ }
+ //Attempts to get a member info object from the entity type the converter is converting to, returning true if one is found.
+ private static bool TryGetMemberInfo(string memberName, bool caseSensitive, out MemberInfo memberInfo)
+ {
+ BindingFlags flags = BindingFlags.Instance | BindingFlags.Public;
+ //Determine if the case sensitivite bool is false and add the ignore case flag to the binding search.
+ if (!caseSensitive)
+ {
+ flags |= BindingFlags.IgnoreCase;
+ }
+ //Determine if a property exists with the name member name and has the appropriate flags and set the out variable to this property info.
+ if (type.GetProperty(memberName, flags) is PropertyInfo propertyInfo)
+ {
+ memberInfo = propertyInfo;
+ }
+ //Determine if a field exists with the name member name and has the appropriate flags and set the out variable to this field info.
+ else if (type.GetField(memberName, flags) is FieldInfo fieldInfo)
+ {
+ memberInfo = fieldInfo;
+ }
+ //If no property or field exists in the type with the name given, assume that there is no valid target and set the out variable to null.
+ else
+ {
+ memberInfo = null;
+ }
+ return memberInfo != null;
+ }
+ //Creates a key value pair for the data column/column's name. This is used whenever no dictionary is provided to seed the converter's data column => property map.
+ private static KeyValuePair GetDataColumnKeyValuePair(DataColumn dataColumn) =>
+ new KeyValuePair(dataColumn, dataColumn.ColumnName);
+ }
+}
\ No newline at end of file
diff --git a/MJTop.Data/BWofter.Converters/EqualityComparers/StringCollectionComparer.cs b/MJTop.Data/BWofter.Converters/EqualityComparers/StringCollectionComparer.cs
new file mode 100644
index 0000000..acc7f53
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/EqualityComparers/StringCollectionComparer.cs
@@ -0,0 +1,112 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.EqualityComparers
+{
+ using System;
+ using System.Collections.Generic;
+ /// A utility class that is used to compare string collections within the cache object.
+ public class StringCollectionComparer : IEqualityComparer>
+ {
+ private static readonly Lazy instance = new Lazy(true);
+ /// Returns the singleton of .
+ /// The singleton of .
+ public static IEqualityComparer> GetInstance() => instance.Value;
+ /// Determines whether the specified objects are equal.
+ /// The first object of type of values to compare.
+ /// The second object of type of values to compare.
+ /// if the specified objects are equal; otherwise, .
+ public bool Equals(ICollection x, ICollection y)
+ {
+ //Determines if x and y are the same instance and returns true.
+ if (x == y)
+ {
+ return true;
+ }
+ //Determines if either x or y is null and returns false.
+ else if (x == null || y == null)
+ {
+ return false;
+ }
+ //Determines if x is a different length from y and returns false.
+ else if (x.Count != y.Count)
+ {
+ return false;
+ }
+ //Determines if x is a hash set and uses it as the contains target.
+ else if (x is HashSet)
+ {
+ //Iterate over the values in y and determine if x contains them. If any are not contained in x, return false.
+ foreach (string s in y)
+ {
+ if (!x.Contains(s))
+ {
+ return false;
+ }
+ }
+ }
+ //The default option.
+ else
+ {
+ //Iterate over the values in x and determine if y contains them. If any are not contained in y, return false.
+ foreach (string s in x)
+ {
+ if (!y.Contains(s))
+ {
+ return false;
+ }
+ }
+ }
+ return true;
+ }
+ /// Returns a hash code for the specified object.
+ /// The for which a hash code is to be returned.
+ /// A hash code for the specified object.
+ public int GetHashCode(ICollection obj)
+ {
+ //Determine if obj is null and return 0.
+ if (obj == null)
+ {
+ return 0;
+ }
+ int hashCode = 2;
+ //Enter an overflow unchecked areaa, iterate over the strings in the collection, and create a compound hash code using the hash code of each string.
+ unchecked
+ {
+ foreach (string s in obj)
+ {
+ hashCode <<= (obj?.GetHashCode() ?? 10) * 230182;
+ }
+ }
+ return hashCode;
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/ChangeTypeExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/ChangeTypeExpression.cs
new file mode 100644
index 0000000..bae89f7
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/ChangeTypeExpression.cs
@@ -0,0 +1,60 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ using System.Reflection;
+
+ public sealed class ChangeTypeExpression : DataExpression
+ {
+ public Expression Operand { get; }
+ public override Type Type { get; }
+ private static readonly MethodInfo changeType = convertType.GetMethod(nameof(System.Convert.ChangeType), new[] { objectType, typeType });
+ public ChangeTypeExpression(Expression operand, Type type)
+ {
+ Operand = operand ?? throw new ArgumentNullException(nameof(operand));
+ Type = type ?? throw new ArgumentNullException(nameof(operand));
+ }
+ public override Expression Reduce()
+ {
+ if (convertType.GetMethod($"To{Type.Name}", new[] { Operand.Type }) is MethodInfo methodInfo)
+ {
+ return Call(methodInfo, Operand);
+ }
+ else
+ {
+ return Convert(Call(changeType, Operand, Constant(Type)), Type);
+ }
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/DataColumnExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/DataColumnExpression.cs
new file mode 100644
index 0000000..729dfb7
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/DataColumnExpression.cs
@@ -0,0 +1,61 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class DataColumnExpression : DataExpression
+ {
+ public override Type Type => dataColumnType;
+ public new Expression DataTable { get; }
+ public Expression ColumnName { get; }
+
+ internal DataColumnExpression(Expression dataTable, Expression columnName)
+ {
+ DataTable = dataTable ?? throw new ArgumentNullException(nameof(dataTable));
+ ColumnName = columnName ?? throw new ArgumentNullException(nameof(columnName));
+ }
+
+ public override Expression Reduce()
+ {
+ if (!dataTableType.IsAssignableFrom(DataTable.Type))
+ {
+ throw new InvalidOperationException($"{nameof(DataTable)} should return a value that inherits from {dataTableType.FullName}, {DataTable.Type.FullName} given instead.");
+ }
+ if (!intType.IsAssignableFrom(ColumnName.Type) && !stringType.IsAssignableFrom(ColumnName.Type))
+ {
+ throw new InvalidOperationException($"{nameof(ColumnName)} should return a value that is either {intType.FullName} or {stringType.FullName}, {ColumnName.Type.FullName} given instead.");
+ }
+ return Property(Property(DataTable, nameof(System.Data.DataTable.Columns)), "Item", ColumnName);
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/DataExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/DataExpression.cs
new file mode 100644
index 0000000..1df49f1
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/DataExpression.cs
@@ -0,0 +1,104 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Data;
+ using System.Linq.Expressions;
+ using System.Reflection;
+
+ public abstract class DataExpression : Expression
+ {
+ public override bool CanReduce => true;
+ public override ExpressionType NodeType => ExpressionType.Extension;
+ protected static readonly Type objectType = typeof(object);
+ protected static readonly Type boolType = typeof(bool);
+ protected static readonly Type typeType = typeof(Type);
+ protected static readonly Type typeInfoType = typeof(TypeInfo);
+ protected static readonly Type dataColumnType = typeof(DataColumn);
+ protected static readonly Type dataTableType = typeof(DataTable);
+ protected static readonly Type dataRowType = typeof(DataRow);
+ protected static readonly Type intType = typeof(int);
+ protected static readonly Type stringType = typeof(string);
+ protected static readonly Type dataSetType = typeof(DataSet);
+ protected static readonly Type convertType = typeof(Convert);
+
+ public static IsAssignableFromExpression IsAssignableFrom(Type target, Type other) =>
+ new IsAssignableFromExpression(Constant(target), Constant(other));
+ public static IsAssignableFromExpression IsAssignableFrom(Expression other, Type target) =>
+ new IsAssignableFromExpression(Constant(target), other);
+ public static IsAssignableFromExpression IsAssignableFrom(Expression target, Expression other) =>
+ new IsAssignableFromExpression(target, other);
+ public static DataColumnExpression DataColumn(Expression dataTable, int columnNumber) =>
+ new DataColumnExpression(dataTable, Constant(columnNumber));
+ public static DataColumnExpression DataColumn(Expression dataTable, string columnName) =>
+ new DataColumnExpression(dataTable, Constant(columnName));
+ public static DataColumnExpression DataColumn(Expression dataTable, Expression columnName) =>
+ new DataColumnExpression(dataTable, columnName);
+ public static DataTableExpression DataTable(Expression dataMember, int tableNumber) =>
+ new DataTableExpression(dataMember, Constant(tableNumber));
+ public static DataTableExpression DataTable(Expression dataMember, string tableName) =>
+ new DataTableExpression(dataMember, Constant(tableName));
+ public static DataTableExpression DataTable(Expression dataMember, string tableName, string tableNamespace) =>
+ new DataTableExpression(dataMember, Constant(tableName), Constant(tableNamespace));
+ public static DataTableExpression DataTable(Expression dataMember, Expression tableName, string tableNamespace) =>
+ new DataTableExpression(dataMember, tableName, Constant(tableNamespace));
+ public static DataTableExpression DataTable(Expression dataMember, Expression tableName = null, Expression tableNamespace = null) =>
+ new DataTableExpression(dataMember, tableName, tableNamespace);
+ public static DataTypeExpression DataType(Expression dataColumn) =>
+ new DataTypeExpression(dataColumn);
+ public static DataFieldExpression DataField(Expression dataRow, int columnNumber) =>
+ new DataFieldExpression(dataRow, DataColumn(DataTable(dataRow), columnNumber));
+ public static DataFieldExpression DataField(Expression dataRow, string columnName) =>
+ new DataFieldExpression(dataRow, DataColumn(DataTable(dataRow), columnName));
+ public static DataFieldExpression DataField(Expression dataRow, Expression dataColumn) =>
+ new DataFieldExpression(dataRow, dataColumn);
+ public static TypeIsAssignExpression TypeIsAssign(Expression left, ParameterExpression right) =>
+ new TypeIsAssignExpression(left, right, right.Type);
+ public static TypeIsAssignExpression TypeIsAssign(Expression left, Expression right, Type type) =>
+ new TypeIsAssignExpression(left, right, type);
+ public static TryParseExpression TryParse(Expression inParameter, ParameterExpression outParameter) =>
+ new TryParseExpression(inParameter, outParameter, outParameter.Type);
+ public static TryParseExpression TryParse(Expression inParameter, Expression outParameter, Type type) =>
+ new TryParseExpression(inParameter, outParameter, type);
+ public static ChangeTypeExpression ChangeType(Expression operand, Type type) =>
+ new ChangeTypeExpression(operand, type);
+ public static DataFieldIsNullExpression DataFieldIsNull(Expression dataRow, int columnNumber) =>
+ new DataFieldIsNullExpression(dataRow, DataColumn(DataTable(dataRow), columnNumber));
+ public static DataFieldIsNullExpression DataFieldIsNull(Expression dataRow, string columnName) =>
+ new DataFieldIsNullExpression(dataRow, DataColumn(DataTable(dataRow), columnName));
+ public static DataFieldIsNullExpression DataFieldIsNull(Expression dataRow, Expression dataColumn) =>
+ new DataFieldIsNullExpression(dataRow, dataColumn);
+
+ public override abstract Expression Reduce();
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/DataFieldExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/DataFieldExpression.cs
new file mode 100644
index 0000000..cf080c5
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/DataFieldExpression.cs
@@ -0,0 +1,59 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class DataFieldExpression : DataExpression
+ {
+ public Expression DataRow { get; }
+ public new Expression DataColumn { get; }
+ public override Type Type => objectType;
+ public DataFieldExpression(Expression dataRow, Expression dataColumn)
+ {
+ DataRow = dataRow ?? throw new ArgumentNullException(nameof(dataRow));
+ DataColumn = dataColumn ?? throw new ArgumentNullException(nameof(dataColumn));
+ }
+ public override Expression Reduce()
+ {
+ if (!dataRowType.IsAssignableFrom(DataRow.Type))
+ {
+ throw new InvalidOperationException($"");
+ }
+ if (!dataColumnType.IsAssignableFrom(DataColumn.Type))
+ {
+ throw new InvalidOperationException($"");
+ }
+ return Property(DataRow, "Item", DataColumn);
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/DataFieldIsNullExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/DataFieldIsNullExpression.cs
new file mode 100644
index 0000000..c372d18
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/DataFieldIsNullExpression.cs
@@ -0,0 +1,59 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class DataFieldIsNullExpression : DataExpression
+ {
+ public Expression DataRow { get; }
+ public new Expression DataColumn { get; }
+ public override Type Type => boolType;
+ public DataFieldIsNullExpression(Expression dataRow, Expression dataColumn)
+ {
+ DataRow = dataRow ?? throw new ArgumentNullException(nameof(dataRow));
+ DataColumn = dataColumn ?? throw new ArgumentNullException(nameof(dataColumn));
+ }
+ public override Expression Reduce()
+ {
+ if (!dataRowType.IsAssignableFrom(DataRow.Type))
+ {
+ throw new InvalidOperationException($"");
+ }
+ if (!dataColumnType.IsAssignableFrom(DataColumn.Type))
+ {
+ throw new InvalidOperationException($"");
+ }
+ return Call(DataRow, nameof(System.Data.DataRow.IsNull), Type.EmptyTypes, DataColumn);
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/DataTableExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/DataTableExpression.cs
new file mode 100644
index 0000000..609947e
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/DataTableExpression.cs
@@ -0,0 +1,86 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class DataTableExpression : DataExpression
+ {
+ public override Type Type => dataTableType;
+ public Expression DataMember { get; }
+ public Expression TableName { get; }
+ public Expression TableNamespace { get; }
+
+ internal DataTableExpression(Expression dataMember, Expression tableName = null, Expression tableNamespace = null)
+ {
+ DataMember = dataMember ?? throw new ArgumentNullException(nameof(dataMember));
+ TableName = tableName;
+ TableNamespace = tableNamespace;
+ }
+
+ public override Expression Reduce()
+ {
+ if (dataTableType.IsAssignableFrom(DataMember.Type))
+ {
+ return DataMember;
+ }
+ else if (dataRowType.IsAssignableFrom(DataMember.Type))
+ {
+ return Property(DataMember, nameof(System.Data.DataRow.Table));
+ }
+ else if (dataColumnType.IsAssignableFrom(DataMember.Type))
+ {
+ return Property(DataMember, nameof(System.Data.DataColumn.Table));
+ }
+ else if (dataSetType.IsAssignableFrom(DataMember.Type))
+ {
+ MemberExpression tables = Property(DataMember, "Tables");
+ if ((stringType.IsAssignableFrom(TableName.Type) || intType.IsAssignableFrom(TableName.Type)) && TableNamespace == null)
+ {
+ return Property(tables, "Item", TableName);
+ }
+ else if (stringType.IsAssignableFrom(TableName.Type) && stringType.IsAssignableFrom(TableNamespace.Type))
+ {
+ return Property(tables, "Item", TableName, TableNamespace);
+ }
+ else
+ {
+ throw new InvalidOperationException($"");
+ }
+ }
+ else
+ {
+ throw new InvalidOperationException($"");
+ }
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/DataTypeExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/DataTypeExpression.cs
new file mode 100644
index 0000000..5fecf31
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/DataTypeExpression.cs
@@ -0,0 +1,56 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class DataTypeExpression : DataExpression
+ {
+ public override Type Type => typeType;
+ public new Expression DataColumn { get; }
+
+ public DataTypeExpression(Expression dataColumn) =>
+ DataColumn = dataColumn ?? throw new ArgumentNullException(nameof(dataColumn));
+
+ public override Expression Reduce()
+ {
+ if (dataColumnType.IsAssignableFrom(DataColumn.Type))
+ {
+ return Property(DataColumn, nameof(System.Data.DataColumn.DataType));
+ }
+ else
+ {
+ throw new InvalidOperationException($"");
+ }
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/ExpressionReducer.cs b/MJTop.Data/BWofter.Converters/Expressions/ExpressionReducer.cs
new file mode 100644
index 0000000..2080585
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/ExpressionReducer.cs
@@ -0,0 +1,45 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System.Linq.Expressions;
+ public sealed class ExpressionReducer : ExpressionVisitor
+ {
+ public override Expression Visit(Expression node)
+ {
+ if (node != null && !node.NodeType.HasFlag(ExpressionType.MemberInit))
+ while (node.CanReduce)
+ node = node.Reduce();
+ return base.Visit(node);
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/IsAssignableFromExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/IsAssignableFromExpression.cs
new file mode 100644
index 0000000..5e92d9e
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/IsAssignableFromExpression.cs
@@ -0,0 +1,71 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class IsAssignableFromExpression : DataExpression
+ {
+ public override Type Type => boolType;
+ public Expression TargetType { get; }
+ public Expression OtherType { get; }
+ internal IsAssignableFromExpression(Expression target, Expression other)
+ {
+ TargetType = target ?? throw new ArgumentNullException(nameof(target));
+ OtherType = other ?? throw new ArgumentNullException(nameof(other));
+ }
+ public IsAssignableFromExpression Update(Expression target, Expression other) =>
+ new IsAssignableFromExpression(target, other);
+ public override Expression Reduce()
+ {
+ Expression target,
+ other;
+ if (typeType.IsAssignableFrom(TargetType.Type) || typeInfoType.IsAssignableFrom(TargetType.Type))
+ {
+ target = TargetType;
+ }
+ else
+ {
+ target = Call(TargetType, nameof(object.GetType), Type.EmptyTypes);
+ }
+ if (typeType.IsAssignableFrom(OtherType.Type) || typeInfoType.IsAssignableFrom(OtherType.Type))
+ {
+ other = OtherType;
+ }
+ else
+ {
+ other = Call(OtherType, nameof(object.GetType), Type.EmptyTypes);
+ }
+ return Call(TargetType, nameof(Type.IsAssignableFrom), Type.EmptyTypes, other);
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/TryParseExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/TryParseExpression.cs
new file mode 100644
index 0000000..06ecb8b
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/TryParseExpression.cs
@@ -0,0 +1,51 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class TryParseExpression : DataExpression
+ {
+ public Expression InParameter { get; }
+ public Expression OutParameter { get; }
+ public override Type Type => boolType;
+ public Type TargetType { get; }
+ public TryParseExpression(Expression inParameter, Expression outParameter, Type type)
+ {
+ InParameter = inParameter ?? throw new ArgumentNullException(nameof(inParameter));
+ OutParameter = outParameter ?? throw new ArgumentNullException(nameof(outParameter));
+ TargetType = type ?? throw new ArgumentNullException(nameof(type));
+ }
+ public override Expression Reduce() =>
+ Call(TargetType.GetMethod("TryParse", new[] { stringType, TargetType.MakeByRefType() }), InParameter, OutParameter);
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Expressions/TypeIsAssignExpression.cs b/MJTop.Data/BWofter.Converters/Expressions/TypeIsAssignExpression.cs
new file mode 100644
index 0000000..0071368
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Expressions/TypeIsAssignExpression.cs
@@ -0,0 +1,51 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Expressions
+{
+ using System;
+ using System.Linq.Expressions;
+ public sealed class TypeIsAssignExpression : DataExpression
+ {
+ public Expression Left { get; }
+ public Expression Right { get; }
+ public override Type Type => boolType;
+ public Type TargetType { get; }
+ public TypeIsAssignExpression(Expression left, Expression right, Type type)
+ {
+ Left = left ?? throw new ArgumentNullException(nameof(left));
+ Right = right ?? throw new ArgumentNullException(nameof(right));
+ TargetType = type ?? throw new ArgumentNullException(nameof(type));
+ }
+ public override Expression Reduce() =>
+ NotEqual(Assign(Right, TypeAs(Left, TargetType)), Constant(null, TargetType));
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Extensions/DataColumnCollectionExtensions.cs b/MJTop.Data/BWofter.Converters/Extensions/DataColumnCollectionExtensions.cs
new file mode 100644
index 0000000..f35fa5c
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Extensions/DataColumnCollectionExtensions.cs
@@ -0,0 +1,82 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Extensions
+{
+ using System;
+ using System.Collections.Generic;
+ using System.Data;
+ using System.Linq;
+ /// A static class that provides LINQ extensions for the type.
+ public static class DataColumnCollectionExtensions
+ {
+ /// Returns an of values that represents .
+ /// The target of the extension method.
+ /// of values or .
+ public static IEnumerable Select(this DataColumnCollection collection) =>
+ collection.Select(dc => dc);
+ /// Returns an of values that represents .
+ /// The target of the extension method.
+ /// The selector of the extension method.
+ /// of values or .
+ public static IEnumerable Select(this DataColumnCollection collection, Func selector)
+ {
+ if (collection == null) throw new ArgumentNullException(nameof(collection));
+ if (selector == null) throw new ArgumentNullException(nameof(selector));
+ //Determines if there are no entries in the collection. If not, return an empty enumerable. Otherwise, process the selector.
+ if (collection.Count == 0)
+ {
+ return Enumerable.Empty();
+ }
+ else
+ {
+ return collection.Cast().Select(selector);
+ }
+ }
+ /// Returns an of values that represents .
+ /// The target of the extension method.
+ /// The predicate of the extension method.
+ /// of values or .
+ public static IEnumerable Where(this DataColumnCollection collection, Func predicate)
+ {
+ if (collection == null) throw new ArgumentNullException(nameof(collection));
+ if (predicate == null) throw new ArgumentNullException(nameof(predicate));
+ if (collection.Count == 0)
+ {
+ return Enumerable.Empty();
+ }
+ else
+ {
+ return collection.Cast().Where(predicate);
+ }
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Extensions/DictionaryStringObjectExtensions.cs b/MJTop.Data/BWofter.Converters/Extensions/DictionaryStringObjectExtensions.cs
new file mode 100644
index 0000000..5a0a8fe
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Extensions/DictionaryStringObjectExtensions.cs
@@ -0,0 +1,55 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Extensions
+{
+ using System;
+ using System.Collections.Generic;
+ using System.Data;
+ /// A static class that provides LINQ extensions for of keys and values.
+ public static class DictionaryStringObjectExtensions
+ {
+ /// Returns a that represents the columns and types of . This does not copy the values.
+ /// The target of the extension method.
+ /// with columns that match the key and type of the entries.
+ public static DataTable AsDataTableDefinition(this IDictionary dictionary)
+ {
+ if (dictionary == null) throw new ArgumentNullException(nameof(dictionary));
+ DataTable dataTable = new DataTable();
+ //Iterate over the entries in the dictionary and add a matching column to the new data table.
+ foreach (KeyValuePair keyValuePair in dictionary)
+ {
+ dataTable.Columns.Add(keyValuePair.Key, keyValuePair.Value?.GetType() ?? typeof(object));
+ }
+ return dataTable;
+ }
+ }
+}
diff --git a/MJTop.Data/BWofter.Converters/Extensions/IEnumerableKeyValuePairExtensions.cs b/MJTop.Data/BWofter.Converters/Extensions/IEnumerableKeyValuePairExtensions.cs
new file mode 100644
index 0000000..01c6183
--- /dev/null
+++ b/MJTop.Data/BWofter.Converters/Extensions/IEnumerableKeyValuePairExtensions.cs
@@ -0,0 +1,60 @@
+/*
+BSD 3-Clause License
+
+Copyright (c) 2017, B. Wofter
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+* Neither the name of the copyright holder nor the names of its
+ contributors may be used to endorse or promote products derived from
+ this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+namespace BWofter.Converters.Extensions
+{
+ using System;
+ using System.Collections.Generic;
+ using System.Linq;
+ /// A static class that provides LINQ extensions for of values.
+ public static class IEnumerableKeyValuePairExtensions
+ {
+ /// Returns a with the key type and value type ,
+ /// initialized with the values in .
+ /// The key type.
+ /// The value type.
+ /// An of values that contain the initial data of the dictionary.
+ /// with the key type and value type .
+ public static Dictionary ToDictionary(this IEnumerable> dictionarySource)
+ {
+ if (dictionarySource == null) throw new ArgumentNullException(nameof(dictionarySource));
+ //Instantiate a new dictionary with a number of entries equal to the length of the source, then sets gD equal to the reference of dictionary. This is to prevent extra casting operations.
+ Dictionary dictionary = new Dictionary(dictionarySource.Count());
+ ICollection> gD = dictionary;
+ foreach (KeyValuePair entry in dictionarySource)
+ {
+ //Add the key value pair to gD.
+ gD.Add(entry);
+ }
+ return dictionary;
+ }
+ }
+}
diff --git a/MJTop.Data/DB.Ext.cs b/MJTop.Data/DB.Ext.cs
new file mode 100644
index 0000000..d074040
--- /dev/null
+++ b/MJTop.Data/DB.Ext.cs
@@ -0,0 +1,401 @@
+using MJTop.Data.SPI;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Collections;
+using System.Data;
+using System.Data.Common;
+using System.Collections.Specialized;
+using MJTop.Data.DatabaseInfo;
+using System.Reflection;
+using System.Threading;
+using System.Text.RegularExpressions;
+
+namespace MJTop.Data
+{
+ public partial class DB
+ {
+ #region 实体相关
+ public virtual TEntity GetById(string tableName, object pkValue) where TEntity : class, new()
+ {
+ TableInfo tabInfo = Info.TableInfoDict[tableName];
+ ColumnInfo colInfo = Info[tableName, tabInfo.PriKeyColName];
+ string strSql = "select * from " + tableName + " where " + colInfo.ColumnName + "=" + ParameterSql(colInfo.ColumnName);
+ DataTable data = GetDataTable(strSql, CreateParameter(colInfo.ColumnName, pkValue, colInfo).TransArray());
+ return BWofter.Converters.Data.DataTableConverter.ToEntities(data).ToList()?.FirstOrDefault();
+ }
+
+ public virtual List GetByIds(string tableName, object[] pkValues) where TEntity : class, new()
+ {
+ TableInfo tabInfo = Info.TableInfoDict[tableName];
+ ColumnInfo colInfo = Info[tableName, tabInfo.PriKeyColName];
+ string strSql = "select * from " + tableName + " where " + colInfo.ColumnName + " in ({0})";
+ if (pkValues.Length <= 0)
+ {
+ return new List();
+ }
+ strSql = string.Format(strSql, ParameterSql(colInfo.ColumnName).Repeater(pkValues.Length, ","));
+
+ List lstpara = new List();
+ foreach (var value in pkValues)
+ {
+ lstpara.Add(CreateParameter(colInfo.ColumnName, value, colInfo));
+ }
+ return BWofter.Converters.Data.DataTableConverter.ToEntities(GetDataTable(strSql, lstpara)).ToList();
+ }
+
+ public TEntity Get(string tableName, object whereParameters = null)
+ where TEntity : class, new()
+
+ {
+ return GetList(tableName, whereParameters).FirstOrDefault();
+ }
+
+ public List GetList(string tableName, object whereParameters)
+ where TEntity : class, new()
+
+ {
+ string strSql = "select * from " + tableName;
+ List lstPara = new List();
+ List lstWhere = new List();
+ if (whereParameters != null)
+ {
+ if (whereParameters is System.Collections.IDictionary)
+ {
+ IDictionary dict = whereParameters as IDictionary;
+ if (dict != null && dict.Count > 0)
+ {
+ foreach (DictionaryEntry kv in dict)
+ {
+ var parameter = CreateParameter();
+ parameter.ParameterName = ParameterChar + kv.Key.ToString();
+ parameter.Value = kv.Value;
+
+ if (parameter.Value == null || parameter.Value == DBNull.Value)
+ {
+ parameter.Value = DBNull.Value;
+ }
+ else
+ {
+ if (tableName != null)
+ {
+ ColumnInfo colInfo = Info[tableName, kv.Key.ToString()];
+ if (colInfo != null)
+ {
+ parameter.DbType = colInfo.DbType;
+
+ parameter.Value = Global.Dict_Convert_Type[colInfo.DbType].Invoke(parameter.Value);
+ }
+ }
+ else
+ {
+ Type tyValue = parameter.Value.GetType();
+ DbType tmpType;
+ if (Global.TypeMap.TryGetValue(tyValue, out tmpType))
+ {
+ parameter.DbType = tmpType;
+ }
+ else
+ {
+ parameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ lstWhere.Add(kv.Key.ToString() + "=" + ParameterSql(kv.Key.ToString()));
+ lstPara.Add(parameter);
+ }
+ }
+ }
+ else if (whereParameters is NameValueCollection)
+ {
+ NameValueCollection nvc = whereParameters as NameValueCollection;
+ if (nvc != null && nvc.Count > 0)
+ {
+ foreach (var key in nvc.AllKeys)
+ {
+ var parameter = CreateParameter();
+ parameter.ParameterName = ParameterChar + key;
+ parameter.Value = nvc[key];
+
+ if (parameter.Value == null || parameter.Value == DBNull.Value)
+ {
+ parameter.Value = DBNull.Value;
+ }
+ else
+ {
+ if (tableName != null)
+ {
+ ColumnInfo colInfo = Info[tableName, key];
+ if (colInfo != null)
+ {
+ parameter.DbType = colInfo.DbType;
+
+ parameter.Value = Global.Dict_Convert_Type[colInfo.DbType].Invoke(parameter.Value);
+ }
+ }
+ else
+ {
+ Type tyValue = parameter.Value.GetType();
+ DbType tmpType;
+ if (Global.TypeMap.TryGetValue(tyValue, out tmpType))
+ {
+ parameter.DbType = tmpType;
+ }
+ else
+ {
+ parameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ lstWhere.Add(key + "=" + ParameterSql(key));
+ lstPara.Add(parameter);
+ }
+ }
+ }
+ else
+ {
+ Type ty = whereParameters.GetType();
+
+ if (ty.Name.Contains("AnonymousType"))
+ {
+ PropertyInfo[] props;
+ if (!Dict_Type_Props.TryGetValue(ty, out props))
+ {
+ Dict_Type_Props[ty] = ty.GetProperties();
+ props = Dict_Type_Props[ty];
+ }
+
+ if (props != null && props.Length > 0)
+ {
+ foreach (var prop in props)
+ {
+ var parameter = CreateParameter();
+ parameter.ParameterName = ParameterChar + prop.Name;
+ parameter.Value = prop.GetValue(whereParameters, null);
+
+ if (parameter.Value == null || parameter.Value == DBNull.Value)
+ {
+ parameter.Value = DBNull.Value;
+ }
+ else
+ {
+ if (tableName != null)
+ {
+ ColumnInfo colInfo = Info[tableName, prop.Name];
+ if (colInfo != null)
+ {
+ parameter.DbType = colInfo.DbType;
+
+ parameter.Value = Global.Dict_Convert_Type[colInfo.DbType].Invoke(parameter.Value);
+ }
+ }
+ else
+ {
+ Type tyValue = parameter.Value.GetType();
+ DbType tmpType;
+ if (Global.TypeMap.TryGetValue(tyValue, out tmpType))
+ {
+ parameter.DbType = tmpType;
+ }
+ else
+ {
+ parameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ lstWhere.Add(prop.Name + "=" + ParameterSql(prop.Name));
+ lstPara.Add(parameter);
+ }
+ }
+ }
+ else
+ {
+ //其他类型
+ throw new ArgumentException("不支持其他类型参数！", nameof(whereParameters));
+ }
+ }
+ }
+ strSql = strSql + (lstWhere.Any() ? " where " : "") + string.Join(" and ", lstWhere);
+ DataTable data = GetDataTable(strSql, lstPara);
+ //return BWofter.Converters.Data.DataTableConverter.ToEntities(data).ToList();
+ return data.ConvertToListObject();
+ }
+
+ public List GetList(string strSql) where TEntity : class, new()
+ {
+ DataTable data = GetDataTable(strSql);
+ //return BWofter.Converters.Data.DataTableConverter.ToEntities(data).ToList();
+ return data.ConvertToListObject();
+ }
+
+ #endregion
+
+ public virtual DataTable SelectTable(string joinTableName, string whereStr, string orderbyStr)
+ {
+ if (!string.IsNullOrWhiteSpace(whereStr))
+ {
+ whereStr = Regex.Replace(whereStr, @"(\s)*(where)?(\s)*(.+)", "where 1=1 and $3$4", RegexOptions.Compiled | RegexOptions.IgnoreCase);
+ }
+
+ if (!string.IsNullOrWhiteSpace(orderbyStr))
+ {
+ orderbyStr = Regex.Replace(orderbyStr, @"(\s)*(order)(\s)+(by)(.+)", "$5", RegexOptions.Compiled | RegexOptions.IgnoreCase);
+ }
+ else
+ {
+ throw new ArgumentNullException("orderbyStr");
+ }
+
+ string strSql = "select * from {0} {1} order by {2}";
+ strSql = string.Format(strSql, joinTableName, whereStr, orderbyStr);
+
+ return GetDataTable(strSql);
+ }
+ public virtual bool Exist(string tableName, string columnName, object columnValue)
+ {
+ return Exist(tableName, columnName, columnValue, null);
+ }
+ public virtual bool Exist(string tableName, string columnName, object columnValue, params object[] excludeValues)
+ {
+ string exist_sql = "select count(1) from " + tableName + " where " + columnName + "='" + columnValue + "' ";
+ if (excludeValues != null && excludeValues.Length > 0)
+ {
+ string in_sql = Script.SqlIn(columnName, excludeValues, true);
+ exist_sql += in_sql;
+ }
+ return Single(exist_sql, 0) > 0;
+ }
+
+ public virtual bool UpSingle(string tableName, string columnName, object columnValue, object pkOrUniqueValue, string pkOrUniqueColName = "Id")
+ {
+ string upSql = string.Empty;
+ upSql = "update " + tableName + " set " + columnName + "=" + ParameterSql(columnName) + " where " + pkOrUniqueColName + "=" + ParameterSql(pkOrUniqueColName);
+
+ var p1 = CreateParameter(columnName, columnValue, Info[tableName, columnName]);
+ var p2 = CreateParameter(pkOrUniqueColName, pkOrUniqueValue, Info[tableName, pkOrUniqueColName]);
+
+ bool res = ExecSql(upSql, new DbParameter[] { p1, p2 }) > 0;
+
+ var lstAct = DataChangeTriggers.GetActions(tableName);
+ if (lstAct.Any())
+ {
+ foreach (var act in lstAct)
+ {
+ act.Invoke();
+ }
+ }
+ return res;
+ }
+ public virtual int Delete(string tableName, string columnName, params object[] columnValues)
+ {
+ if (columnValues != null && columnValues.Length <= 0
+ && !Info.IsExistColumn(tableName, columnName))
+ {
+ return Delete(tableName, (object)columnName);
+ }
+
+ if (!Info.IsExistTable(tableName))
+ {
+ return -1;
+ }
+
+ string delSql = "delete from " + tableName + " where 1=1 " + Script.SqlInByDBType(Info[tableName, columnName], columnValues, this.DBType);
+ int res = ExecSql(delSql);
+ var lstAct = DataChangeTriggers.GetActions(tableName);
+ if (lstAct.Any())
+ {
+ foreach (var act in lstAct)
+ {
+ act.Invoke();
+ }
+ }
+ return res;
+ }
+
+ public virtual bool Delete(string tableName)
+ {
+ if (!Info.IsExistTable(tableName))
+ {
+ return false;
+ }
+ string delSql = "delete from " + tableName;
+ //ExecSql(delSql, new DbParameter[] { CreateParameter(tableName, tableName) });
+ ExecSql(delSql);
+ return true;
+ }
+
+ public virtual int Delete(string tableName, object pkValue)
+ {
+ if (!Info.IsExistTable(tableName))
+ {
+ return -1;
+ }
+ string delSql = string.Empty;
+ delSql = "delete from " + tableName + " where " + Info.TableInfoDict[tableName].PriKeyColName + "=" + ParameterSql(Info.TableInfoDict[tableName].PriKeyColName);
+ int res = ExecSql(delSql, new DbParameter[] { CreateParameter(Info.TableInfoDict[tableName].PriKeyColName, pkValue) });
+ var lstAct = DataChangeTriggers.GetActions(tableName);
+ if (lstAct.Any())
+ {
+ foreach (var act in lstAct)
+ {
+ act.Invoke();
+ }
+ }
+ return res;
+ }
+
+ ///
+ /// 根据表名查数据
+ ///
+ /// 表名
+ /// 排序字段+asc/desc
+ /// DataTable
+ public virtual DataTable SelectAll(string tableName, string orderbyStr = null)
+ {
+ if (!Info.IsExistTable(tableName))
+ {
+ return null;
+ }
+ string selSql = string.Format("select * from {0} ", tableName);
+ if (!string.IsNullOrWhiteSpace(orderbyStr))
+ {
+ selSql += " order by " + orderbyStr;
+ }
+ return GetDataTable(selSql);
+ }
+
+ ///
+ /// 取表中的前top条数据
+ ///
+ /// 表名
+ /// 取多少条
+ /// 排序字段+asc/desc
+ /// DataTable
+ public virtual DataTable SelectTop(string tableName, int top, string orderbyStr = null)
+ {
+ throw new NotImplementedException(DBType + "暂未支持");
+ }
+
+ ///
+ /// 获取数据条数
+ ///
+ /// 表名
+ /// and过滤条件
+ /// 总条数
+ public virtual long SelectCount(string tableName, string whereAndStr = null)
+ {
+ if (!Info.IsExistTable(tableName))
+ {
+ return -1;
+ }
+ string selSql = string.Format("select count(1) from {0} ", tableName);
+ if (!string.IsNullOrWhiteSpace(whereAndStr))
+ {
+ selSql += " where 1=1 " + whereAndStr;
+ }
+ return Scalar(selSql, 0);
+ }
+ }
+}
diff --git a/MJTop.Data/DB.cs b/MJTop.Data/DB.cs
new file mode 100644
index 0000000..e34c21d
--- /dev/null
+++ b/MJTop.Data/DB.cs
@@ -0,0 +1,1816 @@
+using MJTop.Data.SPI;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Collections;
+using System.Data;
+using System.Data.Common;
+using System.Collections.Specialized;
+using MJTop.Data.DatabaseInfo;
+using System.Reflection;
+using System.Threading;
+using System.Text.RegularExpressions;
+using System.Collections.Concurrent;
+
+namespace MJTop.Data
+{
+ public partial class DB : IDB
+ {
+ ///
+ /// 数据提供程序工厂
+ ///
+ internal DbProviderFactory DBFactory
+ {
+ get;
+ set;
+ }
+
+ ///
+ /// 连接字符串基类对象
+ ///
+ public DbConnectionStringBuilder ConnectionStringBuilder { get; protected set; }
+
+ ///
+ /// 数据库类型
+ ///
+ public DBType DBType
+ {
+ get; protected set;
+ }
+
+ ///
+ /// 数据库表列相关信息
+ ///
+ public IDBInfo Info
+ {
+ get;
+ protected set;
+ }
+
+
+ ///
+ /// 超时时间
+ ///
+ internal int CmdTimeout
+ {
+ get;
+ set;
+ }
+
+ ///
+ /// 连接字符串
+ ///
+ internal string ConnectionString { get; set; }
+
+ #region AOP
+ ///
+ /// 执行前
+ ///
+ public Action OnExecuting { get; set; }
+
+ ///
+ /// 执行后，附带返回值
+ ///
+ public Action OnExecuted { get; set; }
+
+ ///
+ /// 报异常时
+ ///
+ public Action OnError { get; set; }
+ #endregion
+
+ ///
+ /// 对数据 增删改 时触发
+ ///
+ public TableTrigger DataChangeTriggers
+ {
+ get;
+ internal set;
+ }
+
+ #region 插入或更新排除列 设置与获取
+ ///
+ /// 设置 插入时 要排除表列 集合
+ ///
+ public ExcludeColumn InsertExcludeColumns
+ {
+ get;
+ internal set;
+ }
+
+ ///
+ /// 获取 插入时 排除表列 集合
+ ///
+ ///
+ public NameValueCollection GetInsertExcludeColumns()
+ {
+ return InsertExcludeColumns.Coll;
+ }
+
+ ///
+ /// 设置 更新时 要排除表列 集合
+ ///
+ public ExcludeColumn UpdateExcludeColumns
+ {
+ get;
+ internal set;
+ }
+
+ ///
+ /// 获取 更新时 排除表列 集合
+ ///
+ ///
+ public NameValueCollection GetUpdateExcludeColumns()
+ {
+ return InsertExcludeColumns.Coll;
+ }
+
+
+ public string ParameterChar
+ {
+ get
+ {
+ return DBType.ParameterChar();
+ }
+ }
+
+
+ #endregion
+
+
+ internal string ParameterSql(string parameterName)
+ {
+ if (DBType == DBType.OracleDDTek)
+ {
+ return "?";
+ }
+ return ParameterChar + parameterName;
+ }
+
+ ///
+ /// 构建 参数化 对象
+ /// 不同数据库 参数化 时所使用的字符：Global.ParameterCharMap
+ ///
+ /// 参数化 变量名
+ /// 参数化 值
+ /// 列信息
+ ///
+ public DbParameter CreateParameter(string parameterName, object value, ColumnInfo colInfo = null)
+ {
+ DbParameter dbparameter = DBFactory.CreateParameter();
+ dbparameter.ParameterName = DBType.ParameterChar() + parameterName;
+ dbparameter.Value = value;
+
+ if (value == null || value == DBNull.Value)
+ {
+ dbparameter.Value = DBNull.Value;
+ }
+ else
+ {
+ DbType dbType;
+ if (colInfo != null)
+ {
+ dbType = colInfo.DbType;
+ object val = null;
+ val = Global.Dict_Convert_Type[dbType].Invoke(dbparameter.Value);
+ if (val is Exception)
+ {
+ throw val as Exception;
+ }
+ dbparameter.Value = val;
+ dbparameter.DbType = dbType;
+ }
+ else
+ {
+ Type tyValue = dbparameter.Value.GetType();
+ if (Global.TypeMap.TryGetValue(tyValue, out dbType))
+ {
+ dbparameter.DbType = dbType;
+ }
+ else
+ {
+ dbparameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ return dbparameter;
+ }
+
+ ///
+ /// 构建 参数化 对象
+ ///
+ /// 参数化 变量名
+ /// 参数化 值
+ /// 数据类型
+ /// 参数化的方式
+ ///
+ public DbParameter CreateParameter(string parameterName, object value, DbType type, ParameterDirection direction = ParameterDirection.Input)
+ {
+ DbParameter dbparameter = DBFactory.CreateParameter();
+ dbparameter.ParameterName = DBType.ParameterChar() + parameterName;
+ dbparameter.Value = value;
+ dbparameter.DbType = type;
+ dbparameter.Direction = direction;
+ return dbparameter;
+ }
+
+ ///
+ /// 创建 Connection 对象
+ ///
+ ///
+ public DbConnection CreateConn()
+ {
+ return CreateConn(this.ConnectionString);
+ }
+
+
+ #region internal ado.net的四大核心对象
+ internal DbConnection CreateConn(string connectionString)
+ {
+ DbConnection _DBConn = DBFactory.CreateConnection();
+ if (!string.IsNullOrWhiteSpace(connectionString))
+ {
+ _DBConn.ConnectionString = connectionString;
+ }
+ return _DBConn;
+ }
+
+ internal DbCommand CreateCmd()
+ {
+ DbCommand _DBCmd = DBFactory.CreateCommand();
+ return _DBCmd;
+ }
+
+ internal DbCommand CreateCmd(string commandText = null, DbConnection DbConn = null)
+ {
+ DbCommand _DBCmd = DBFactory.CreateCommand();
+ if (DbConn != null)
+ {
+ _DBCmd.Connection = DbConn;
+ }
+ if (!string.IsNullOrWhiteSpace(commandText))
+ {
+ _DBCmd.CommandText = commandText;
+ }
+ return _DBCmd;
+ }
+
+ internal DbDataAdapter CreateAdapter(DbCommand dbCmd = null)
+ {
+ DbDataAdapter dbadapter = DBFactory.CreateDataAdapter();
+ if (dbCmd != null)
+ {
+ dbadapter.SelectCommand = dbCmd;
+ }
+ return dbadapter;
+ }
+
+ internal DbParameter CreateParameter()
+ {
+ DbParameter dbparameter = DBFactory.CreateParameter();
+ return dbparameter;
+ }
+
+ public void CheckTabStuct(string tableName, params string[] columnNames)
+ {
+ if (string.IsNullOrWhiteSpace(tableName))
+ {
+ throw new ArgumentNullException("tableName", "不能为空！");
+ }
+
+ if (!Info.TableNames.Contains(tableName, StringComparer.OrdinalIgnoreCase))
+ {
+ throw new ArgumentException(string.Format("不存在该表！{0}", "[" + tableName + "]"), "tableName:" + tableName);
+ }
+
+ if (columnNames != null && columnNames.Length > 0)
+ {
+ List lstAllColName = Info[tableName];
+
+ foreach (string columnName in columnNames)
+ {
+ if (!lstAllColName.Contains(columnName, StringComparer.OrdinalIgnoreCase))
+ {
+ throw new ArgumentException(string.Format("不存在该列！{0}", "[" + tableName + "." + columnName + "]"), "columnName:" + columnName, null);
+ }
+ }
+ }
+ }
+
+ #endregion
+
+
+ public DB(DBType dbType, DbProviderFactory dbFactory, string connectionString)
+ {
+ this.DBType = dbType;
+ this.DBFactory = dbFactory;
+ this.ConnectionString = connectionString;
+
+ this.ConnectionStringBuilder = DBFactory.CreateConnectionStringBuilder();
+ this.ConnectionStringBuilder.ConnectionString = connectionString;
+
+ this.InsertExcludeColumns = new ExcludeColumn(this);
+ this.UpdateExcludeColumns = new ExcludeColumn(this);
+
+ this.DataChangeTriggers = new TableTrigger(this);
+
+ {//查询数据库表列信息前，先验证数据库能否可以连接成功！
+
+ try
+ {
+ using (DbConnection conn = CreateConn())
+ {
+ conn.Open();
+ }
+ }
+ catch (Exception ex)
+ {
+ if (this.OnError != null)
+ this.OnError.Invoke(null, ex);
+
+ throw ex;
+ }
+ }
+ }
+
+ internal DbCommand BuildCommand(DbConnection conn, string cmdText, int timeOut = 30, CommandType cmdType = CommandType.Text)
+ {
+ return BuildCommandByParam(conn, cmdText, null, timeOut, cmdType);
+ }
+
+ static ConcurrentDictionary Dict_Type_Props = new ConcurrentDictionary();
+ internal DbCommand BuildCommandByParam(DbConnection conn, string cmdText, object cmdParms, int timeOut = 60, CommandType cmdType = CommandType.Text, string tableName = null)
+ {
+ if (conn.State != ConnectionState.Open)
+ conn.Open();
+ var cmd = conn.CreateCommand();
+ cmd.CommandText = cmdText;
+ cmd.CommandType = cmdType;
+
+ if (this.CmdTimeout != timeOut)
+ {
+ cmd.CommandTimeout = this.CmdTimeout;
+ }
+ else //以秒为单位）。默认为 30 秒
+ {
+ cmd.CommandTimeout = timeOut;
+ }
+
+ if (cmdParms != null)
+ {
+ if (cmdParms is DbParameter[])
+ {
+ DbParameter[] arr = cmdParms as DbParameter[];
+ cmd.Parameters.AddRange(arr);
+ }
+ else if (cmdParms is List)
+ {
+ List lstDp = cmdParms as List;
+ cmd.Parameters.AddRange(lstDp.ToArray());
+ }
+ else if (cmdParms is System.Collections.IDictionary)
+ {
+ IDictionary dict = cmdParms as IDictionary;
+ if (dict != null && dict.Count > 0)
+ {
+ foreach (DictionaryEntry kv in dict)
+ {
+ var parameter = cmd.CreateParameter();
+ parameter.ParameterName = ParameterChar + kv.Key.ToString();
+ parameter.Value = kv.Value;
+
+ if (parameter.Value == null || parameter.Value == DBNull.Value)
+ {
+ parameter.Value = DBNull.Value;
+ }
+ else
+ {
+ if (tableName != null)
+ {
+ ColumnInfo colInfo = Info[tableName, kv.Key.ToString()];
+ if (colInfo != null)
+ {
+ parameter.DbType = colInfo.DbType;
+
+ parameter.Value = Global.Dict_Convert_Type[colInfo.DbType].Invoke(parameter.Value);
+ }
+ }
+ else
+ {
+ Type tyValue = parameter.Value.GetType();
+ DbType tmpType;
+ if (Global.TypeMap.TryGetValue(tyValue, out tmpType))
+ {
+ parameter.DbType = tmpType;
+ }
+ else
+ {
+ parameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ cmd.Parameters.Add(parameter);
+ }
+ }
+ }
+ else if (cmdParms is NameValueCollection)
+ {
+ NameValueCollection nvc = cmdParms as NameValueCollection;
+ if (nvc != null && nvc.Count > 0)
+ {
+ foreach (var key in nvc.AllKeys)
+ {
+ var parameter = cmd.CreateParameter();
+ parameter.ParameterName = ParameterChar + key;
+ parameter.Value = nvc[key];
+
+ if (parameter.Value == null || parameter.Value == DBNull.Value)
+ {
+ parameter.Value = DBNull.Value;
+ }
+ else
+ {
+ if (tableName != null)
+ {
+ ColumnInfo colInfo = Info[tableName, key];
+ if (colInfo != null)
+ {
+ parameter.DbType = colInfo.DbType;
+
+ parameter.Value = Global.Dict_Convert_Type[colInfo.DbType].Invoke(parameter.Value);
+ }
+ }
+ else
+ {
+ Type tyValue = parameter.Value.GetType();
+ DbType tmpType;
+ if (Global.TypeMap.TryGetValue(tyValue, out tmpType))
+ {
+ parameter.DbType = tmpType;
+ }
+ else
+ {
+ parameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ cmd.Parameters.Add(parameter);
+ }
+ }
+ }
+ else
+ {
+ Type ty = cmdParms.GetType();
+
+ if (ty.Name.Contains("AnonymousType"))
+ {
+ PropertyInfo[] props;
+ if (!Dict_Type_Props.TryGetValue(ty, out props))
+ {
+ Dict_Type_Props[ty] = ty.GetProperties();
+ props = Dict_Type_Props[ty];
+ }
+
+ if (props != null && props.Length > 0)
+ {
+ foreach (var prop in props)
+ {
+ var parameter = cmd.CreateParameter();
+ parameter.ParameterName = ParameterChar + prop.Name;
+ parameter.Value = prop.GetValue(cmdParms, null);
+
+ if (parameter.Value == null || parameter.Value == DBNull.Value)
+ {
+ parameter.Value = DBNull.Value;
+ }
+ else
+ {
+ if (tableName != null)
+ {
+ ColumnInfo colInfo = Info[tableName, prop.Name];
+ if (colInfo != null)
+ {
+ parameter.DbType = colInfo.DbType;
+
+ parameter.Value = Global.Dict_Convert_Type[colInfo.DbType].Invoke(parameter.Value);
+ }
+ }
+ else
+ {
+ Type tyValue = parameter.Value.GetType();
+ DbType tmpType;
+ if (Global.TypeMap.TryGetValue(tyValue, out tmpType))
+ {
+ parameter.DbType = tmpType;
+ }
+ else
+ {
+ parameter.DbType = DbType.AnsiString;
+ }
+ }
+ }
+ cmd.Parameters.Add(parameter);
+ }
+ }
+ }
+ else
+ {
+ //其他类型
+ }
+
+ }
+ }
+
+ if (OnExecuting != null)
+ {
+ OnExecuting.Invoke(cmd);
+ }
+ return cmd;
+ }
+
+ ///
+ /// 尝试 连接字符串 能否 连接成功
+ ///
+ ///
+ public virtual bool TryConnect()
+ {
+ try
+ {
+ using (DbConnection conn = CreateConn())
+ {
+ conn.Open();
+ }
+ return true;
+ }
+ catch
+ {
+ return false;
+ }
+ }
+
+ ///
+ /// Sqlite3 收缩数据库（缓存数据写入到db文件中）
+ ///
+ public void Shrink()
+ {
+ ExecSql("pragma journal_mode=delete;");
+ }
+
+
+ ///
+ /// 验证 执行语句 是否 能执行通过
+ ///
+ ///
+ ///
+ ///
+ public virtual bool ValidateSql(string strSql, out Exception ex)
+ {
+ bool bResult = false;
+ ex = null;
+ DbConnection conn = null;
+ DbCommand cmd = null;
+ int res = -1;
+ try
+ {
+ conn = CreateConn();
+ strSql = "explain " + strSql;
+ cmd = BuildCommand(conn, strSql);
+ res = cmd.ExecuteNonQuery();
+ bResult = true;
+ }
+ catch (Exception e)
+ {
+ ex = e;
+ bResult = false;
+ }
+ finally
+ {
+ conn?.Close();
+ }
+
+ if (OnExecuted != null)
+ {
+ OnExecuted.Invoke(cmd, bResult);
+ }
+ return bResult;
+ }
+
+
+ public virtual int RunStoreProc(string storeProcName, object parameters = null)
+ {
+ DbConnection conn = null;
+ DbCommand cmd = null;
+ int cnt = -1;
+ try
+ {
+ conn = CreateConn();
+ cmd = BuildCommandByParam(conn, storeProcName, parameters, this.CmdTimeout, CommandType.StoredProcedure);
+ cnt = cmd.ExecuteNonQuery();
+ }
+ catch (Exception ex)
+ {
+ if (this.OnError != null)
+ this.OnError.Invoke(cmd, ex);
+ throw ex;
+ }
+ finally
+ {
+ conn?.Close();
+ }
+
+ if (OnExecuted != null)
+ {
+ OnExecuted.Invoke(cmd, cnt);
+ }
+ return cnt;
+ }
+ public virtual DataTable RunStoreProcGetDT(string storeProcName, object parameters = null)
+ {
+ DataSet ds = new DataSet("ds");
+ DbConnection conn = null;
+ DbCommand cmd = null;
+ try
+ {
+ conn = CreateConn();
+ cmd = BuildCommandByParam(conn, storeProcName, parameters, this.CmdTimeout, CommandType.StoredProcedure);
+ DataAdapter adapter = CreateAdapter(cmd);
+ adapter.Fill(ds);
+ }
+ catch (Exception ex)
+ {
+ if (this.OnError != null)
+ this.OnError.Invoke(cmd, ex);
+ throw ex;
+ }
+ finally
+ {
+ conn?.Close();
+ }
+
+ DataTable dt = null;
+ if (ds != null && ds.Tables.Count > 0)
+ {
+ dt = ds.Tables[0];
+ dt.TableName = "data";
+ }
+
+ if (OnExecuted != null)
+ {
+ OnExecuted.Invoke(cmd, dt);
+ }
+ return dt;
+ }
+ public virtual DataSet RunStoreProcGetDS(string storeProcName, object parameters = null)
+ {
+ DataSet ds = new DataSet("ds");
+ DbConnection conn = null;
+ DbCommand cmd = null;
+ try
+ {
+ conn = CreateConn();
+ cmd = BuildCommandByParam(conn, storeProcName, parameters, this.CmdTimeout, CommandType.StoredProcedure);
+ DataAdapter adapter = CreateAdapter(cmd);
+ adapter.Fill(ds);
+ }
+ catch (Exception ex)
+ {
+ if (this.OnError != null)
+ this.OnError.Invoke(cmd, ex);
+ throw ex;
+ }
+ finally
+ {
+ conn?.Close();
+ }
+
+ if (OnExecuted != null)
+ {
+ OnExecuted.Invoke(cmd, ds);
+ }
+ return ds;
+ }
+
+
+
+ #region 基础查询
+
+ public virtual TRet Scalar(string strSql, TRet defRet, object parameters = null)
+ {
+ DbConnection conn = null;
+ DbCommand cmd = null;
+ object obj = null;
+ TRet result;
+ try
+ {
+ conn = CreateConn();
+ cmd = BuildCommandByParam(conn, strSql, parameters);
+ obj = cmd.ExecuteScalar();
+ }
+ catch (Exception ex)
+ {
+ result = defRet;
+ if (this.OnError != null)
+ this.OnError.Invoke(cmd, ex);
+ }
+ finally
+ {
+ conn?.Close();
+ }
+
+ result = obj.ChangeType