logo Windmill Hub
Login
All items

Execute arbitrary Query in Deno

Execute an arbitrary query on a MySQL resource, more at: https://www.windmill.dev/docs/getting_started/scripts_quickstart/sql

Script mysql Verified

by henri186 ยท 3/11/2024

Use in Windmill

The script

Submitted by hugo989 Bun
Verified 4 days ago
All edits
Permalink
1 
import mysql from "mysql2/promise";
2
3 
// Define the MySQL resource type as specified
4 
type Mysql = {
5 
  ssl: boolean,
6 
  host: string,
7 
  port: number,
8 
  user: string,
9 
  database: string,
10 
  password: string
11
12 
}
13
14 
// The main function that executes a query on a MySQL database
15 
export async function main(
16 
  mysqlResource: Mysql,
17 
  query: string,
18 
): Promise<any> {
19 
  // Adjust the SSL configuration based on the mysqlResource.ssl value
20 
  const sslConfig = mysqlResource.ssl ? { rejectUnauthorized: true } : false;
21
22 
  // Create a new connection using the provided MySQL resource
23 
  const conn = await mysql.createConnection({
24 
    host: mysqlResource.host,
25 
    user: mysqlResource.user,
26 
    database: mysqlResource.database,
27 
    password: mysqlResource.password,
28 
    port: mysqlResource.port,
29 
    // Use the adjusted SSL configuration
30 
    ssl: sslConfig,
31 
  });
32
33 
  try {
34 
    // Execute the query
35 
    const [rows] = await conn.query(query);
36 
    return rows;
37 
  } catch (error) {
38 
    // If an error occurs, throw it to be handled by the caller
39 
    throw new Error(`Failed to execute query: ${error}`);
40 
  } finally {
41 
    // Always close the connection after the operation is complete
42 
    await conn.end();
43 
  }
44 
}
45
Other submissions
  • Submitted by henri186 Deno
    Created 396 days ago
    All edits
    Permalink
    1 
    import { createPool as createMysqlPool } from "npm:mysql2/promise";
    2
    3 
    // Define the MySQL resource type as specified
    4 
    type Mysql = {
    5 
      ssl: boolean,
    6 
      host: string,
    7 
      port: number,
    8 
      user: string,
    9 
      database: string,
    10 
      password: string
    11
    12 
    }
    13
    14 
    // The main function that executes a query on a MySQL database
    15 
    export async function main(
    16 
      mysqlResource: Mysql,
    17 
      query: string,
    18 
    ): Promise<any> {
    19 
      // Adjust the SSL configuration based on the mysqlResource.ssl value
    20 
      const sslConfig = mysqlResource.ssl ? { rejectUnauthorized: true } : false;
    21
    22 
      // Create a new connection pool using the provided MySQL resource
    23 
      const pool = createMysqlPool({
    24 
        host: mysqlResource.host,
    25 
        user: mysqlResource.user,
    26 
        database: mysqlResource.database,
    27 
        password: mysqlResource.password,
    28 
        port: mysqlResource.port,
    29 
        // Use the adjusted SSL configuration
    30 
        ssl: sslConfig,
    31 
        waitForConnections: true,
    32 
        connectionLimit: 10,
    33 
        queueLimit: 0,
    34 
      });
    35
    36 
      try {
    37 
        // Get a connection from the pool and execute the query
    38 
        const [rows] = await pool.query(query);
    39 
        return rows;
    40 
      } catch (error) {
    41 
        // If an error occurs, throw it to be handled by the caller
    42 
        throw new Error(`Failed to execute query: ${error}`);
    43 
      } finally {
    44 
        // Always close the pool after the operation is complete
    45 
        await pool.end();
    46 
      }
    47 
    }