import 'bootstrap.css';
import '@mescius/wijmo.styles/wijmo.css';
import './styles.css';
//
import { RestCollectionViewOData } from './rest-collection-view-odata';
import { CollectionViewNavigator } from '@mescius/wijmo.input';
import { FlexGrid } from '@mescius/wijmo.grid';
import { FlexGridFilter } from '@mescius/wijmo.grid.filter';
//
document.readyState === 'complete' ? init() : window.onload = init;
//
function init() {
// Northwind OData service
let urlOData = 'https://services.odata.org/V4/Northwind/Northwind.svc';
// fields and columns to show
let fields = 'CustomerID,CompanyName,ContactName,ContactTitle,Address,City,Region,PostalCode,Country,Phone,Fax'.split(',');
// create the grid to show the data
let theGrid = new FlexGrid('#theGrid', {
isReadOnly: true,
showMarquee: true,
selectionMode: 'MultiRange',
deferResizing: true,
alternatingRowStep: 0,
// create RestCollectionViewOData
itemsSource: new RestCollectionViewOData(urlOData, 'Customers', {
fields: fields,
pageSize: 8,
sortDescriptions: ['CustomerID']
})
});
// auto-number row headers
theGrid.topLeftCells.columns[0].cellTemplate = $ => $.text || ($.row.index + 1).toString();
// add the filter
new FlexGridFilter(theGrid);
// add the navigator
new CollectionViewNavigator('#theNavigator', {
cv: theGrid.collectionView,
byPage: true
});
// toggle pagination
document.getElementById('paging').addEventListener('click', e => {
let paging = e.target.checked, view = theGrid.collectionView;
view.pageSize = paging ? 8 : 0;
});
}
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="utf-8">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title>MESCIUS Wijmo RestCollectionView OData</title>
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<!-- SystemJS -->
<script src="https://cdnjs.cloudflare.com/ajax/libs/systemjs/0.21.5/system.src.js" integrity="sha512-skZbMyvYdNoZfLmiGn5ii6KmklM82rYX2uWctBhzaXPxJgiv4XBwJnFGr5k8s+6tE1pcR1nuTKghozJHyzMcoA==" crossorigin="anonymous"></script>
<script src="systemjs.config.js"></script>
<script>
System.import('./src/app');
</script>
</head>
<body>
<div class="container-fluid">
<label>
Paging
<input id="paging" type="checkbox" checked>
</label>
<br />
<div id="theNavigator"></div>
<div id="theGrid"></div>
</div>
</body>
</html>
body {
margin-bottom: 36pt;
}
.wj-flexgrid {
max-height: 400px;
}
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { RestCollectionView } from '@mescius/wijmo.rest';
import { DataType, DateTime, httpRequest, copy, changeType, isString, isDate, asString, asNumber, isNumber, asArray, assert } from '@mescius/wijmo';
// regex used to parse dates
const _rxDate = /^\d{4}\-\d{2}\-\d{2}T\d{2}\:\d{2}\:\d{2}|\/Date\([\d\-]*?\)/;
/**
* Class that extends {@link ServerCollectionViewBase} to support OData sources.
*/
export class RestCollectionViewOData extends RestCollectionView {
/**
* Initializes a new instance of the {@link RestCollectionViewOData} class.
*
* @param url Url of the OData service (for example
* 'https://services.odata.org/Northwind/Northwind.svc/').
* @param tableName Name of the table (entity) to retrieve from the service.
* If not provided, a list of the tables (entities) available is retrieved.
* @param options JavaScript object containing initialization data (property
* values and event handlers) for the {@link ODataCollectionView}.
*/
constructor(url, tableName, options) {
super();
this._odv = 4; // OData Version
this._url = asString(url, false);
this._tbl = asString(tableName);
copy(this, options);
}
/**
* Gets or sets an array containing the names of the key fields.
*
* Key fields are required for update operations (add/remove/delete).
*/
get keys() {
return this._keys;
}
set keys(value) {
this._keys = asArray(value);
}
/**
* Gets or sets the OData version to use.
*/
get odataVersion() {
return this._odv;
}
set odataVersion(value) {
this._odv = asNumber(value);
}
// ** implementation
// URL handling
_getServiceUrl() {
let url = this._url;
if (url[url.length - 1] != '/') {
url += '/';
}
return url;
}
_getReadUrl(link) {
let url = this._getServiceUrl();
if (link) {
url = link.indexOf('http') == 0 ? link : url + link;
}
else if (this._tbl) {
url += this._tbl;
}
return url;
}
_getWriteUrl(item) {
let url = this._getServiceUrl() + this._tbl;
if (item) {
assert(this.keys && this.keys.length > 0, 'write operations require keys.');
let keys = [];
this.keys.forEach(key => {
let itemKey = item[key];
if (itemKey == null) {
itemKey = '';
}
if (isString(itemKey)) { // enclose string keys in quotes
itemKey = '\'' + itemKey + '\'';
}
keys.push(this.keys.length == 1 // add key name only if we have multiple keys
? itemKey
: key + '=' + itemKey);
});
if (keys.length) {
url += '(' + keys.join(',') + ')';
}
}
return url;
}
// read parameters apply fields, sort, paging, and filter
_getReadParams(nextLink) {
let settings = {};
// we only do json
if (!nextLink || (nextLink.indexOf('$format') < 0 && nextLink.indexOf('%24format') < 0)) {
settings.$format = 'json';
}
// no parameters needed if they are already on the nextLink argument
if (!nextLink) {
// more setting if we have a table
if (this._tbl) {
// get filtered (but not paged) item count (OData4 uses $count, earlier versions use $inlinecount)
if (this._odv < 4) {
settings.$inlinecount = 'allpages';
}
else {
settings.$count = true;
}
// specify fields to retrieve
if (this.fields) {
settings.$select = this.fields.join(',');
}
// apply sort
if (this.sortOnServer && this.sortDescriptions.length) {
let sort = '';
this.sortDescriptions.forEach(sd => {
if (sort)
sort += ',';
sort += sd.property;
if (!sd.ascending)
sort += ' desc';
});
settings.$orderby = sort;
}
// apply paging
if (this.pageOnServer && this.pageSize > 0) {
settings.$skip = this.pageIndex * this.pageSize;
settings.$top = this.pageSize;
}
// apply filter
if (this.filterOnServer && this._filterProvider) {
settings.$filter = this._asODataFilter(this._filterProvider);
}
}
}
return settings;
}
// parse data
_jsonReviver(key, value) {
if (typeof value === 'string' && _rxDate.test(value)) {
value = value.indexOf('/Date(') == 0 // verbosejson
? new Date(parseInt(value.substr(6)))
: new Date(value);
}
return value;
}
// gets the OData filter definition from a wijmo.grid.filter.FlexGridFilter object.
// https://www.odata.org/documentation/odata-version-2-0/uri-conventions/
_asODataFilter(filter) {
let def = '';
for (let c = 0; c < filter.grid.columns.length; c++) {
let col = filter.grid.columns[c], cf = filter.getColumnFilter(col, false);
if (cf && cf.isActive) {
if (def) {
def += ' and ';
}
if (cf.conditionFilter && cf.conditionFilter.isActive) {
def += this._asODataConditionFilter(cf.conditionFilter);
}
else if (cf.valueFilter && cf.valueFilter.isActive) {
def += this._asODataValueFilter(cf.valueFilter);
}
}
}
return def;
}
_asODataValueFilter(vf) {
let col = vf.column, fld = col.binding, map = col.dataMap, def = '';
// build condition with 'eq/or'
for (let key in vf.showValues) {
let value = changeType(key, col.dataType, col.format);
if (map && isString(value)) { // TFS 239356
value = map.getKeyValue(value);
}
if (def)
def += ' or ';
def += this._asEquals(fld, value, col.dataType);
}
// enclose in parenthesis if not empty
if (def.length) {
def = '(' + def + ')';
}
// all done
return def;
}
_asEquals(fld, value, type) {
let def = '', DT = DataType;
if (value === '' || value == null) { // null or empty
def += fld + ' eq null';
if (type == DT.String) { // empty OK for strings only
def += ' or ' + fld + ' eq \'\'';
}
}
else if (type == DT.Date) { // non-null/empty dates (TFS 458080)
def += fld + ' ge ' + this._asODataValue(value, type) + ' and ' +
fld + ' lt ' + this._asODataValue(DateTime.addDays(value, 1), type);
}
else { // other types
def += fld + ' eq ' + this._asODataValue(value, type);
}
return '(' + def + ')';
}
_asODataConditionFilter(cf) {
let c1 = this._asODataCondition(cf, cf.condition1), c2 = this._asODataCondition(cf, cf.condition2);
if (c1 && c2)
return '(' + c1 + (cf.and ? ' and ' : ' or ') + c2 + ')';
if (c1)
return '(' + c1 + ')';
if (c2)
return '(' + c2 + ')';
return null;
}
_asODataCondition(cf, cnd) {
let col = cf.column, fld = col.binding, map = col.dataMap, value = cnd.value;
if (map && isString(value)) { // TFS 440901
value = map.getKeyValue(value);
}
value = this._asODataValue(value, cf.column.dataType);
switch (cnd.operator) {
case 0: // EQ = 0,
return fld + ' eq ' + value;
case 1: // NE = 1,
return fld + ' ne ' + value;
case 2: // GT = 2,
return fld + ' gt ' + value;
case 3: // GE = 3,
return fld + ' ge ' + value;
case 4: // LT = 4,
return fld + ' lt ' + value;
case 5: // LE = 5,
return fld + ' le ' + value;
case 6: // BW = 6,
return 'startswith(' + fld + ',' + value + ')';
case 7: // EW = 7,
return 'endswith(' + fld + ',' + value + ')';
case 8: // CT = 8,
return this._odv >= 4
? 'contains(' + fld + ',' + value + ')' // OData4
: 'substringof(' + value.toLowerCase() + ', tolower(' + fld + '))'; // OData2
case 9: // NC = 9
return this._odv >= 4
? 'not contains(' + fld + ',' + value + ')' // OData4
: 'not substringof(' + value.toLowerCase() + ', tolower(' + fld + '))'; // OData2
}
}
_asODataValue(value, dataType) {
if (isDate(value)) {
value = value.toJSON();
if (this._odv < 4) { // TFS 323961
value = "datetime'" + value.substr(0, 10) + "'";
}
return value;
}
else if (isString(value)) {
return "'" + value.replace(/'/g, "''") + "'";
}
else if (value != null) {
return value.toString();
}
return dataType == DataType.String ? "''" : null;
}
// convert objects before posting to OData services
_convertToDbFormat(item) {
if (this._odv >= 4) {
return item;
}
let obj = {};
for (let key in item) {
let value = item[key];
if (isNumber(value)) {
// convert numbers to strings in versions prior to 4.0.
// failing to do this may cause the service to throw an error:
// 'Cannot convert a primitive value to the expected type'
// which can in turn causes an HTTP 400 (Bad Request) error
value = value.toString();
}
obj[key] = value;
}
return obj;
}
// ** overrides
getItems(link) {
return __awaiter(this, void 0, void 0, function* () {
// cancel any pending requests
if (this._pendingRequest) {
//console.log('aborting pending request');
this._pendingRequest.abort();
}
return new Promise(resolve => {
this._pendingRequest = httpRequest(this._getReadUrl(link), {
requestHeaders: this.requestHeaders,
data: this._getReadParams(link),
success: (xhr) => __awaiter(this, void 0, void 0, function* () {
// parse response (handles OData4 and earlier)
let resp = JSON.parse(xhr.responseText, this._jsonReviver), arr = resp.d ? resp.d.results : resp.value, count = resp.d ? resp.d.__count : (resp['odata.count'] || resp['@odata.count']), nextLink = resp.d ? resp.d.__next : (resp['odata.nextLink'] || resp['@odata.nextLink']);
// update total item count
if (count != null) {
this._totalItemCount = isString(count) ? parseInt(count) : count;
}
// get data from next link
if (nextLink) {
let nextPage = yield this.getItems(nextLink);
arr = arr.concat(nextPage);
}
// done
resolve(arr);
}),
error: xhr => this._raiseError(xhr.responseText, false),
complete: xhr => this._pendingRequest = null // no pending requests
});
});
});
}
addItem(item) {
// write operations require keys
if (!this.keys || !this.keys.length) {
return null;
}
return new Promise(resolve => {
let url = this._getWriteUrl();
let requestHeaders = {
'Accept': 'application/json'
};
if (this.requestHeaders) {
for (let k in this.requestHeaders) {
requestHeaders[k] = this.requestHeaders[k];
}
}
httpRequest(url, {
method: 'POST',
requestHeaders: requestHeaders,
data: this._convertToDbFormat(item),
success: xhr => {
let newItem = JSON.parse(xhr.responseText, this._jsonReviver);
this.keys.forEach(key => {
item[key] = newItem[key];
});
this.refresh();
},
error: xhr => this._raiseError(xhr.responseText, true)
});
});
}
patchItem(item) {
// write operations require keys
if (!this.keys || !this.keys.length) {
return null;
}
return new Promise((resolve) => {
let url = this._getWriteUrl(this._edtClone);
httpRequest(url, {
method: 'PATCH',
requestHeaders: this.requestHeaders,
data: this._convertToDbFormat(item),
success: xhr => resolve(item),
error: xhr => this._raiseError(xhr.responseText, true)
});
});
}
deleteItem(item) {
// write operations require keys
if (!this.keys || !this.keys.length) {
return null;
}
return new Promise(resolve => {
let url = this._getWriteUrl(item);
httpRequest(url, {
method: 'DELETE',
requestHeaders: this.requestHeaders,
success: xhr => {
resolve(item);
},
error: xhr => this._raiseError(xhr.responseText, true)
});
});
}
}
(function (global) {
System.config({
transpiler: 'plugin-babel',
babelOptions: {
es2015: true
},
meta: {
'*.css': { loader: 'css' }
},
paths: {
// paths serve as alias
'npm:': 'node_modules/'
},
// map tells the System loader where to look for things
map: {
'jszip': 'npm:jszip/dist/jszip.js',
'@mescius/wijmo': 'npm:@mescius/wijmo/index.js',
'@mescius/wijmo.input': 'npm:@mescius/wijmo.input/index.js',
'@mescius/wijmo.styles': 'npm:@mescius/wijmo.styles',
'@mescius/wijmo.cultures': 'npm:@mescius/wijmo.cultures',
'@mescius/wijmo.chart': 'npm:@mescius/wijmo.chart/index.js',
'@mescius/wijmo.chart.analytics': 'npm:@mescius/wijmo.chart.analytics/index.js',
'@mescius/wijmo.chart.animation': 'npm:@mescius/wijmo.chart.animation/index.js',
'@mescius/wijmo.chart.annotation': 'npm:@mescius/wijmo.chart.annotation/index.js',
'@mescius/wijmo.chart.finance': 'npm:@mescius/wijmo.chart.finance/index.js',
'@mescius/wijmo.chart.finance.analytics': 'npm:@mescius/wijmo.chart.finance.analytics/index.js',
'@mescius/wijmo.chart.hierarchical': 'npm:@mescius/wijmo.chart.hierarchical/index.js',
'@mescius/wijmo.chart.interaction': 'npm:@mescius/wijmo.chart.interaction/index.js',
'@mescius/wijmo.chart.radar': 'npm:@mescius/wijmo.chart.radar/index.js',
'@mescius/wijmo.chart.render': 'npm:@mescius/wijmo.chart.render/index.js',
'@mescius/wijmo.chart.webgl': 'npm:@mescius/wijmo.chart.webgl/index.js',
'@mescius/wijmo.chart.map': 'npm:@mescius/wijmo.chart.map/index.js',
'@mescius/wijmo.gauge': 'npm:@mescius/wijmo.gauge/index.js',
'@mescius/wijmo.grid': 'npm:@mescius/wijmo.grid/index.js',
'@mescius/wijmo.grid.detail': 'npm:@mescius/wijmo.grid.detail/index.js',
'@mescius/wijmo.grid.filter': 'npm:@mescius/wijmo.grid.filter/index.js',
'@mescius/wijmo.grid.search': 'npm:@mescius/wijmo.grid.search/index.js',
'@mescius/wijmo.grid.grouppanel': 'npm:@mescius/wijmo.grid.grouppanel/index.js',
'@mescius/wijmo.grid.multirow': 'npm:@mescius/wijmo.grid.multirow/index.js',
'@mescius/wijmo.grid.transposed': 'npm:@mescius/wijmo.grid.transposed/index.js',
'@mescius/wijmo.grid.transposedmultirow': 'npm:@mescius/wijmo.grid.transposedmultirow/index.js',
'@mescius/wijmo.grid.pdf': 'npm:@mescius/wijmo.grid.pdf/index.js',
'@mescius/wijmo.grid.sheet': 'npm:@mescius/wijmo.grid.sheet/index.js',
'@mescius/wijmo.grid.xlsx': 'npm:@mescius/wijmo.grid.xlsx/index.js',
'@mescius/wijmo.grid.selector': 'npm:@mescius/wijmo.grid.selector/index.js',
'@mescius/wijmo.grid.cellmaker': 'npm:@mescius/wijmo.grid.cellmaker/index.js',
'@mescius/wijmo.nav': 'npm:@mescius/wijmo.nav/index.js',
'@mescius/wijmo.odata': 'npm:@mescius/wijmo.odata/index.js',
'@mescius/wijmo.olap': 'npm:@mescius/wijmo.olap/index.js',
'@mescius/wijmo.rest': 'npm:@mescius/wijmo.rest/index.js',
'@mescius/wijmo.pdf': 'npm:@mescius/wijmo.pdf/index.js',
'@mescius/wijmo.pdf.security': 'npm:@mescius/wijmo.pdf.security/index.js',
'@mescius/wijmo.viewer': 'npm:@mescius/wijmo.viewer/index.js',
'@mescius/wijmo.xlsx': 'npm:@mescius/wijmo.xlsx/index.js',
'@mescius/wijmo.undo': 'npm:@mescius/wijmo.undo/index.js',
'@mescius/wijmo.interop.grid': 'npm:@mescius/wijmo.interop.grid/index.js',
'@mescius/wijmo.touch': 'npm:@mescius/wijmo.touch/index.js',
'@mescius/wijmo.cloud': 'npm:@mescius/wijmo.cloud/index.js',
'@mescius/wijmo.barcode': 'npm:@mescius/wijmo.barcode/index.js',
'@mescius/wijmo.barcode.common': 'npm:@mescius/wijmo.barcode.common/index.js',
'@mescius/wijmo.barcode.composite': 'npm:@mescius/wijmo.barcode.composite/index.js',
'@mescius/wijmo.barcode.specialized': 'npm:@mescius/wijmo.barcode.specialized/index.js',
'jszip': 'npm:jszip/dist/jszip.js',
'bootstrap.css': 'npm:bootstrap/dist/css/bootstrap.min.css',
'css': 'npm:systemjs-plugin-css/css.js',
'plugin-babel': 'npm:systemjs-plugin-babel/plugin-babel.js',
'systemjs-babel-build':'npm:systemjs-plugin-babel/systemjs-babel-browser.js'
},
// packages tells the System loader how to load when no filename and/or no extension
packages: {
src: {
defaultExtension: 'js'
},
"node_modules": {
defaultExtension: 'js'
},
}
});
})(this);
