dvliman

// src/main/resources/application.properties

demo.db.url = jdbc:postgresql://localhost/demo

dvliman

// src/main/kotlin/com/dvliman/demo/Beans.kt

package com.dvliman.demo

import org.davidmoten.rx.jdbc.Database
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration

@Configuration
class Beans {

dvliman

// build.gradle

dependencies {

    implementation 'com.github.davidmoten:rxjava2-jdbc:0.2.2'
    implementation 'org.postgresql:postgresql:42.2.5'
}

dvliman

// src/main/kotlin/com/dvliman/demo/Config.kt

package com.dvliman.demo;

import org.springframework.beans.factory.annotation.Value
import org.springframework.context.annotation.Component

@Component
class Config {

dvliman

INSERT INTO users (name, email) VALUES ('some-name', 'some-email');

SELECT * FROM users;

SELECT user_id, name, email FROM users WHERE user_id = '1';

dvliman

--  setup.sql

CREATE DATABASE demo;

CREATE TABLE users (
    user_id SERIAL PRIMARY KEY,
    name    TEXT NOT NULL,
    email   TEXT NOT NULL UNIQUE
);

dvliman

package com.guardtime.amgenlink

import com.sun.org.apache.xerces.internal.dom.DOMInputImpl
import com.sun.org.apache.xerces.internal.impl.xs.XSComplexTypeDecl
import com.sun.org.apache.xerces.internal.impl.xs.XSImplementationImpl
import com.sun.org.apache.xerces.internal.impl.xs.XSModelGroupImpl
import com.sun.org.apache.xerces.internal.impl.xs.XSParticleDecl
import com.sun.org.apache.xerces.internal.xs.*
import org.w3c.dom.bootstrap.DOMImplementationRegistry
import org.w3c.dom.ls.LSInput

dvliman

(ns pipejine.core
  (:require [clojure.tools.logging :as log]
            [clojure.stacktrace :as st])
  (:import [java.util.concurrent LinkedBlockingQueue CountDownLatch TimeUnit]
           [org.slf4j MDC]))

(defn new-queue
  "Create and initialize a new queue"
  [{:keys [name queue-size number-of-consumer-threads number-of-producers partition time-out]
    :or {name (gensym name), queue-size 1, number-of-consumer-threads 1,

dvliman

(ns your.namespace.async-util
    (:require
      [clojure.core.async :as a :refer [>! <! >!! <!! go chan buffer
                                        close! thread alts! alts!! timeout]]
      [clojure.core.match :as match :refer [match]]))

;;
;; core.async util fns
;;

dvliman

{
  "id": "3f5d6a4e-c284-4f78-bfdf-7669b45af907",
  "name": "Uber",
  "legalName": "Uber Technologies, Inc.",
  "domain": "uber.com",
  "domainAliases": [
    "uber.org",
    "ubercab.com"
  ],
  "site": {