postgres-mumu 0.2.0-rc.1

postgrtes-mumu is a plugin for the mumu ecosystem
Documentation 
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

extend("flow")
extend("postgres")
extend("string")

conn = pg:connect("postgres://tom:12345678@localhost/tom")

// Ensure table exists
pg:query(conn, `
  CREATE TABLE IF NOT EXISTS users (
    id SERIAL PRIMARY KEY,
    username TEXT NOT NULL,
    age INT NOT NULL,
    balance FLOAT
  )
`)

// Insert a user using named parameters
pg:query(
  conn,
  "INSERT INTO users (username, age, balance) VALUES ($username, $age, $balance)",
  [username: "tom", age: 42, balance: 123.45]
)

// Select all users, print username, age, balnce using flow:compose and slog
stream = pg:query(
  conn,
  "SELECT username, age, balance FROM users"
)

flow:compose(
  slog,
  flow:throttle(200),
  flow:trans(row => string:multi(row["username"], " ", row["age"], " ", row["balance"]))
)(stream)