Store JSON in MYSQL:- Here below snippet will show you how we can store json data in mysql and read the json data from mysql and convert into a java object. Remember that the field where you can store the JSON data in mysql to set data type of that field is TEXT.
pom.xml
project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com</groupId>
<artifactId>StoreJson</artifactId>
<version>0.0.1-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
<version>20090211</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.6</version>
</dependency>
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-mapper-asl</artifactId>
<version>1.9.13</version>
</dependency>
</dependencies>
</project>
EmpModel.java
public class EmpModel {
private int empId;
private String name;
private String notes;
public int getEmpId() {
return empId;
}
public void setEmpId(int empId) {
this.empId = empId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getNotes() {
return notes;
}
public void setNotes(String notes) {
this.notes = notes;
}
}
WriteJSONData.java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;
import org.codehaus.jackson.map.ObjectMapper;
public class WriteJSONData {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
try{
ObjectMapper objMap=new ObjectMapper();
EmpModel empModel=new EmpModel();
empModel.setEmpId(101);
empModel.setName("Manish");
empModel.setNotes("Hello manish how are you");
Connection con=null;
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/mahi","root","");
PreparedStatement pstmt=con.prepareStatement("INSERT INTO emp(empId,name,notes) VALUES(?,?,?)");
pstmt.setInt(1,101 );
pstmt.setString(2, "Manish");
pstmt.setObject(3, objMap.defaultPrettyPrintingWriter().writeValueAsString(empModel));
pstmt.execute();
}
catch(Exception e){e.printStackTrace();}
}
}
ReadJSONData.java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import org.codehaus.jackson.map.ObjectMapper;
public class ReadJSONData {
/**
* @param args
*/
public static void main(String[] args)throws Exception {
ObjectMapper objMap=new ObjectMapper();
Connection con=null;
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/mahi","root","");
PreparedStatement pstmt=con.prepareStatement("SELECT * FROM emp");
ResultSet rs=pstmt.executeQuery();
while(rs.next())
{
EmpModel empModel=(EmpModel)objMap.readValue(rs.getString(3), EmpModel.class);
System.out.println(empModel.getEmpId());
System.out.println(empModel.getName());
System.out.println(empModel.getNotes());
}
}
}
0 Comment(s)