30:T6dc,class HeavyAIDatabaseClient { static async open({ protocol = "https", port = protocol === "https" ? "443" : undefined, host, dbName, user, password } = {}) { const connector = new HeavyAI.DbCon(); if (protocol !== undefined) connector.protocol(protocol); if (host !== undefined) connector.host(host); if (port !== undefined) connector.port(port); if (dbName !== undefined) connector.dbName(dbName); if (user !== undefined) connector.user(user); if (password !== undefined) connector.password(password); return new HeavyAIDatabaseClient(await connector.connectAsync()); } constructor(connector) { Object.defineProperty(this, "connector", {value: connector}); } async describe(name) { if (name !== undefined) { const fields = await this.connector.getFieldsAsync(name); const table = htl.html`${fields.columns.map(c => htl.html``)}

name	type	precision	is_array	is_dict
${c.name}	${c.type}	${c.precision}	${c.is_array}	${c.is_dict}

`; table.value = fields.columns; return table; } const tables = await this.connector.getTablesAsync(); const table = htl.html`${tables.map(t => htl.html``)}

name	label
${t.name}	${t.label}

`; table.value = tables; return table; } async sql(strings, ...args) { if (strings.length > 1) throw new Error("query parameters not supported"); return this.connector.queryAsync(strings[0]); } }31:[] 2e:{"title":"Hello, HEAVY.AI","cells":[{"id":0,"value":"# Hello, HEAVY.AI\n\nFormerly known as OmniSci and MapD. To use in your notebook:\n\n~~~js\nimport {HeavyAIDatabaseClient} from \"@observablehq/heavyai\"\n~~~\n\nThen call `HeavyAIDatabaseClient.open`, and use the result with a [SQL cell](/@observablehq/sql).","pinned":false,"hidden":false,"mode":"md"},{"id":46,"value":"demo = HeavyAIDatabaseClient.open({\n protocol: \"https\",\n host: \"demo-flights.heavy.ai\",\n port: \"443\",\n dbName: \"newflights\",\n user: \"demouser\",\n password: \"HyperInteractive\"\n})","pinned":true,"hidden":false,"mode":"ojs"},{"id":23,"value":"demo.describe()","pinned":true,"hidden":false,"mode":"ojs"},{"id":36,"value":"SELECT carrier_name, AVG(airtime) AS avg_airtime\nFROM flights\nWHERE airtime IS NOT NULL\nGROUP BY carrier_name\nORDER BY avg_airtime DESC","pinned":true,"hidden":false,"mode":"sql","output":"flights","database":"var:demo"},{"id":99,"value":"SELECT COUNT(*) AS \"count\"\nFROM flights\nWHERE airtime IS NOT NULL","pinned":true,"hidden":false,"mode":"sql","output":"","database":"var:demo"},{"id":81,"value":"Plot.plot({\n marginLeft: 150,\n y: {\n label: null\n },\n marks: [\n Plot.barX(flights, {x: \"avg_airtime\", y: \"carrier_name\", sort: {y: \"x\"}}),\n Plot.ruleX([0])\n ]\n})","pinned":true,"hidden":false,"mode":"ojs"},{"id":84,"value":"---\n\n## Implementation","pinned":false,"hidden":false,"mode":"md"},{"id":38,"value":"$30","pinned":true,"hidden":false,"mode":"ojs"},{"id":141,"value":"MapDDatabaseClient = HeavyAIDatabaseClient // for backwards compatibility","pinned":true,"hidden":false,"mode":"ojs"},{"id":3,"value":"HeavyAI = (await import(\"https://cdn.jsdelivr.net/npm/@heavyai/connector@7/+esm\")).default","pinned":true,"hidden":false,"mode":"ojs"}],"files":"$W31","stdlib":"1","titling":"auto"}