Compare commits
41 Commits
abdbb67471
...
v7.0.0
Author | SHA1 | Date | |
---|---|---|---|
8c60473c15 | |||
bb126eba5b | |||
d1998422d2 | |||
69f687a85f | |||
2aa19d1dca | |||
e44a25dcc3 | |||
efb5ffa906 | |||
b4c586a859 | |||
e874143a95 | |||
e4dbab8b16 | |||
f6d7d6f90c | |||
063c90caf4 | |||
2011c2eee7 | |||
24545f2acd | |||
a7c81245ff | |||
4f2c993b2d | |||
e5f8e500c1 | |||
a61e2de140 | |||
881d2b060e | |||
4830c6d219 | |||
4c3c9ac88c | |||
7e1c610a4d | |||
8139f495ce | |||
89ab296151 | |||
a0dc92c403 | |||
86134f478a | |||
9a2addc18e | |||
9264ce2a60 | |||
cbd69df708 | |||
ca7caa25b6 | |||
c10330627f | |||
d80c59afce | |||
d2097ad6dd | |||
1bd542cddb | |||
fb1c1ee874 | |||
624a7a8f37 | |||
381378f532 | |||
af05486c0e | |||
4b558948d9 | |||
d9cff42f5c | |||
2a3d2b8d0d |
@ -1,11 +1,12 @@
|
||||
#!/bin/sh
|
||||
|
||||
# Avoid commits to the master branch
|
||||
BRANCH=`git rev-parse --abbrev-ref HEAD`
|
||||
REGEX="^(master|development)$"
|
||||
# Using `--silent` helps for showing any errs in the first line of the response
|
||||
# The first line is picked up by the VS Code GIT UI popup when rc is not 0
|
||||
|
||||
if [[ "$BRANCH" =~ $REGEX ]]; then
|
||||
echo "You are on branch $BRANCH. Are you sure you want to commit to this branch?"
|
||||
echo "If so, commit with -n to bypass the pre-commit hook."
|
||||
exit 1
|
||||
if npm run --silent lint:silent ; then
|
||||
exit 0
|
||||
else
|
||||
npm run --silent lint:fix
|
||||
echo "❌ Prettier check failed! We ran lint:fix for you. Please add & commit again."
|
||||
exit 1
|
||||
fi
|
||||
|
@ -237,20 +237,20 @@ jobs:
|
||||
cd sas
|
||||
sasjs c -t viya
|
||||
rm -rf sasjsbuild/tests
|
||||
sed -i -e 's/servertype="SASJS"/servertype="SASVIYA"/g' sasjsbuild/services/clickme.html
|
||||
sasjs b -t viya
|
||||
cp sasjsbuild/viya.sas ./demostream_viya.sas
|
||||
# compile Viya Full deploy (without web)
|
||||
rm -rf sasjsbuild/services/web
|
||||
rm sasjsbuild/services/clickme.html
|
||||
sed -i -e 's/servertype="SASJS"/servertype="SASVIYA"/g' sasjsbuild/services/DC.html
|
||||
sasjs b -t viya
|
||||
cp sasjsbuild/viya.sas ./viya.sas
|
||||
cp sasjsbuild/viya.json ./viya.json
|
||||
# compile Viya Full deploy (without web)
|
||||
rm -rf sasjsbuild/services/web
|
||||
rm sasjsbuild/services/DC.html
|
||||
sasjs b -t viya
|
||||
cp sasjsbuild/viya.sas ./viya_noweb.sas
|
||||
cp sasjsbuild/viya.json ./viya_noweb.json
|
||||
|
||||
- name: Zip Frontend (including viya.json for full viya deploy)
|
||||
run: |
|
||||
cd sas
|
||||
cp sasjsbuild/viya.json ../client/dist
|
||||
cp sasjsbuild/viya.json ../client/dist/viya.json
|
||||
cd ..
|
||||
zip -r frontend.zip ./client/dist
|
||||
|
||||
@ -277,8 +277,8 @@ jobs:
|
||||
URL="https://git.datacontroller.io/api/v1/repos/dc/dc/releases/$RELEASE_ID/assets?access_token=${{ secrets.RELEASE_TOKEN }}"
|
||||
curl -k $URL -F attachment=@frontend.zip
|
||||
curl -k $URL -F attachment=@sas/demostream_sas9.sas
|
||||
curl -k $URL -F attachment=@sas/demostream_viya.sas
|
||||
curl -k $URL -F attachment=@sas/viya.sas
|
||||
curl -k $URL -F attachment=@sas/sasjs_server.json.zip
|
||||
curl -k $URL -F attachment=@sas/sas9.sas
|
||||
curl -k $URL -F attachment=@sas/viya.sas
|
||||
curl -k $URL -F attachment=@sas/viya.json
|
||||
curl -k $URL -F attachment=@sas/viya_noweb.sas
|
||||
curl -k $URL -F attachment=@sas/viya_noweb.json
|
||||
|
80
CHANGELOG.md
80
CHANGELOG.md
@ -1,3 +1,83 @@
|
||||
# [7.0.0](https://git.datacontroller.io/dc/dc/compare/v6.16.2...v7.0.0) (2025-06-11)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* bumping adapter to re-enable JES API method ([e874143](https://git.datacontroller.io/dc/dc/commit/e874143a95d0ac2e56c0793e04b979c27f96d74b))
|
||||
* commit git hooks checking lint ([69f687a](https://git.datacontroller.io/dc/dc/commit/69f687a85f1cc562346b6167813d617cb9bd3404))
|
||||
* ensuring apploc is not case sensitive. Closes [#171](https://git.datacontroller.io/dc/dc/issues/171) ([24545f2](https://git.datacontroller.io/dc/dc/commit/24545f2acdd5bd73cbe062526f2bd043269cc6a3))
|
||||
* export unregistered formats ([f6d7d6f](https://git.datacontroller.io/dc/dc/commit/f6d7d6f90c978ac8c071471dfb67a60834424de5)), closes [#158](https://git.datacontroller.io/dc/dc/issues/158)
|
||||
* reload startupservice after user approves the MPE_TABLES page ([e5f8e50](https://git.datacontroller.io/dc/dc/commit/e5f8e500c125ee233c6f7af5ad0077c0ed6abfcb))
|
||||
* showing catalog_cnt in libinfo ([e44a25d](https://git.datacontroller.io/dc/dc/commit/e44a25dcc39ba4b9714257c60da84c2dfa613a85)), closes [#160](https://git.datacontroller.io/dc/dc/issues/160)
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* adding 4 new tables for catalogs ([e4dbab8](https://git.datacontroller.io/dc/dc/commit/e4dbab8b1654b24e610e4b0603d1cf2b02a451e2))
|
||||
* capturing catalog specific information, closes [#159](https://git.datacontroller.io/dc/dc/issues/159) ([b4c586a](https://git.datacontroller.io/dc/dc/commit/b4c586a859929e0122cd46449e43d4ca597b8b2b))
|
||||
* viewer added catalog_cnt ([2aa19d1](https://git.datacontroller.io/dc/dc/commit/2aa19d1dca747f41274a032cde78d8ba73d66224))
|
||||
|
||||
|
||||
### BREAKING CHANGES
|
||||
|
||||
* Introduction of 4 new tables for capturing information related to catalogs and their objects. Migration script prepared and available in the DB folder (usual place)
|
||||
|
||||
## [6.16.2](https://git.datacontroller.io/dc/dc/compare/v6.16.1...v6.16.2) (2025-06-06)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* streaming viya deploy `isStreaming` function stability fix ([4830c6d](https://git.datacontroller.io/dc/dc/commit/4830c6d2191cb47abcc7919bc1d49e55595e6121))
|
||||
|
||||
## [6.16.1](https://git.datacontroller.io/dc/dc/compare/v6.16.0...v6.16.1) (2025-06-06)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* viya deploy updating index html based on URL ([86134f4](https://git.datacontroller.io/dc/dc/commit/86134f478ae0b9426e01bfcc9ca4ee597ca733f7))
|
||||
* viya streamed app deploy page flow fix ([89ab296](https://git.datacontroller.io/dc/dc/commit/89ab2961513b245eeea48d1867c6496d3261761e))
|
||||
|
||||
# [6.16.0](https://git.datacontroller.io/dc/dc/compare/v6.15.2...v6.16.0) (2025-06-05)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* adapter bump ([ca7caa2](https://git.datacontroller.io/dc/dc/commit/ca7caa25b6eea1bd4579fb8b67ec9b211a893079))
|
||||
* automatic viya deploy timing issue ([037a97b](https://git.datacontroller.io/dc/dc/commit/037a97b6ffa27b40891531ae6812ebe5b5e71e34))
|
||||
* bump core to ensure ff works on viya streaming deploy ([cbd69df](https://git.datacontroller.io/dc/dc/commit/cbd69df708edf3a8446115ca7315fac3557dcf97)), closes [#156](https://git.datacontroller.io/dc/dc/issues/156)
|
||||
* viya deploy load data timing ([abdbb67](https://git.datacontroller.io/dc/dc/commit/abdbb674713796e5308eb4272197a5c253868a85))
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* viya deploy, update the index.html contextname ([7223955](https://git.datacontroller.io/dc/dc/commit/72239558af2ee50cdfc71b7e185e6661ab568ba1))
|
||||
|
||||
## [6.15.2](https://git.datacontroller.io/dc/dc/compare/v6.15.1...v6.15.2) (2025-06-04)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* pipeline updates for DC.html ([624a7a8](https://git.datacontroller.io/dc/dc/commit/624a7a8f37f0265cf576da310ac330c75aa417cf))
|
||||
|
||||
## [6.15.1](https://git.datacontroller.io/dc/dc/compare/v6.15.0...v6.15.1) (2025-06-04)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* updating pipeline to default to streaming on viya ([4b55894](https://git.datacontroller.io/dc/dc/commit/4b558948d997f456ff25a12a58827fe0d2075493))
|
||||
|
||||
# [6.15.0](https://git.datacontroller.io/dc/dc/compare/v6.14.10...v6.15.0) (2025-06-04)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* makedata with context name ([da4d0b2](https://git.datacontroller.io/dc/dc/commit/da4d0b28c7109afd6f96455e1e0e80a40d25a942))
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* viya deploy context ([6c96ef7](https://git.datacontroller.io/dc/dc/commit/6c96ef7fb0a55754a84ff0a8bbab838b78c1acaf))
|
||||
|
||||
## [6.14.10](https://git.datacontroller.io/dc/dc/compare/v6.14.9...v6.14.10) (2025-06-02)
|
||||
|
||||
|
||||
|
11
README.md
11
README.md
@ -23,7 +23,16 @@ _Problems with the above include:_
|
||||
|
||||
Data Controller for SAS® solves all these issues in a simple-to-install, user-friendly, secure, documented, battle-tested web application. Available on Viya, SAS 9 EBI, and [SASjs Server](https://server.sasjs.io).
|
||||
|
||||
For more information:
|
||||
An individual Viya deploy can be done in just 2 lines of #SAS code!
|
||||
|
||||
```sas
|
||||
filename dc url "https://git.datacontroller.io/dc/dc/releases/download/latest/viya.sas";
|
||||
%inc dc;
|
||||
```
|
||||
|
||||
For a multi-user deploy, using a shared system account, please see [deploy docs](https://docs.datacontroller.io/deploy-viya/).
|
||||
|
||||
For further information:
|
||||
|
||||
* Main site: https://datacontroller.io
|
||||
* Docs: https://docs.datacontroller.io
|
||||
|
8
client/package-lock.json
generated
8
client/package-lock.json
generated
@ -21,7 +21,7 @@
|
||||
"@clr/icons": "^13.0.2",
|
||||
"@clr/ui": "file:libraries/clr-ui-17.9.0.tgz",
|
||||
"@handsontable/angular": "^15.3.0",
|
||||
"@sasjs/adapter": "^4.11.0",
|
||||
"@sasjs/adapter": "^4.12.1",
|
||||
"@sasjs/utils": "^3.4.0",
|
||||
"@sheet/crypto": "file:libraries/sheet-crypto.tgz",
|
||||
"@types/d3-graphviz": "^2.6.7",
|
||||
@ -5912,9 +5912,9 @@
|
||||
]
|
||||
},
|
||||
"node_modules/@sasjs/adapter": {
|
||||
"version": "4.11.3",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/adapter/-/adapter-4.11.3.tgz",
|
||||
"integrity": "sha512-KF6G4vzs4l4efjpCD02og3kB44uFfJ1u2UWu749VdHtLKNN9l+PO26/moR+YAmRmmz2I9sC3X09fZE1nlN6zgw==",
|
||||
"version": "4.12.1",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/adapter/-/adapter-4.12.1.tgz",
|
||||
"integrity": "sha512-0217oZIkrecOyQygRe6Azgc1C4TIcjB5noi15fU4Rd5GsfDpleKVfQQdzYZ7im/vesWlLIVl/yUT67MMaQe0ew==",
|
||||
"hasInstallScript": true,
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
|
@ -49,7 +49,7 @@
|
||||
"@clr/icons": "^13.0.2",
|
||||
"@clr/ui": "file:libraries/clr-ui-17.9.0.tgz",
|
||||
"@handsontable/angular": "^15.3.0",
|
||||
"@sasjs/adapter": "^4.11.0",
|
||||
"@sasjs/adapter": "^4.12.1",
|
||||
"@sasjs/utils": "^3.4.0",
|
||||
"@sheet/crypto": "file:libraries/sheet-crypto.tgz",
|
||||
"@types/d3-graphviz": "^2.6.7",
|
||||
|
@ -8,6 +8,7 @@ import {
|
||||
} from '@angular/core'
|
||||
import SASjs, { SASjsConfig } from '@sasjs/adapter'
|
||||
import { DcAdapterSettings } from 'src/app/models/DcAdapterSettings'
|
||||
import { HelperService } from 'src/app/services'
|
||||
import { DeployService } from 'src/app/services/deploy.service'
|
||||
import { EventService } from 'src/app/services/event.service'
|
||||
import { LoggerService } from 'src/app/services/logger.service'
|
||||
@ -82,7 +83,8 @@ export class AutomaticComponent implements OnInit {
|
||||
private deployService: DeployService,
|
||||
private sasService: SasService,
|
||||
private sasViyaService: SasViyaService,
|
||||
private loggerService: LoggerService
|
||||
private loggerService: LoggerService,
|
||||
private helperService: HelperService
|
||||
) {}
|
||||
|
||||
ngOnInit(): void {
|
||||
@ -325,7 +327,8 @@ export class AutomaticComponent implements OnInit {
|
||||
})
|
||||
}
|
||||
|
||||
this.updateIndexHtmlComputeContext()
|
||||
if (this.helperService.isStreamingViya())
|
||||
this.updateIndexHtmlComputeContext()
|
||||
})
|
||||
.catch((err: any) => {
|
||||
this.eventService.showAbortModal('makedata', JSON.stringify(err))
|
||||
@ -341,18 +344,29 @@ export class AutomaticComponent implements OnInit {
|
||||
}
|
||||
|
||||
/**
|
||||
* Only when on Viya, this method will update the `contextname` in the `DataController.html` on the SAS drive
|
||||
* Only when on Viya streamed app, this method will update the `contextname` in the `index.html` on the SAS drive
|
||||
* This is needed to ensure that the DC will use the same compute context `makedata` service used to run against.
|
||||
*/
|
||||
public async updateIndexHtmlComputeContext() {
|
||||
const filenamePath = location.search.split('/').pop()
|
||||
const filename = filenamePath?.includes('.') ? filenamePath : undefined
|
||||
|
||||
if (!filename) {
|
||||
this.eventService.showAbortModal(
|
||||
null,
|
||||
'We could not figure out the file name of `index.html` based on the url.'
|
||||
)
|
||||
return
|
||||
}
|
||||
|
||||
const indexHtmlContent = await this.sasService.getFileContent(
|
||||
`${this.appLoc}/services`,
|
||||
'DataController.html'
|
||||
filename
|
||||
)
|
||||
|
||||
if (!indexHtmlContent) {
|
||||
this.loggerService.error(
|
||||
`Failed to get DataController.html at ${this.appLoc}/services`
|
||||
`Failed to get ${filename} at ${this.appLoc}/services`
|
||||
)
|
||||
return
|
||||
}
|
||||
@ -374,11 +388,7 @@ export class AutomaticComponent implements OnInit {
|
||||
)
|
||||
|
||||
await this.sasService
|
||||
.updateFileContent(
|
||||
`${this.appLoc}/services`,
|
||||
'DataController.html',
|
||||
updatedContent
|
||||
)
|
||||
.updateFileContent(`${this.appLoc}/services`, filename, updatedContent)
|
||||
.catch((err: any) => {
|
||||
this.loggerService.error(`Failed to update DataController.html: ${err}`)
|
||||
})
|
||||
|
@ -8,4 +8,5 @@ export interface Libinfo {
|
||||
LIBID: string
|
||||
LIBSIZE: number
|
||||
TABLE_CNT: number
|
||||
CATALOG_CNT: number
|
||||
}
|
||||
|
@ -1,30 +1,14 @@
|
||||
import { BaseSASResponse } from './common/BaseSASResponse'
|
||||
|
||||
export interface EditorsStageDataSASResponse extends BaseSASResponse {
|
||||
SYSDATE: string
|
||||
SYSTIME: string
|
||||
sasparams: Sasparam[]
|
||||
_DEBUG: string
|
||||
_PROGRAM: string
|
||||
AUTOEXEC: string
|
||||
MF_GETUSER: string
|
||||
SYSCC: string
|
||||
SYSENCODING: string
|
||||
SYSERRORTEXT: string
|
||||
SYSHOSTINFOLONG: string
|
||||
SYSHOSTNAME: string
|
||||
SYSPROCESSID: string
|
||||
SYSPROCESSMODE: string
|
||||
SYSPROCESSNAME: string
|
||||
SYSJOBID: string
|
||||
SYSSCPL: string
|
||||
SYSSITE: string
|
||||
SYSTCPIPHOSTNAME: string
|
||||
SYSUSERID: string
|
||||
SYSVLONG: string
|
||||
SYSWARNINGTEXT: string
|
||||
END_DTTM: string
|
||||
MEMSIZE: string
|
||||
}
|
||||
|
||||
export interface Sasparam {
|
||||
|
28
client/src/app/models/sas/public-getchangeinfo.model.ts
Normal file
28
client/src/app/models/sas/public-getchangeinfo.model.ts
Normal file
@ -0,0 +1,28 @@
|
||||
import { BaseSASResponse } from './common/BaseSASResponse'
|
||||
|
||||
export interface PublicGetChangeinfo extends BaseSASResponse {
|
||||
jsparams: Jsparam[]
|
||||
}
|
||||
|
||||
export interface Jsparam {
|
||||
TABLE_ID: string
|
||||
SUBMIT_STATUS_CD: string
|
||||
BASE_LIB: string
|
||||
BASE_DS: string
|
||||
SUBMITTED_BY_NM: string
|
||||
SUBMITTED_ON: number
|
||||
SUBMITTED_REASON_TXT: string
|
||||
INPUT_OBS: number
|
||||
INPUT_VARS: number
|
||||
NUM_OF_APPROVALS_REQUIRED: number
|
||||
NUM_OF_APPROVALS_REMAINING: number
|
||||
REVIEWED_BY_NM: string
|
||||
REVIEWED_ON?: any
|
||||
TABLE_NM: string
|
||||
BASE_TABLE: string
|
||||
REVIEWED_ON_DTTM: string
|
||||
SUBMITTED_ON_DTTM: string
|
||||
LIB_ENGINE: string
|
||||
ALLOW_RESTORE: string
|
||||
REASON: string
|
||||
}
|
@ -13,6 +13,8 @@ import {
|
||||
AuditorsPostdataSASResponse,
|
||||
Param
|
||||
} from '../../models/sas/auditors-postdata.model'
|
||||
import { PublicGetChangeinfo } from 'src/app/models/sas/public-getchangeinfo.model'
|
||||
import { SasService } from 'src/app/services'
|
||||
|
||||
interface ChangesObj {
|
||||
ind: any
|
||||
@ -76,9 +78,11 @@ export class ApproveDetailsComponent implements AfterViewInit, OnDestroy {
|
||||
|
||||
public diffsLimit: boolean = false
|
||||
public recordsLimit: number = 100
|
||||
public refreshStartupserviceAfterApprove: boolean = false
|
||||
|
||||
constructor(
|
||||
private sasStoreService: SasStoreService,
|
||||
private sasService: SasService,
|
||||
private eventService: EventService,
|
||||
private router: ActivatedRoute,
|
||||
private route: Router
|
||||
@ -162,6 +166,9 @@ export class ApproveDetailsComponent implements AfterViewInit, OnDestroy {
|
||||
await this.sasStoreService
|
||||
.approveTable(approveParams, 'SASControlTable', 'auditors/postdata')
|
||||
.then((res: any) => {
|
||||
// If we are approving MPE_TABLES we will arm the trigger for the reload of startup data to se the updated tables
|
||||
if (this.refreshStartupserviceAfterApprove)
|
||||
this.sasService.reloadStartupData()
|
||||
this.route.navigateByUrl('/review/history')
|
||||
})
|
||||
.catch((err: any) => {
|
||||
@ -176,7 +183,7 @@ export class ApproveDetailsComponent implements AfterViewInit, OnDestroy {
|
||||
public async callChangesInfo(tableId: any) {
|
||||
await this.sasStoreService
|
||||
.getChangeInfo(tableId)
|
||||
.then((res: any) => {
|
||||
.then((res: PublicGetChangeinfo) => {
|
||||
this.tableDetails = res.jsparams[0]
|
||||
this.jsParams = res.jsparams[0]
|
||||
|
||||
@ -189,6 +196,11 @@ export class ApproveDetailsComponent implements AfterViewInit, OnDestroy {
|
||||
}
|
||||
|
||||
this.keysArray = keysArray
|
||||
|
||||
// If we are approving MPE_TABLES we will arm the trigger for the reload of startup data to se the updated tables
|
||||
// After user approved if armed, reload will be triggered
|
||||
if (res.jsparams[0].BASE_DS === 'MPE_TABLES')
|
||||
this.refreshStartupserviceAfterApprove = true
|
||||
})
|
||||
.catch((err: any) => {
|
||||
this.acceptLoading = false
|
||||
|
@ -1,6 +1,7 @@
|
||||
import { Injectable } from '@angular/core'
|
||||
import cloneDeep from 'lodash-es/cloneDeep'
|
||||
import * as CryptoMD5 from 'crypto-js/md5'
|
||||
import { SasService } from './sas.service'
|
||||
|
||||
const librariesToShow = 50
|
||||
|
||||
@ -12,7 +13,7 @@ export class HelperService {
|
||||
public loadMoreCount: number = librariesToShow
|
||||
public isMicrosoft: boolean = false
|
||||
|
||||
constructor() {
|
||||
constructor(private sasService: SasService) {
|
||||
this.isMicrosoft = this.isIEorEDGE()
|
||||
console.log('Is IE or Edge?', this.isMicrosoft)
|
||||
}
|
||||
@ -314,6 +315,20 @@ export class HelperService {
|
||||
}
|
||||
}
|
||||
|
||||
public isStreamingViya(): boolean {
|
||||
const serverType = this.sasService.getServerType()
|
||||
|
||||
if (serverType !== 'SASVIYA') return false
|
||||
|
||||
if (
|
||||
location.search.toLowerCase().includes('?_file=') &&
|
||||
location.pathname.toLowerCase().includes('/sasjobexecution')
|
||||
)
|
||||
return true
|
||||
|
||||
return false
|
||||
}
|
||||
|
||||
// Required type is NodeJS.Timeout
|
||||
// But NodeJS is not available in browser so we have to go with any
|
||||
private debounceTimeout: any
|
||||
|
@ -333,6 +333,10 @@ export class SasService {
|
||||
})
|
||||
}
|
||||
|
||||
public reloadStartupData() {
|
||||
this.loadStartupServiceEmitter.emit()
|
||||
}
|
||||
|
||||
public getLicenseSiteId(): string[] {
|
||||
return this.license_site_id.value || []
|
||||
}
|
||||
|
@ -598,6 +598,12 @@
|
||||
{{ libinfo[0] ? libinfo[0].TABLE_CNT : '' }}
|
||||
</td>
|
||||
</tr>
|
||||
<tr *ngIf="libinfo[0].CATALOG_CNT !== null">
|
||||
<td class="m-0">CATALOG_CNT:</td>
|
||||
<td class="m-0 font-bold">
|
||||
{{ libinfo[0] ? libinfo[0].CATALOG_CNT : '' }}
|
||||
</td>
|
||||
</tr>
|
||||
</table>
|
||||
</ng-container>
|
||||
</div>
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "dcfrontend",
|
||||
"version": "6.14.10",
|
||||
"version": "7.0.0",
|
||||
"description": "Data Controller",
|
||||
"devDependencies": {
|
||||
"@saithodev/semantic-release-gitea": "^2.1.0",
|
||||
@ -19,7 +19,9 @@
|
||||
"lint": "npm run lint:fix",
|
||||
"lint:fix": "npx prettier --write \"client/{src,test}/**/*.{ts,tsx,js,jsx,html,css,sass,less,yml,md,graphql}\" \"client/cypress/integration/*.tests.ts\"",
|
||||
"lint:check": "npx prettier --check \"client/{src,test}/**/*.{ts,tsx,js,jsx,html,css,sass,less,yml,md,graphql}\" \"client/cypress/integration/*.tests.ts\"",
|
||||
"jo": "echo"
|
||||
"lint:silent": "npx prettier --loglevel silent --check \"client/{src,test}/**/*.{ts,tsx,js,jsx,html,css,sass,less,yml,md,graphql}\" \"client/cypress/integration/*.tests.ts\"",
|
||||
"jo": "echo",
|
||||
"prepare": "git rev-parse --git-dir && git config core.hooksPath ./.git-hooks && git config core.autocrlf false || true"
|
||||
},
|
||||
"repository": {
|
||||
"type": "git",
|
||||
|
32
sas/package-lock.json
generated
32
sas/package-lock.json
generated
@ -6,8 +6,8 @@
|
||||
"": {
|
||||
"name": "dc-sas",
|
||||
"dependencies": {
|
||||
"@sasjs/cli": "^4.12.5",
|
||||
"@sasjs/core": "^4.58.1"
|
||||
"@sasjs/cli": "^4.12.8",
|
||||
"@sasjs/core": "^4.59.1"
|
||||
}
|
||||
},
|
||||
"node_modules/@coolaj86/urequest": {
|
||||
@ -30,9 +30,9 @@
|
||||
}
|
||||
},
|
||||
"node_modules/@sasjs/adapter": {
|
||||
"version": "4.11.3",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/adapter/-/adapter-4.11.3.tgz",
|
||||
"integrity": "sha512-KF6G4vzs4l4efjpCD02og3kB44uFfJ1u2UWu749VdHtLKNN9l+PO26/moR+YAmRmmz2I9sC3X09fZE1nlN6zgw==",
|
||||
"version": "4.12.1",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/adapter/-/adapter-4.12.1.tgz",
|
||||
"integrity": "sha512-0217oZIkrecOyQygRe6Azgc1C4TIcjB5noi15fU4Rd5GsfDpleKVfQQdzYZ7im/vesWlLIVl/yUT67MMaQe0ew==",
|
||||
"hasInstallScript": true,
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
@ -45,14 +45,14 @@
|
||||
}
|
||||
},
|
||||
"node_modules/@sasjs/cli": {
|
||||
"version": "4.12.5",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/cli/-/cli-4.12.5.tgz",
|
||||
"integrity": "sha512-y6JFATKlTyTl0gRPpDBPL1rwZsyeuyp5uEz7HMA7raSzQuNa6QZ1oO1Er91I7+cLUg0Ndh5aSNGKYOdBRStQ2g==",
|
||||
"version": "4.12.8",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/cli/-/cli-4.12.8.tgz",
|
||||
"integrity": "sha512-20WiywlcLV22T1XfkAumV66mM3PfQ1N9ihJfpxoOVCFs2wF/ZertqnP4BZ5CE1dc30M1C2oDOzzSSVZqePPQnw==",
|
||||
"hasInstallScript": true,
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"@sasjs/adapter": "4.11.3",
|
||||
"@sasjs/core": "4.57.0",
|
||||
"@sasjs/adapter": "4.12.1",
|
||||
"@sasjs/core": "4.59.1",
|
||||
"@sasjs/lint": "2.4.3",
|
||||
"@sasjs/utils": "3.5.2",
|
||||
"adm-zip": "0.5.10",
|
||||
@ -76,16 +76,10 @@
|
||||
"sasjs": "build/index.js"
|
||||
}
|
||||
},
|
||||
"node_modules/@sasjs/cli/node_modules/@sasjs/core": {
|
||||
"version": "4.57.0",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/core/-/core-4.57.0.tgz",
|
||||
"integrity": "sha512-iJiLnW4oY15InGerXXWtrjc1YpJ9UDz72+r7Odfr/yYR7RxIhtXGjYQIqyQu6US+cS/0b2pi12LZB6VnfMS/pA==",
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/@sasjs/core": {
|
||||
"version": "4.58.1",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/core/-/core-4.58.1.tgz",
|
||||
"integrity": "sha512-Qp6KAtp1VZcmN5HLGSIUE9H41qpFuihWLbjNygOYp+NRs/Y8VagpHrYeyIQbh3cSgchiJEMXudLql8hoU06wpg==",
|
||||
"version": "4.59.1",
|
||||
"resolved": "https://registry.npmjs.org/@sasjs/core/-/core-4.59.1.tgz",
|
||||
"integrity": "sha512-52GNI4nIll5YivI8uobWrucE6TkHcTjcbKTr/YPC9eTauC4sh0V0MptebfAJ5E6vE5P2WevNZGr42KdDpckLpg==",
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/@sasjs/lint": {
|
||||
|
@ -22,13 +22,13 @@
|
||||
"serverdata": "sasjs request services/admin/makedata -d deploy/makeDataServer.json -l sasjsresults/makedata_server.log -o sasjsresults/makedata_server.json -t server",
|
||||
"viya": "npm run viyacbd && sasjs test",
|
||||
"viyacbd": "sasjs folder delete /Public/app/viya && sasjs cbd -t viya && npm run viyadata",
|
||||
"viyadata": "sasjs request services/admin/makedata -d deploy/makeDataViya.json -l sasjsresults/makedata.log -o sasjsresults/output.json",
|
||||
"viyadata": "sasjs request services/admin/makedata -d deploy/makeDataViya.json -l sasjsresults/makedata.log -o sasjsresults/output.json -t viya",
|
||||
"v4data": "sasjs request services/admin/makedata -d deploy/makeDataV4.json -l sasjsresults/makedatav4.log -o sasjsresults/outputv4.json -t v4",
|
||||
"sasdocs": "sasjs doc && ./sasjs/utils/deploydocs.sh"
|
||||
},
|
||||
"private": true,
|
||||
"dependencies": {
|
||||
"@sasjs/cli": "^4.12.5",
|
||||
"@sasjs/core": "^4.58.1"
|
||||
"@sasjs/cli": "^4.12.8",
|
||||
"@sasjs/core": "^4.59.1"
|
||||
}
|
||||
}
|
||||
}
|
17
sas/sasjs/db/datactrl/mpe_datacatalog_cats.ddl
Normal file
17
sas/sasjs/db/datactrl/mpe_datacatalog_cats.ddl
Normal file
@ -0,0 +1,17 @@
|
||||
/**
|
||||
@file mpe_datacatalog_CATS.ddl
|
||||
@brief ddl file
|
||||
@details
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd
|
||||
**/
|
||||
|
||||
create table &curlib..mpe_datacatalog_CATS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
constraint pk_mpe_datacatalog_CATS
|
||||
primary key(libref,memname,tx_to));
|
21
sas/sasjs/db/datactrl/mpe_datacatalog_objs.ddl
Normal file
21
sas/sasjs/db/datactrl/mpe_datacatalog_objs.ddl
Normal file
@ -0,0 +1,21 @@
|
||||
/**
|
||||
@file mpe_datacatalog_CATS.ddl
|
||||
@brief ddl file
|
||||
@details
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd
|
||||
**/
|
||||
|
||||
create table &curlib..mpe_datacatalog_OBJS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
objname char(32) label='Object Name',
|
||||
objtype char(8) label='Object Type',
|
||||
objdesc char(256) label='Object Description',
|
||||
alias char(32) label='Object Alias',
|
||||
constraint pk_mpe_datacatalog_OBJS
|
||||
primary key(libref,memname,objname,objtype,tx_to));
|
20
sas/sasjs/db/datactrl/mpe_datastatus_cats.ddl
Normal file
20
sas/sasjs/db/datactrl/mpe_datastatus_cats.ddl
Normal file
@ -0,0 +1,20 @@
|
||||
/**
|
||||
@file mpe_datacatalog_CATS.ddl
|
||||
@brief ddl file
|
||||
@details
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd
|
||||
**/
|
||||
|
||||
create table &curlib..mpe_datastatus_CATS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
nobjs num label='Number of objects',
|
||||
created num format=DATETIME. label='Date Created',
|
||||
modified num format=DATETIME. label='Date Modified',
|
||||
constraint pk_mpe_datastatus_CATS
|
||||
primary key(libref,memname,tx_to));
|
@ -14,5 +14,6 @@ create table &curlib..mpe_datastatus_libs(
|
||||
libref char(8) label='Library Name',
|
||||
libsize num format=SIZEKMG. label='Size of file',
|
||||
table_cnt num label='Number of Tables',
|
||||
catalog_cnt num label='Number of Catalogs',
|
||||
constraint pk_mpe_datastatus_libs
|
||||
primary key(libref,tx_to));
|
||||
|
22
sas/sasjs/db/datactrl/mpe_datastatus_objs.ddl
Normal file
22
sas/sasjs/db/datactrl/mpe_datastatus_objs.ddl
Normal file
@ -0,0 +1,22 @@
|
||||
/**
|
||||
@file mpe_datacatalog_CATS.ddl
|
||||
@brief ddl file
|
||||
@details
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd
|
||||
**/
|
||||
|
||||
create table &curlib..mpe_datastatus_OBJS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
objname char(32) label='Object Name',
|
||||
objtype char(8) label='Object Type',
|
||||
created num format=DATETIME. label='Date Created',
|
||||
modified num format=DATETIME. label='Date Modified',
|
||||
level num label='Library Concatenation Level',
|
||||
constraint pk_mpe_datastatus_OBJS
|
||||
primary key(libref,memname,objname,objtype,tx_to));
|
@ -14,8 +14,8 @@ create table &curlib..mpe_datastatus_tabs(
|
||||
libref char(8) label='Library Name',
|
||||
dsn char(64) label='Member Name',
|
||||
filesize num format=SIZEKMG. label='Size of file',
|
||||
crdate num format=DATETIME. informat=DATETIME. label='Date Created',
|
||||
modate num format=DATETIME. informat=DATETIME. label='Date Modified',
|
||||
crdate num format=DATETIME. label='Date Created',
|
||||
modate num format=DATETIME. label='Date Modified',
|
||||
nobs num label='Number of Physical (Actual, inc. deleted) Observations',
|
||||
constraint pk_mpe_datastatus_tabs
|
||||
primary key(libref,dsn,tx_to));
|
||||
|
@ -29,7 +29,7 @@ create table dc.mpe_datacatalog_TABS(
|
||||
nvar num label='Number of Variables',
|
||||
compress char(8) label='Compression Routine',
|
||||
pk_fields char(512)
|
||||
label='Primary Key Fields (identified by being in a constraint that is both Unique and Not Null)',
|
||||
label='Primary Key Fields (in a constraint that is both Unique and Not Null)',
|
||||
constraint pk
|
||||
primary key(libref,dsn,tx_to));
|
||||
|
||||
@ -67,8 +67,8 @@ create table dc.mpe_datacatalog_vars(
|
||||
libref char(8) label='Library Name',
|
||||
dsn char(64) label='Member Name',
|
||||
filesize num format=SIZEKMG. label='Size of file',
|
||||
crdate num format=DATETIME. informat=DATETIME. label='Date Created',
|
||||
modate num format=DATETIME. informat=DATETIME. label='Date Modified',
|
||||
crdate num format=DATETIME. label='Date Created',
|
||||
modate num format=DATETIME. label='Date Modified',
|
||||
nobs num label='Number of Physical (Actual, inc. deleted) Observations',
|
||||
constraint pk
|
||||
primary key(libref,dsn,tx_to));
|
71
sas/sasjs/db/migrations/20250611_v7.0_release.sas
Normal file
71
sas/sasjs/db/migrations/20250611_v7.0_release.sas
Normal file
@ -0,0 +1,71 @@
|
||||
/**
|
||||
@file
|
||||
@brief migration script to move from v6.8.2 to v7.0 of data controller
|
||||
|
||||
BREAKING CHANGE - 1 new column and 4 additional tables for capturing catalogs
|
||||
|
||||
Be sure to run this using the correct system account
|
||||
(eg the regular DC account)
|
||||
|
||||
On SAS 9 you may wish to run proc metalib or refresh in DI Studio afterwards
|
||||
to see the new tables in the VIEW page
|
||||
|
||||
proc metalib;
|
||||
omr (library="&DC_LIBNAME");
|
||||
folder="&root/data";
|
||||
update_rule=(delete);
|
||||
run;
|
||||
|
||||
**/
|
||||
|
||||
%let dclib=YOURDCLIB;
|
||||
|
||||
libname &dclib "/YOUR/DATACONTROLLER/LIBRARY/PATH";
|
||||
|
||||
proc sql;
|
||||
create table work.BACKUP as select * from &dclib..mpe_datastatus_libs;
|
||||
alter table &dclib..mpe_datastatus_libs add catalog_cnt num;
|
||||
|
||||
create table &dclib..mpe_datacatalog_CATS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
constraint pk_mpe_datacatalog_CATS
|
||||
primary key(libref,memname,tx_to));
|
||||
|
||||
create table &dclib..mpe_datacatalog_OBJS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
objname char(32) label='Object Name',
|
||||
objtype char(8) label='Object Type',
|
||||
objdesc char(256) label='Object Description',
|
||||
alias char(32) label='Object Alias',
|
||||
constraint pk_mpe_datacatalog_OBJS
|
||||
primary key(libref,memname,objname,objtype,tx_to));
|
||||
|
||||
create table &dclib..mpe_datastatus_CATS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
nobjs num label='Number of objects',
|
||||
created num format=DATETIME. label='Date Created',
|
||||
modified num format=DATETIME. label='Date Modified',
|
||||
constraint pk_mpe_datastatus_CATS
|
||||
primary key(libref,memname,tx_to));
|
||||
|
||||
create table &dclib..mpe_datastatus_OBJS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
objname char(32) label='Object Name',
|
||||
objtype char(8) label='Object Type',
|
||||
created num format=DATETIME. label='Date Created',
|
||||
modified num format=DATETIME. label='Date Modified',
|
||||
level num label='Library Concatenation Level',
|
||||
constraint pk_mpe_datastatus_OBJS
|
||||
primary key(libref,memname,objname,objtype,tx_to));
|
@ -14,14 +14,31 @@
|
||||
**/
|
||||
|
||||
%macro mpe_dsmeta(libds, outds=dsmeta);
|
||||
%local ddsd ddld notes lenstmt;
|
||||
%local ddsd ddld notes lenstmt memname;
|
||||
%let lenstmt=length ods_table $18 name $100 value $1000;
|
||||
%let libds=%upcase(&libds);
|
||||
%mp_dsmeta(&libds, outds=&outds)
|
||||
|
||||
%if "%scan(&libds,2,-)" ne "FC" %then %do;
|
||||
%let memname=%scan(&libds,2,.);
|
||||
%mp_dsmeta(&libds, outds=&outds)
|
||||
%end;
|
||||
%else %do;
|
||||
%let memname=%scan(&libds,2,.-);
|
||||
data &outds;
|
||||
&lenstmt;
|
||||
set sashelp.vcatalg;
|
||||
ods_table=cats(objtype);
|
||||
name=cats(objname);
|
||||
value=catx(' ',objdesc,'(modified:',put(modified,datetime19.),')');
|
||||
where libname="%scan(&libds,1,.)" and memname="&memname";
|
||||
keep ods_table name value;
|
||||
run;
|
||||
proc sort; by ods_table name;run;
|
||||
%end;
|
||||
|
||||
data _null_;
|
||||
set &mpelib..mpe_datadictionary;
|
||||
where &dc_dttmtfmt < tx_to & dd_source=%upcase("&libds") & dd_type='TABLE';
|
||||
where &dc_dttmtfmt < tx_to & dd_source="&memname" & dd_type='TABLE';
|
||||
call symputx('ddsd',dd_shortdesc,'l');
|
||||
call symputx('ddld',dd_longdesc,'l');
|
||||
run;
|
||||
|
@ -34,4 +34,15 @@ run;
|
||||
outds=work.test_results
|
||||
)
|
||||
|
||||
%mpe_dsmeta(FMTONLY.DCFMTS-FC,outds=test2)
|
||||
data work.test2;
|
||||
set work.test2;
|
||||
putlog (_all_)(=);
|
||||
run;
|
||||
|
||||
%mp_assertdsobs(work.test2,
|
||||
desc=Test 2 - records returned,
|
||||
test=EQUALS 5,
|
||||
outds=work.test_results
|
||||
)
|
||||
|
||||
|
@ -106,6 +106,19 @@ proc datasets lib=&lib noprint;
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datacatalog_CATS(
|
||||
TX_FROM float ¬null format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
modify mpe_datacatalog_CATS;
|
||||
index create
|
||||
pk_mpe_datacatalog_CATS=(tx_to libref memname)
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datacatalog_libs(
|
||||
TX_FROM num ¬null format=datetime19.3,
|
||||
TX_TO num ¬null format=datetime19.3,
|
||||
@ -125,6 +138,23 @@ proc datasets lib=&lib noprint;
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datacatalog_OBJS(
|
||||
TX_FROM num ¬null format=datetime19.,
|
||||
TX_TO num ¬null format=datetime19.,
|
||||
libref char(8) ¬null label='Library Name',
|
||||
memname char(64) ¬null label='Member Name',
|
||||
objname char(32) ¬null label='Object Name',
|
||||
objtype char(8) ¬null label='Object Type',
|
||||
objdesc char(256) label='Object Description',
|
||||
alias char(32) label='Object Alias'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
modify mpe_datacatalog_OBJS;
|
||||
index create
|
||||
pk_mpe_datacatalog_OBJS=(libref memname objname objtype tx_to)
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datacatalog_TABS(
|
||||
TX_FROM num ¬null format=datetime19.3,
|
||||
TX_TO num ¬null format=datetime19.3,
|
||||
@ -137,7 +167,7 @@ create table &lib..mpe_datacatalog_TABS(
|
||||
nvar num label='Number of Variables',
|
||||
compress char(8) label='Compression Routine',
|
||||
pk_fields char(512)
|
||||
label='Primary Key Fields (identified by being in a constraint that is both Unique and Not Null)'
|
||||
label='Primary Key Fields - in a constraint being both Unique and Not Null'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
modify mpe_datacatalog_TABS;
|
||||
@ -169,12 +199,29 @@ proc datasets lib=&lib noprint;
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datastatus_CATS(
|
||||
TX_FROM float format=datetime19.,
|
||||
TX_TO float format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
nobjs num ¬null label='Number of objects',
|
||||
created num ¬null format=DATETIME. label='Date Created',
|
||||
modified num format=DATETIME. label='Date Modified'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
modify mpe_datastatus_CATS;
|
||||
index create
|
||||
pk_mpe_datastatus_cats=(libref memname tx_to)
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datastatus_libs(
|
||||
TX_FROM num ¬null format=datetime19.3,
|
||||
TX_TO num ¬null format=datetime19.3,
|
||||
libref char(8) label='Library Name',
|
||||
libsize num format=SIZEKMG. label='Size of library',
|
||||
table_cnt num label='Number of Tables'
|
||||
table_cnt num label='Number of Tables',
|
||||
catalog_cnt num label='Number of Catalogs'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
modify mpe_datastatus_libs;
|
||||
@ -183,14 +230,32 @@ proc datasets lib=&lib noprint;
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datastatus_OBJS(
|
||||
TX_FROM float ¬null format=datetime19.,
|
||||
TX_TO float ¬null format=datetime19.,
|
||||
libref char(8) label='Library Name',
|
||||
memname char(64) label='Member Name',
|
||||
objname char(32) label='Object Name',
|
||||
objtype char(8) label='Object Type',
|
||||
created num ¬null format=DATETIME. label='Date Created',
|
||||
modified num format=DATETIME. label='Date Modified',
|
||||
level num label='Library Concatenation Level'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
modify mpe_datastatus_OBJS;
|
||||
index create
|
||||
pk_mpe_datastatus_OBJS=(libref memname objname objtype tx_to)
|
||||
/nomiss unique;
|
||||
quit;
|
||||
proc sql;
|
||||
create table &lib..mpe_datastatus_tabs(
|
||||
TX_FROM num ¬null format=datetime19.3,
|
||||
TX_TO num ¬null format=datetime19.3,
|
||||
libref char(8) label='Library Name',
|
||||
dsn char(64) label='Member Name',
|
||||
filesize num format=SIZEKMG. label='Size of file',
|
||||
crdate num format=DATETIME. informat=DATETIME. label='Date Created',
|
||||
modate num format=DATETIME. informat=DATETIME. label='Date Modified',
|
||||
crdate num format=DATETIME. label='Date Created',
|
||||
modate num format=DATETIME. label='Date Modified',
|
||||
nobs num label='Number of Physical (Actual, inc. deleted) Observations'
|
||||
);quit;
|
||||
proc datasets lib=&lib noprint;
|
||||
|
26
sas/sasjs/macros/mpe_makedatamodel.test.sas
Normal file
26
sas/sasjs/macros/mpe_makedatamodel.test.sas
Normal file
@ -0,0 +1,26 @@
|
||||
/**
|
||||
@file
|
||||
@brief Testing mpe_refreshtables macro
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li mpe_makedatamodel.sas
|
||||
@li mp_assert.sas
|
||||
@li mp_assertscope.sas
|
||||
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd. This code may only be used within Data Controller
|
||||
and may not be re-distributed or re-sold without the express permission of
|
||||
4GL Apps Ltd.
|
||||
|
||||
**/
|
||||
|
||||
%mp_assertscope(SNAPSHOT)
|
||||
%mpe_makedatamodel(lib=WORK)
|
||||
%mp_assertscope(COMPARE,
|
||||
desc=Checking macro variables against previous snapshot
|
||||
)
|
||||
|
||||
%mp_assert(
|
||||
iftrue=(&syscc = 0),
|
||||
desc=Checking error condition
|
||||
)
|
140
sas/sasjs/macros/mpe_refreshcatalogs.sas
Normal file
140
sas/sasjs/macros/mpe_refreshcatalogs.sas
Normal file
@ -0,0 +1,140 @@
|
||||
/**
|
||||
@file mpe_refreshtables.sas
|
||||
@brief Refreshes the data catalog
|
||||
@details Assumes library is already assigned.
|
||||
Usage:
|
||||
|
||||
%mpe_refreshcatalogs(sashelp)
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li bitemporal_dataloader.sas
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
**/
|
||||
|
||||
%macro mpe_refreshcatalogs(lib,cat=#all);
|
||||
%let lib=%upcase(&lib);
|
||||
%let cat=%upcase(&cat);
|
||||
|
||||
%put running &sysmacroname &lib for &cat;
|
||||
proc sql;
|
||||
create table work.catdata as
|
||||
select libname as libref,
|
||||
memname,
|
||||
objname,
|
||||
objtype,
|
||||
objdesc,
|
||||
created,
|
||||
modified,
|
||||
alias,
|
||||
level
|
||||
from dictionary.catalogs
|
||||
where upcase(libname)="&lib"
|
||||
%if &cat ne #ALL %then %do;
|
||||
and upcase(memname)="&cat"
|
||||
%end;
|
||||
;
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,mac=&_program
|
||||
,msg=%str(syscc=&syscc afer &lib objects extraction)
|
||||
)
|
||||
|
||||
/* load mpe_datacatalog_CATS */
|
||||
proc sql;
|
||||
create table datacats as select distinct libref,memname from catdata;
|
||||
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
,base_dsn=mpe_datacatalog_CATS
|
||||
,append_dsn=datacats
|
||||
,PK=LIBREF MEMNAME
|
||||
,etlsource=&sysmacroname
|
||||
,loadtype=TXTEMPORAL
|
||||
,tech_from=TX_FROM
|
||||
,tech_to=TX_TO
|
||||
%if &cat = #ALL %then %do;
|
||||
,close_vars=LIBREF
|
||||
%end;
|
||||
,dclib=&mpelib
|
||||
)
|
||||
|
||||
/* load mpe_datacatalog_objsS */
|
||||
proc sql;
|
||||
create table dataobjs as
|
||||
select distinct libref,
|
||||
memname,
|
||||
objname,
|
||||
objtype,
|
||||
objdesc,
|
||||
alias
|
||||
from catdata;
|
||||
quit;
|
||||
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
,base_dsn=mpe_datacatalog_OBJS
|
||||
,append_dsn=dataobjs
|
||||
,PK=LIBREF MEMNAME OBJNAME OBJTYPE
|
||||
,etlsource=&sysmacroname
|
||||
,loadtype=TXTEMPORAL
|
||||
,tech_from=TX_FROM
|
||||
,tech_to=TX_TO
|
||||
%if &cat = #ALL %then %do;
|
||||
,close_vars=LIBREF MEMNAME
|
||||
%end;
|
||||
,dclib=&mpelib
|
||||
)
|
||||
|
||||
%put load mpe_datastatus_OBJS;
|
||||
proc sql;
|
||||
create table statusobjs as
|
||||
select distinct libref,
|
||||
memname,
|
||||
objname,
|
||||
objtype,
|
||||
created,
|
||||
modified,
|
||||
level
|
||||
from catdata;
|
||||
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
,base_dsn=mpe_datastatus_OBJS
|
||||
,append_dsn=statusobjs
|
||||
,PK=LIBREF MEMNAME OBJNAME OBJTYPE
|
||||
,etlsource=&sysmacroname
|
||||
,loadtype=TXTEMPORAL
|
||||
,tech_from=TX_FROM
|
||||
,tech_to=TX_TO
|
||||
%if &cat = #ALL %then %do;
|
||||
,close_vars=LIBREF MEMNAME
|
||||
%end;
|
||||
,dclib=&mpelib
|
||||
)
|
||||
|
||||
%put load mpe_datastatus_cats;
|
||||
proc sql;
|
||||
create table statuscats as
|
||||
select libref,
|
||||
memname,
|
||||
count(*) as nobjs,
|
||||
min(created) as created,
|
||||
max(modified) as modified
|
||||
from catdata
|
||||
group by 1,2;
|
||||
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
,base_dsn=mpe_datastatus_cats
|
||||
,append_dsn=statuscats
|
||||
,PK=LIBREF MEMNAME
|
||||
,etlsource=&sysmacroname
|
||||
,loadtype=TXTEMPORAL
|
||||
,tech_from=TX_FROM
|
||||
,tech_to=TX_TO
|
||||
%if &cat = #ALL %then %do;
|
||||
,close_vars=LIBREF
|
||||
%end;
|
||||
,dclib=&mpelib
|
||||
)
|
||||
|
||||
|
||||
%mend mpe_refreshcatalogs;
|
38
sas/sasjs/macros/mpe_refreshcatalogs.test.sas
Normal file
38
sas/sasjs/macros/mpe_refreshcatalogs.test.sas
Normal file
@ -0,0 +1,38 @@
|
||||
/**
|
||||
@file
|
||||
@brief Testing mpe_refreshcatalogs macro
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li mpe_refreshcatalogs.sas
|
||||
@li mp_assert.sas
|
||||
@li mp_assertscope.sas
|
||||
@li mp_ds2md.sas
|
||||
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd. This code may only be used within Data Controller
|
||||
and may not be re-distributed or re-sold without the express permission of
|
||||
4GL Apps Ltd.
|
||||
|
||||
**/
|
||||
|
||||
%mp_assertscope(SNAPSHOT)
|
||||
%mpe_refreshcatalogs(FMTONLY)
|
||||
%mp_assertscope(COMPARE,
|
||||
desc=Checking macro variables against previous snapshot
|
||||
)
|
||||
|
||||
/* make sure that the process picks up the catalog */
|
||||
proc sql noprint;
|
||||
create table work.test1 as
|
||||
select *
|
||||
from &mpelib..mpe_datacatalog_cats(where=(&dc_dttmtfmt. lt tx_to))
|
||||
where libref="FMTONLY";
|
||||
%let test1=0;
|
||||
select count(*) into: test1 from work.test1;
|
||||
|
||||
%mp_assert(
|
||||
iftrue=(&test1>0),
|
||||
desc=Checking fmtonly.dcfmts was picked up
|
||||
)
|
||||
|
||||
%mp_ds2md(work.test1)
|
@ -48,11 +48,6 @@ create table cols as
|
||||
,msg=%str(syscc=&syscc afer &lib cols extraction)
|
||||
)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,mac=&_program
|
||||
,msg=%str(syscc=&syscc afer &lib indexes extraction)
|
||||
)
|
||||
|
||||
%if &engine=SQLSVR %then %do;
|
||||
proc sql;
|
||||
connect using &lib;
|
||||
@ -175,6 +170,11 @@ create table cols as
|
||||
|
||||
%end;
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,mac=&_program
|
||||
,msg=%str(syscc=&syscc afer &lib indexes extraction)
|
||||
)
|
||||
|
||||
/* load columns */
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
,base_dsn=mpe_datacatalog_vars
|
||||
@ -295,7 +295,7 @@ proc sql;
|
||||
%if &ds ne #ALL %then %do;
|
||||
and upcase(memname)="&ds"
|
||||
%end;
|
||||
;
|
||||
;
|
||||
%end;
|
||||
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
@ -314,12 +314,26 @@ proc sql;
|
||||
|
||||
%if &ds = #ALL %then %do;
|
||||
proc sql;
|
||||
create table statuslibs as select
|
||||
create table work.sumcat as
|
||||
select libname as libref,
|
||||
count(distinct memname) as catalog_cnt
|
||||
from dictionary.catalogs
|
||||
where upcase(libname)="&lib"
|
||||
group by 1;
|
||||
create table work.sumdsn as select
|
||||
libref
|
||||
,sum(filesize) as libsize
|
||||
,count(*) as table_cnt
|
||||
from statustabs
|
||||
group by 1;
|
||||
create table work.statuslibs as
|
||||
select coalesce(a.libref,b.libref) as libref,
|
||||
a.libsize,
|
||||
a.table_cnt,
|
||||
b.catalog_cnt
|
||||
from work.sumdsn a
|
||||
full join work.sumcat b
|
||||
on a.libref=b.libref;
|
||||
|
||||
%bitemporal_dataloader(base_lib=&mpelib
|
||||
,base_dsn=mpe_datastatus_libs
|
||||
|
50
sas/sasjs/macros/mpe_refreshtables.test.sas
Normal file
50
sas/sasjs/macros/mpe_refreshtables.test.sas
Normal file
@ -0,0 +1,50 @@
|
||||
/**
|
||||
@file
|
||||
@brief Testing mpe_refreshtables macro
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li mpe_refreshtables.sas
|
||||
@li mp_assert.sas
|
||||
@li mp_assertscope.sas
|
||||
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd. This code may only be used within Data Controller
|
||||
and may not be re-distributed or re-sold without the express permission of
|
||||
4GL Apps Ltd.
|
||||
|
||||
**/
|
||||
|
||||
%mp_assertscope(SNAPSHOT)
|
||||
%mpe_refreshtables(FMTONLY)
|
||||
%mp_assertscope(COMPARE,
|
||||
desc=Checking macro variables against previous snapshot
|
||||
)
|
||||
|
||||
/* make sure that the process picks up a library that contains only a single
|
||||
catalog */
|
||||
proc sql;
|
||||
create table work.libinfo as
|
||||
select a.engine,
|
||||
a.libname,
|
||||
a.paths,
|
||||
a.perms,
|
||||
a.owners,
|
||||
a.schemas,
|
||||
a.libid,
|
||||
b.libsize,
|
||||
b.table_cnt,
|
||||
b.catalog_cnt
|
||||
from &mpelib..mpe_datacatalog_libs(where=(&dc_dttmtfmt. lt tx_to)) a
|
||||
left join &mpelib..mpe_datastatus_libs(where=(&dc_dttmtfmt. lt tx_to)) b
|
||||
on a.libref=b.libref
|
||||
where a.libref="&libref";
|
||||
|
||||
%let test1=0;
|
||||
data _null_;
|
||||
set work.libinfo;
|
||||
call symputx('test1',table_cnt);
|
||||
run;
|
||||
%mp_assert(
|
||||
iftrue=(&test1>0),
|
||||
desc=Checking fmtonly.dcfmts was picked up
|
||||
)
|
@ -94,50 +94,18 @@
|
||||
},
|
||||
{
|
||||
"name": "viya",
|
||||
"serverUrl": "https://sas.4gl.io",
|
||||
"serverUrl": "https://viya-f0g8ht62vq.engage.sas.com",
|
||||
"serverType": "SASVIYA",
|
||||
"httpsAgentOptions": {
|
||||
"allowInsecureRequests": false
|
||||
},
|
||||
"appLoc": "/Public/app/dcplaceholder",
|
||||
"macroFolders": [
|
||||
"sasjs/targets/viya/macros_viya"
|
||||
],
|
||||
"programFolders": [
|
||||
"sasjs/db/datactrl"
|
||||
],
|
||||
"binaryFolders": [],
|
||||
"buildConfig": {
|
||||
"initProgram": "sasjs/utils/buildinitviya.sas",
|
||||
"buildResultsFolder": "sasjsresults",
|
||||
"buildOutputFolder": "sasjsbuild",
|
||||
"buildOutputFileName": "viya.sas"
|
||||
},
|
||||
"serviceConfig": {
|
||||
"initProgram": "sasjs/utils/serviceinitviya.sas",
|
||||
"serviceFolders": [
|
||||
"sasjs/targets/viya/services_viya/viya_users",
|
||||
"sasjs/targets/viya/services_viya/admin",
|
||||
"sasjs/targets/viya/services_viya/public"
|
||||
]
|
||||
},
|
||||
"deployConfig": {
|
||||
"deployServicePack": true,
|
||||
"deployScripts": [
|
||||
"sasjs/utils/viyadeploy.sh"
|
||||
]
|
||||
},
|
||||
"contextName": "SAS Job Execution compute context"
|
||||
},
|
||||
{
|
||||
"name": "viyacloud",
|
||||
"serverUrl": "https://4gl.viyacloud.sas.com",
|
||||
"serverType": "SASVIYA",
|
||||
"httpsAgentOptions": {
|
||||
"rejectUnauthorized": false,
|
||||
"allowInsecureRequests": true
|
||||
},
|
||||
"appLoc": "/30.SASApps/app/dc",
|
||||
"macroFolders": [
|
||||
"sasjs/targets/viya/macros_viya"
|
||||
],
|
||||
@ -146,36 +114,31 @@
|
||||
],
|
||||
"buildConfig": {
|
||||
"initProgram": "sasjs/utils/buildinitviya.sas",
|
||||
"termProgram": "sasjs/utils/buildtermviya.sas",
|
||||
"macroVars": {
|
||||
"dcpath": "/opt/sas/viya/config/var/tmp/dc",
|
||||
"adminGroup": "DataBuilders"
|
||||
},
|
||||
"buildResultsFolder": "sasjsresults",
|
||||
"buildOutputFolder": "sasjsbuild",
|
||||
"buildOutputFileName": "viya.sas"
|
||||
"buildOutputFileName": "viya.sas",
|
||||
"termProgram": "",
|
||||
"macroVars": {}
|
||||
},
|
||||
"serviceConfig": {
|
||||
"initProgram": "sasjs/utils/serviceinitviya.sas",
|
||||
"serviceFolders": [
|
||||
"sasjs/targets/viya/services_viya/viya_users",
|
||||
"sasjs/targets/viya/services_viya/admin",
|
||||
"sasjs/targets/viya/services_viya/public"
|
||||
],
|
||||
"initProgram": "sasjs/utils/serviceinitviya.sas",
|
||||
"termProgram": "",
|
||||
"macroVars": {}
|
||||
},
|
||||
"streamConfig": {
|
||||
"streamWeb": true,
|
||||
"streamWebFolder": "webv",
|
||||
"streamWebFolder": "web",
|
||||
"webSourcePath": "../client/dist",
|
||||
"streamServiceName": "clickme",
|
||||
"streamServiceName": "DC",
|
||||
"streamLogo": "favicon.ico",
|
||||
"assetPaths": []
|
||||
},
|
||||
"deployConfig": {
|
||||
"deployServicePack": true
|
||||
},
|
||||
"contextName": "Datacontroller compute context"
|
||||
"contextName": "SAS Job Execution compute context"
|
||||
},
|
||||
{
|
||||
"name": "vtest",
|
||||
|
@ -675,7 +675,7 @@ data xl_rules;
|
||||
keep xl_column xl_rule;
|
||||
run;
|
||||
|
||||
%mpe_dsmeta(&libds, outds=dsmeta)
|
||||
%mpe_dsmeta(&orig_libds, outds=dsmeta)
|
||||
|
||||
%mpe_getversions(&mpelib,
|
||||
%scan(&orig_libds,1,.),
|
||||
|
@ -54,7 +54,10 @@ data _null_;
|
||||
/* if a TXTEMPORAL table then filter as such */
|
||||
call symputx('txfrom',var_txfrom);
|
||||
call symputx('txto',var_txto);
|
||||
run;
|
||||
|
||||
/* if a format, extract relevant info */
|
||||
data _null_;
|
||||
ds=symget('ds');
|
||||
is_fmt=0;
|
||||
if subpad(cats(reverse(ds)),1,3)=:'CF-' then do;
|
||||
|
@ -76,3 +76,37 @@ run;
|
||||
test=EQUALS 3,
|
||||
outds=work.test_results
|
||||
)
|
||||
|
||||
/* test 3 - when there is a format catalog / nothing else in the library */
|
||||
data work.params3;
|
||||
length name $32 value $1000;
|
||||
name='type';value='SAS';output;
|
||||
name='table';value="FMTONLY.DCFMTS-FC";output;
|
||||
name='filter';value='0';output;
|
||||
run;
|
||||
|
||||
%mx_testservice(&_program,
|
||||
viyacontext=&defaultcontext,
|
||||
inputparams=work.params3,
|
||||
outref=web3,
|
||||
viyaresult=WEBOUT_TXT
|
||||
)
|
||||
|
||||
data work.results3;
|
||||
infile web3;
|
||||
input;
|
||||
putlog _infile_;
|
||||
if _infile_=:'datalines4;' then do;
|
||||
output;
|
||||
output;
|
||||
output;
|
||||
stop;
|
||||
end;
|
||||
if _n_>100 then stop;
|
||||
run;
|
||||
|
||||
%mp_assertdsobs(work.results3,
|
||||
desc=datalines file is successfully returned for LONE format catalog,
|
||||
test=EQUALS 3,
|
||||
outds=work.test_results
|
||||
)
|
||||
|
@ -1,85 +1,86 @@
|
||||
/**
|
||||
@file refreshlibinfo.sas
|
||||
@brief Refresh the Data Catalog for a particular library
|
||||
@details When showing library info in the VIEW menu, the data is taken from
|
||||
the Data Catalog tables. These may be empty or outdated, and so this service
|
||||
allows end users to run a refresh of the data.
|
||||
|
||||
<h4> Service Inputs </h4>
|
||||
<h5> lib2refresh </h5>
|
||||
Should contain the libref to be refreshed.
|
||||
|libref:$8.|
|
||||
|---|
|
||||
|SOMELIB|
|
||||
|
||||
<h4> Service Outputs </h4>
|
||||
|
||||
<h5> libinfo </h5>
|
||||
|
||||
|engine $|libname $|paths $|perms $|owners $|schemas $ |libid $|libsize $|table_cnt |
|
||||
|---|---|---|---|---|---|---|---|---|
|
||||
|V9|SOMELIB|"some/path"|rwxrwxr-x|sassrv|` `|` `|636MB|33|
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li dc_assignlib.sas
|
||||
@li dc_refreshcatalog.sas
|
||||
@li mp_abort.sas
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd. This code may only be used within Data Controller
|
||||
and may not be re-distributed or re-sold without the express permission of
|
||||
4GL Apps Ltd.
|
||||
**/
|
||||
|
||||
|
||||
%mpeinit()
|
||||
|
||||
%webout(FETCH)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc Problem on startup)
|
||||
)
|
||||
|
||||
%let libref=;
|
||||
data _null_;
|
||||
set work.lib2refresh;
|
||||
call symputx('libref',libref);
|
||||
run;
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc Problem with inputs - was lib2refresh object sent?)
|
||||
)
|
||||
|
||||
%dc_assignlib(WRITE,&libref)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc after lib assignment)
|
||||
)
|
||||
|
||||
%dc_refreshcatalog(&libref)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc Problem when running the catalog refresh)
|
||||
)
|
||||
|
||||
/* get libinfo */
|
||||
proc sql;
|
||||
create table work.libinfo as
|
||||
select a.engine,
|
||||
a.libname,
|
||||
a.paths,
|
||||
a.perms,
|
||||
a.owners,
|
||||
a.schemas,
|
||||
a.libid,
|
||||
b.libsize,
|
||||
b.table_cnt
|
||||
from &mpelib..mpe_datacatalog_libs(where=(&dc_dttmtfmt. lt tx_to)) a
|
||||
inner join &mpelib..mpe_datastatus_libs(where=(&dc_dttmtfmt. lt tx_to)) b
|
||||
on a.libref=b.libref
|
||||
where a.libref="&libref";
|
||||
|
||||
%webout(OPEN)
|
||||
%webout(OBJ,libinfo)
|
||||
%webout(CLOSE)
|
||||
/**
|
||||
@file refreshlibinfo.sas
|
||||
@brief Refresh the Data Catalog for a particular library
|
||||
@details When showing library info in the VIEW menu, the data is taken from
|
||||
the Data Catalog tables. These may be empty or outdated, and so this service
|
||||
allows end users to run a refresh of the data.
|
||||
|
||||
<h4> Service Inputs </h4>
|
||||
<h5> lib2refresh </h5>
|
||||
Should contain the libref to be refreshed.
|
||||
|libref:$8.|
|
||||
|---|
|
||||
|SOMELIB|
|
||||
|
||||
<h4> Service Outputs </h4>
|
||||
|
||||
<h5> libinfo </h5>
|
||||
|
||||
|engine $|libname $|paths $|perms $|owners $|schemas $ |libid $|libsize $|table_cnt |
|
||||
|---|---|---|---|---|---|---|---|---|
|
||||
|V9|SOMELIB|"some/path"|rwxrwxr-x|sassrv|` `|` `|636MB|33|
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li dc_assignlib.sas
|
||||
@li dc_refreshcatalog.sas
|
||||
@li mp_abort.sas
|
||||
|
||||
@version 9.3
|
||||
@author 4GL Apps Ltd
|
||||
@copyright 4GL Apps Ltd. This code may only be used within Data Controller
|
||||
and may not be re-distributed or re-sold without the express permission of
|
||||
4GL Apps Ltd.
|
||||
**/
|
||||
|
||||
|
||||
%mpeinit()
|
||||
|
||||
%webout(FETCH)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc Problem on startup)
|
||||
)
|
||||
|
||||
%let libref=;
|
||||
data _null_;
|
||||
set work.lib2refresh;
|
||||
call symputx('libref',libref);
|
||||
run;
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc Problem with inputs - was lib2refresh object sent?)
|
||||
)
|
||||
|
||||
%dc_assignlib(WRITE,&libref)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc after lib assignment)
|
||||
)
|
||||
|
||||
%dc_refreshcatalog(&libref)
|
||||
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,msg=%str(syscc=&syscc Problem when running the catalog refresh)
|
||||
)
|
||||
|
||||
/* get libinfo */
|
||||
proc sql;
|
||||
create table work.libinfo as
|
||||
select a.engine,
|
||||
a.libname,
|
||||
a.paths,
|
||||
a.perms,
|
||||
a.owners,
|
||||
a.schemas,
|
||||
a.libid,
|
||||
b.libsize,
|
||||
b.table_cnt,
|
||||
b.catalog_cnt
|
||||
from &mpelib..mpe_datacatalog_libs(where=(&dc_dttmtfmt. lt tx_to)) a
|
||||
inner join &mpelib..mpe_datastatus_libs(where=(&dc_dttmtfmt. lt tx_to)) b
|
||||
on a.libref=b.libref
|
||||
where a.libref="&libref";
|
||||
|
||||
%webout(OPEN)
|
||||
%webout(OBJ,libinfo)
|
||||
%webout(CLOSE)
|
||||
|
@ -355,7 +355,7 @@ run;
|
||||
|
||||
%mp_getcols(&libds, outds=cols)
|
||||
|
||||
%mpe_dsmeta(&libds, outds=dsmeta)
|
||||
%mpe_dsmeta(&orig_libds, outds=dsmeta)
|
||||
|
||||
%mpe_getversions(&mpelib,
|
||||
%scan(&orig_libds,1,.),
|
||||
|
@ -167,7 +167,8 @@ create table work.libinfo as
|
||||
a.schemas,
|
||||
a.libid,
|
||||
coalesce(b.libsize,0) as libsize,
|
||||
coalesce(b.table_cnt,0) as table_cnt
|
||||
coalesce(b.table_cnt,0) as table_cnt,
|
||||
coalesce(b.catalog_cnt,0) as catalog_cnt
|
||||
from &mpelib..mpe_datacatalog_libs(where=(&dc_dttmtfmt. lt tx_to)) a
|
||||
left join &mpelib..mpe_datastatus_libs(where=(&dc_dttmtfmt. lt tx_to)) b
|
||||
on a.libref=b.libref
|
||||
|
@ -9,6 +9,7 @@
|
||||
<h4> SAS Macros </h4>
|
||||
@li mpe_refreshlibs.sas
|
||||
@li dc_assignlib.sas
|
||||
@li mpe_refreshcatalogs.sas
|
||||
@li mpe_refreshtables.sas
|
||||
@li mm_getrepos.sas
|
||||
|
||||
@ -44,6 +45,7 @@ run;
|
||||
%dc_assignlib(WRITE,&libref) /* write just in order to assign direct lib */
|
||||
%mpe_refreshlibs(lib=&libref)
|
||||
%mpe_refreshtables(&libref)
|
||||
%mpe_refreshcatalogs(&libref)
|
||||
%end;
|
||||
%else %do xx=1 %to &repocnt;
|
||||
options metarepository=&&repo&xx;
|
||||
@ -73,6 +75,7 @@ run;
|
||||
%do i=1 %to &libcnt;
|
||||
%dc_assignlib(WRITE,&&lib&i)
|
||||
%mpe_refreshtables(&&lib&i)
|
||||
%mpe_refreshcatalogs(&&lib&i)
|
||||
%end;
|
||||
%end;
|
||||
|
||||
|
@ -9,6 +9,7 @@
|
||||
<h4> SAS Macros </h4>
|
||||
@li mpe_refreshlibs.sas
|
||||
@li dc_assignlib.sas
|
||||
@li mpe_refreshcatalogs.sas
|
||||
@li mpe_refreshtables.sas
|
||||
|
||||
|
||||
@ -34,6 +35,8 @@ data libraries;
|
||||
str=cats('%mpe_refreshtables(',libref,')');
|
||||
put str;
|
||||
putlog str;
|
||||
str=cats('%mpe_refreshcatalogs(',libref,')');
|
||||
put str;
|
||||
run;
|
||||
%inc executor/source2;
|
||||
|
||||
|
@ -10,6 +10,7 @@
|
||||
@li mpe_refreshlibs.sas
|
||||
@li dc_assignlib.sas
|
||||
@li mpe_refreshtables.sas
|
||||
@li mpe_refreshcatalogs.sas
|
||||
|
||||
|
||||
@version 3.4
|
||||
@ -19,19 +20,29 @@
|
||||
4GL Apps Ltd.
|
||||
**/
|
||||
|
||||
%macro dc_refreshcatalog();
|
||||
%macro dc_refreshcatalog(libref);
|
||||
|
||||
%mpe_refreshlibs()
|
||||
|
||||
filename executor catalog 'work.code.code.source';
|
||||
data libraries;
|
||||
set &mpelib..mpe_datacatalog_libs;
|
||||
where &dc_dttmtfmt. le TX_TO;
|
||||
file executor;
|
||||
str=cats('%mpe_refreshtables(',libref,')');
|
||||
put str;
|
||||
putlog str;
|
||||
run;
|
||||
%inc executor;
|
||||
%if #&libref# ne ## %then %do;
|
||||
%put &sysmacroname: assigning specific libref, &libref;
|
||||
%dc_assignlib(WRITE,&libref) /* write just in order to assign direct lib */
|
||||
%mpe_refreshlibs(lib=&libref)
|
||||
%mpe_refreshtables(&libref)
|
||||
%mpe_refreshcatalogs(&libref)
|
||||
%end;
|
||||
%else %do;
|
||||
%mpe_refreshlibs()
|
||||
filename executor catalog 'work.code.code.source';
|
||||
data libraries;
|
||||
set &mpelib..mpe_datacatalog_libs;
|
||||
where &dc_dttmtfmt. le TX_TO;
|
||||
file executor;
|
||||
str=cats('%mpe_refreshtables(',libref,')');
|
||||
put str;
|
||||
str=cats('%mpe_refreshcatalogs(',libref,')');
|
||||
put str;
|
||||
putlog str;
|
||||
run;
|
||||
%inc executor;
|
||||
%end;
|
||||
|
||||
%mend dc_refreshcatalog;
|
||||
|
@ -7,6 +7,7 @@
|
||||
@li mf_getapploc.sas
|
||||
@li mf_mkdir.sas
|
||||
@li mf_trimstr.sas
|
||||
@li mp_abort.sas
|
||||
@li mpe_getvars.sas
|
||||
@li mpe_makedata.sas
|
||||
@li mpe_makedatamodel.sas
|
||||
@ -50,9 +51,33 @@ options noquotelenmax;
|
||||
%put &=admin;
|
||||
|
||||
%mf_mkdir(&dcpath)
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,mac=&_program
|
||||
,msg=%str(Unable to create &dcpath using &sysuserid)
|
||||
)
|
||||
%mf_mkdir(&dcpath/secret)
|
||||
%mf_mkdir(&dcpath/dc_staging)
|
||||
|
||||
/* check we have physical permissions to the DCLIB folder */
|
||||
data _null_;
|
||||
putlog "dcpath=&dcpath/permTest.txt";
|
||||
putlog "sysuserid=&sysuserid";
|
||||
data _null_;
|
||||
file "&dcpath/permTest.txt";
|
||||
run;
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,mac=&_program
|
||||
,msg=%str(User &sysuserid does not have WRITE permissions to: &dcpath )
|
||||
)
|
||||
filename delfile "&dcpath/permTest.txt";
|
||||
data _null_;
|
||||
rc=fdelete('delfile');
|
||||
run;
|
||||
%mp_abort(iftrue= (&syscc ne 0)
|
||||
,mac=&_program..sas
|
||||
,msg=%str(User &sysuserid could create (but not delete) &dcpath/permTest.txt )
|
||||
)
|
||||
|
||||
|
||||
libname &dclib "&dcpath";
|
||||
%global admin;
|
||||
@ -60,11 +85,23 @@ libname &dclib "&dcpath";
|
||||
%mpe_makedatamodel(lib=&dclib)
|
||||
%mpe_makedata(lib=&dclib,mpeadmins=&admin,path=%str(&dcpath))
|
||||
|
||||
%mp_abort(iftrue=(&syscc ne 0)
|
||||
,mac=&sysmacroname
|
||||
,msg=%str(Err during &dclib build)
|
||||
)
|
||||
|
||||
|
||||
/* sample data library */
|
||||
%mf_mkdir(&dcpath/dc_demo)
|
||||
libname dcdemo "&dcpath/dc_demo";
|
||||
%mpe_makesampledata(outlib=DCDEMO)
|
||||
|
||||
%mp_abort(iftrue=(&syscc ne 0)
|
||||
,mac=&sysmacroname
|
||||
,msg=%str(Err during demo data build)
|
||||
)
|
||||
|
||||
|
||||
/* the DC precode is stored in the root of the project */
|
||||
%let root=%mf_getapploc(&_program)/services;
|
||||
%put &=root;
|
||||
@ -167,7 +204,7 @@ run;
|
||||
*/
|
||||
%mp_abort(iftrue=(&syscc ne 0)
|
||||
,mac=&sysmacroname
|
||||
,msg=%str(Err during DB build)
|
||||
,msg=%str(Err during settings job creation)
|
||||
)
|
||||
|
||||
|
||||
|
@ -21,7 +21,7 @@ REMOVE THAT LAST MACRO
|
||||
%let syscc=0;
|
||||
%global apploc _program dclib defaultcontext _debug sasjs_mdebug dc_dttmtfmt;
|
||||
|
||||
%let defaultcontext=Datacontroller compute context;
|
||||
%let defaultcontext=SAS Job Execution compute context;
|
||||
%let sasjs_mdebug=0;
|
||||
|
||||
options mprint mprintnest nobomfile lrecl=32767;
|
||||
|
@ -28,7 +28,7 @@
|
||||
|
||||
%global apploc _program;
|
||||
|
||||
%let defaultcontext=Datacontroller compute context;
|
||||
%let defaultcontext=SAS Job Execution compute context;
|
||||
|
||||
data _null_;
|
||||
length _pgm $1000;
|
||||
@ -60,6 +60,9 @@ run;
|
||||
%let testloc=%sysfunc(pathname(&DC_LIBREF))/fmt%mf_getuniquefileref();
|
||||
%mf_mkdir(&testloc)
|
||||
libname dctest "&testloc";
|
||||
/* test library with only one format catalog */
|
||||
%mf_mkdir(&testloc/fmtonly)
|
||||
libname fmtonly "&testloc/fmtonly";
|
||||
|
||||
/* add formats */
|
||||
PROC FORMAT library=dctest.dcfmts;
|
||||
@ -99,6 +102,10 @@ run;
|
||||
proc append base=&dc_libref..mpe_tables data=work.append;
|
||||
run;
|
||||
|
||||
/* lone format catalog */
|
||||
proc format cntlin=work.fmts library=fmtonly.dcfmts;
|
||||
run;
|
||||
|
||||
/* add some other tables */
|
||||
%mp_coretable(LOCKTABLE,libds=dctest.locktable)
|
||||
%mp_coretable(DIFFTABLE,libds=dctest.difftable)
|
||||
@ -130,6 +137,7 @@ options mprint;
|
||||
put _infile_;
|
||||
if last then do;
|
||||
put "libname dctest '&testloc';";
|
||||
put "libname fmtonly '&testloc/fmtonly';";
|
||||
end;
|
||||
run;
|
||||
data _null_;
|
||||
@ -151,6 +159,7 @@ options mprint;
|
||||
put _infile_;
|
||||
if last then do;
|
||||
put "libname dctest '&testloc';";
|
||||
put "libname fmtonly '&testloc/fmtonly';";
|
||||
end;
|
||||
run;
|
||||
%ms_deletefile(&root/services/public/settings.sas)
|
||||
@ -182,6 +191,7 @@ options mprint;
|
||||
put _infile_;
|
||||
if last then do;
|
||||
put "libname dctest '&testloc';";
|
||||
put "libname fmtonly '&testloc/fmtonly';";
|
||||
end;
|
||||
run;
|
||||
%mm_deletestp(target=&root/services/public/Data_Controller_Settings)
|
||||
|
@ -2,6 +2,11 @@
|
||||
@file buildinitviya.sas
|
||||
@brief initialisation for viya build program
|
||||
|
||||
<h4> SAS Macros </h4>
|
||||
@li mfv_getfolderpath.sas
|
||||
@li mfv_getpathuri.sas
|
||||
@li mv_createfolder.sas
|
||||
|
||||
**/
|
||||
|
||||
options nonotes nomprint;
|
||||
@ -9,4 +14,8 @@ options nonotes nomprint;
|
||||
/* update apploc to default to user home area if not set */
|
||||
%let apploc=%sysfunc(ifc("&apploc"="/Public/app/dcplaceholder"
|
||||
,/Users/&sysuserid/My Folder/Data Controller
|
||||
,&apploc));
|
||||
,&apploc));
|
||||
|
||||
/* ensure the correct casing of appLoc */
|
||||
%mv_createfolder(path=&apploc)
|
||||
%let apploc=%mfv_getfolderpath(%mfv_getpathuri(&apploc));
|
Reference in New Issue
Block a user