AnanthaRajuC

curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" 127.0.0.1:8083/connectors/ -d '{
  "name": "sample_db-connector",
  "config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "plugin.name": "pgoutput",
    "database.hostname": "postgres",
    "database.port": "5432",
    "database.user": "admin",
    "database.password": "admin",
    "database.dbname": "sample_db",

AnanthaRajuC

version: "3.7"
services:
  postgres:
    image: postgres:latest
    container_name: postgres-latest
    ports:
      - 5432:5432
    environment:
      - POSTGRES_USER=admin
      - POSTGRES_PASSWORD=admin

AnanthaRajuC

version: "3.7"
services:
  postgres:
    image: postgres:latest
    container_name: postgres-latest
    ports:
      - 5432:5432
    environment:
      - POSTGRES_USER=admin
      - POSTGRES_PASSWORD=admin

AnanthaRajuC

System Requirements

1. Apache Superset requires Python evironment. Install Python 3.6.
2. Install Microsoft Visual C++ 14.0 with Build Tools for Visual Studio 2019. Make sure the following tools are selected.
   • MSVC v142 - VS 2019 C++ x64/x86 build tools (v14.24)
   • Windows 10 SDK (10.0.18362.0)

Requirements and Environment Set-Up

The below steps are used to setup the environment

1. Open Command Prompt in Administrator Mode move to C:\

AnanthaRajuC

select tab.table_schema as database_schema,
    tab.table_name as table_name,
    col.ordinal_position as column_id,
    col.column_name as column_name,
    col.data_type as data_type,
    case when col.numeric_precision is not null
        then col.numeric_precision
        else col.character_maximum_length end as max_length,
    case when col.datetime_precision is not null
        then col.datetime_precision

AnanthaRajuC

Columns

schema_name - database name
table_name - table name
column_id - table column id, starting at 1 for each table
column_name - name of the column
data_type - column data type
max_length - data type max length
precision - data type precision

AnanthaRajuC

import org.apache.commons.codec.DecoderException;
import org.apache.commons.codec.binary.Hex;

import javax.crypto.*;
import javax.crypto.spec.SecretKeySpec;
import java.io.UnsupportedEncodingException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;

AnanthaRajuC

package io.github.anantharajuc.springdatarest.model.projection;

import io.github.anantharajuc.springdatarest.model.Person;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.rest.core.config.Projection;

@Projection(name="idAndFullName", types={Person.class})
public interface IdAndFullName {
  Long getId();

AnanthaRajuC

package io.github.anantharajuc.springdatarest.config;


import io.github.anantharajuc.springdatarest.model.Person;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.rest.core.config.RepositoryRestConfiguration;
import org.springframework.data.rest.webmvc.config.RepositoryRestConfigurer;
import org.springframework.web.servlet.config.annotation.CorsRegistry;

@Configuration

AnanthaRajuC

package io.github.anantharajuc.springdatarest.repository;

import io.github.anantharajuc.springdatarest.model.Person;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.rest.core.annotation.RepositoryRestResource;

@RepositoryRestResource(path="persons")
public interface PersonRepository extends JpaRepository<Person, Long> {
}