-
Notifications
You must be signed in to change notification settings - Fork 13
/
FastExportTable.ts
89 lines (74 loc) · 2.25 KB
/
FastExportTable.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
// Copyright 2023 by Teradata Corporation. All rights reserved.
// This sample program demonstrates how to FastExport rows from a table.
// @ts-ignore
import { TeradataConnection, TeradataCursor, OperationalError } from "teradatasql";
type Rows = any[];
const con: TeradataConnection = new TeradataConnection();
con.connect({ host: "whomooz", user: "guest", password: "please" });
const cur: TeradataCursor = con.cursor();
const cur2: TeradataCursor = con.cursor();
const sTableName: string = "FastExportTable";
let sRequest: string = "DROP TABLE " + sTableName;
try {
console.log(sRequest);
cur.execute(sRequest);
} catch (ex) {
if (ex instanceof OperationalError) {
console.log("Ignoring", ex.message.split("\n")[0]);
} else {
throw ex;
}
}
sRequest = "CREATE TABLE " + sTableName + " (c1 INTEGER NOT NULL, c2 VARCHAR(10))";
console.log(sRequest);
cur.execute(sRequest);
try {
const sInsert: string = "INSERT INTO " + sTableName + " VALUES (?, ?)";
console.log(sInsert);
cur.execute(sInsert, [
[1, null],
[2, "abc"],
[3, "def"],
[4, "mno"],
[5, null],
[6, "pqr"],
[7, "uvw"],
[8, "xyz"],
[9, null],
]);
let sSelect = "{fn teradata_try_fastexport}SELECT * FROM " + sTableName;
console.log(sSelect);
cur.execute(sSelect);
let rows: Rows = cur.fetchall();
for (const row of rows.sort()) {
console.log(row);
}
sRequest = "{fn teradata_nativesql}{fn teradata_get_warnings}" + sSelect;
console.log(sRequest);
cur2.execute(sRequest);
rows = cur2.fetchall();
for (const row of rows) {
console.log(row);
}
sRequest = "{fn teradata_nativesql}{fn teradata_get_errors}" + sSelect;
console.log(sRequest);
cur2.execute(sRequest);
rows = cur2.fetchall();
for (const row of rows) {
console.log(row);
}
sRequest = "{fn teradata_nativesql}{fn teradata_logon_sequence_number}" + sSelect;
console.log(sRequest);
cur2.execute(sRequest);
rows = cur2.fetchall();
for (const row of rows) {
console.log(row);
}
} finally {
sRequest = "DROP TABLE " + sTableName;
console.log(sRequest);
cur2.execute(sRequest);
}
cur.close();
cur2.close();
con.close();