Dynamic JSON passing to REST Web service and using it to insert data into mysql db

[Jack Rooney]

Hello,

I am trying to pass a dynamic JSON string to my REST Web service which will in turn be used to populate a mysql db.
I can do this using a hard-coded JSON string,however I dont know how to pass a dynamic JSON string. Any insight is appreciated
as I am very new to this topic. Thanks a lot for all your time. I am attaching my code which I have for the hard-coded JSON
string parsing and adding to a mysql db.

My POJO:

import static javax.persistence.GenerationType.IDENTITY;

import java.util.Date;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;
import javax.persistence.Temporal;
import javax.persistence.TemporalType;
import javax.persistence.UniqueConstraint;

@Entity
@Table(name = "Stock", catalog = "StockDb", uniqueConstraints = {
        @UniqueConstraint(columnNames = "stock_id"),
        @UniqueConstraint(columnNames = "stock_name"),})

public class Stock implements java.io.Serializable {

    private static final long serialVersionUID = 1L;

    private Integer stock_id;
    private String stock_name;

    @Id
    @GeneratedValue(strategy = IDENTITY)
    @Column(name = "stock_id", unique = true, nullable = false)
    public Integer getId() {
        return id;
    }

    public void setstock_id(Integer stock_id) {
        this.stock_id = stock_id;
    }

    @Column(name = "stock_name", unique = true, nullable = false, length = 30)
    public String getstock_name() {
        return stock_name;
    }

    public void setstock_name(String stock_name) {
        this.stock_name = stock_name;
    }

}

My HibernateUtil class :

import org.hibernate.SessionFactory;
import org.hibernate.cfg.AnnotationConfiguration;

public class HibernateUtil {
    private static final SessionFactory sessionFactory = buildSessionFactory();

    private static SessionFactory buildSessionFactory() {
        try {
            // Create the SessionFactory from hibernate.cfg.xml
            return new AnnotationConfiguration().configure().buildSessionFactory();

        } catch (Throwable ex) {
            // Make sure you log the exception, as it might be swallowed
            System.err.println("Initial SessionFactory creation failed." + ex);
            throw new ExceptionInInitializerError(ex);
        }
    }

    public static SessionFactory getSessionFactory() {
        return sessionFactory;
    }

    public static void shutdown() {
        // Close caches and connection pools
        getSessionFactory().close();
    }
}

My SessionFactoryContextListener class :

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;

import org.apache.log4j.Logger;
import org.hibernate.Session;

@WebListener
public class SessionFactoryListener implements ServletContextListener {

    private Logger LOG = Logger.getLogger(SessionFactoryListener.class);

    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        if (LOG.isInfoEnabled()) {
            LOG.info("\n\tInside contextInitialized()---\n");
        }
        Session session = HibernateUtil.getSessionFactory().openSession();
    }

    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        if (LOG.isInfoEnabled()) {
            LOG.info("\n\tInside contextDestroyed()\n");
        }
        HibernateUtil.shutdown();   
    }   

}

My StackService.java

import java.util.Date;

import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

import org.apache.log4j.Logger;
import org.hibernate.Session;

import com.google.gson.Gson;
import com.tracker.domain.Flow;
import com.tracker.persistence.HibernateUtil;
@Path("")
public class StackService {

    private Logger LOG = Logger.getLogger(StackService.class);



    /**
     * curl -X GET http://localhost:8080/stack
     */
    @GET
    @Path("")
    @Produces(MediaType.APPLICATION_JSON)
    public void getStock() {

        String stackJsonString = "{\"stack_name\":\"GOOG\",\"id\":null\"}";
        Gson gson = new Gson();
        Stack stock = gson.fromJson(stockJsonString, stock.class);
        Session session = HibernateUtil.getSessionFactory().getCurrentSession();

        String stockName = stock.getstock_name();
        stock.setstock_name(stockName);

        session.beginTransaction();
        session.save(stock);
        session.getTransaction().commit();


    }
}

My Hibernate.cfg

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        <property name="hibernate.bytecode.use_reflection_optimizer">false</property>
        <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/StockDb</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.connection.password">root</property>
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
        <property name="show_sql">true</property>
        <property name="current_session_context_class">thread</property>
        <mapping class="com.stackapp.domain.Stock"></mapping>
    </session-factory>
</hibernate-configuration>

Thanks,
Jack

[Bear Bibeault]

There are plenty of JSON libraries: Gson, Jackson, Stringtree, ...

Choose one that pleases your sensibilities.

[Jack Rooney]

Hi Bear,

Thanks a lot for the reply. I have already used GSON to parse the JSON string to a Java object. However, I am using a hard-coded JSON. I want to dynamicaly pass the JSON string in a URI and use that string to populate a mysql db.
Right now my URI is something like this :
http://localhost:8080/stack

I actually want the URI to be something like this :

curl -X POST -H'Content-Type:application/json' -d'{"stock_name":"GOOG"}' http://localhost:8080/stack

Kindly help me out.

Thanks,
Jack