kitz99

func updateRecord(fieldName string, newVal string, condFieldName string, condFieldValue int64) error {
	qryString := fmt.Sprintf("UPDATE posts set %s='%s' WHERE %s=%d", fieldName, newVal, condFieldName, condFieldValue)

	fmt.Printf("Query: %v\n", qryString)
	_, err := roachConnection.Exec(qryString)

	return err
}

kitz99

func readRecords() []Post {
	var result []Post
	rows, err := roachConnection.Query("select * FROM posts;")
	if err != nil {
		log.Fatal(err)
	}

	defer rows.Close()

	for rows.Next() {

kitz99

func createRecord(post Post) error {
	qryString := fmt.Sprintf(
		"INSERT INTO posts (name, category, author, created_at, updated_at) VALUES ('%s', '%s', '%s', NOW(), NOW())",
		post.Name, post.Category, post.Author)

	_, err := roachConnection.Exec(qryString)
	return err
}

kitz99

func init() {
	roachConnection, err := sql.Open("postgres", "postgresql://root@localhost:26257/blog_db?sslmode=disable")

	if err != nil {
		panic("Could not establish connection to CockroachDB")
	}
}

kitz99

$ docker exec -it goroach_master_1 ./cockroach sql --insecure

> create database blog_db;
> set database = blog_db;

> CREATE TABLE "posts" (
    "id" SERIAL,
    "name" STRING(100),
    "category" STRING(50),
    "author" STRING(50),

kitz99

version: '2'

networks:
  roachnet:

services:
  master:
    image: cockroachdb/cockroach:v2.0.3
    command: start --insecure
    ports:

kitz99

#!/bin/bash
echo "Hello world"