Insert

WITH
    # Input data
    raw_json := to_json('[
      {
        "title": "1/3 bulk insert",
        "body": "The first piece of text is OK",
        "hashtags": ["exciting", "bulk"]
      },
      {
        "title": "2/3 bulk insert",
        "body": "The second chunk could be longer",
        "hashtags": ["bulk"]
      },
      {
        "title": "3/3 bulk insert",
        "body": "The last piece should have a puppy",
        "hashtags": ["puppies", "bulk"]
      }
    ]'),
    # Get the user the posts belong to
    dana := (SELECT User FILTER .email = 'dana@tutorial.com')
# First, cast the raw data into an array of JSON.
# Then, unpack that array into a set of JSON, where each
# element is now JSON data for a single post.
FOR post IN {array_unpack(<array<json>>raw_json)}
UNION (
    INSERT Text {
        author := dana,
        # JSON object fields can be accessed by name,
        # then a cast is needed to convert the values to
        # str.
        title := <str>post['title'],
        body := <str>post['body'],
        hashtags := <str>array_unpack(
            <array<json>>post['hashtags']
        )
    }
)

SELECT Text {
    author: {
        name
    },
    title,
    body,
    hashtags,
    # We didn't provide one, so we expect the current
    # timestamp here
    post_date
} FILTER
    # We can just get the most recent posts from last 10
    # seconds
    .post_date > datetime_current() - <duration>'10s'
ORDER BY .post_date;