Advertisement
Guest User

Untitled

a guest
Jan 29th, 2017
102
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.62 KB | None | 0 0
  1. enter code here
  2. import java.io.InputStream;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.SQLException;
  7. import java.util.Iterator;
  8.  
  9. import org.apache.commons.io.IOUtils;
  10. import org.springframework.boot.SpringApplication;
  11. import org.springframework.boot.autoconfigure.SpringBootApplication;
  12.  
  13. import net.sf.json.JSONArray;
  14. import net.sf.json.JSONObject;
  15. import net.sf.json.JSONSerializer;
  16.  
  17. @SpringBootApplication
  18. public class DemoRProjetSpringAppApplication {
  19. private static String tableName = "etudiants";
  20. public static void main(String[] args) {
  21. SpringApplication.run(DemoRProjetSpringAppApplication.class, args);
  22.  
  23.  
  24.  
  25. try {
  26.  
  27. ClassLoader cl =DemoRProjetSpringAppApplication.class.getClassLoader();
  28. InputStream is = cl.getResourceAsStream("etudiants.json");
  29. String str = IOUtils.toString(is);
  30. JSONObject jsonObject = (JSONObject) JSONSerializer.toJSON(str);
  31. JSONArray jsonArr = jsonObject.getJSONArray("profiles");
  32. JSONObject obj = null;
  33. JSONArray nameArr = null;
  34. JSONArray valArr = null;
  35.  
  36. for (int i = 0; i < jsonArr.size(); i++) {
  37. obj = jsonArr.getJSONObject(i);
  38. nameArr = obj.names();
  39. valArr = obj.toJSONArray(nameArr);
  40. saveRecord(nameArr, valArr);
  41. }
  42. } catch (Exception e) {
  43. e.printStackTrace();
  44. }
  45. }
  46. private static void saveRecord(JSONArray nameArray, JSONArray valArray) {
  47. Connection conn = getConnection();
  48. StringBuffer sb = new StringBuffer("insert into " + tableName + "(");
  49. int size = nameArray.size();
  50. int count = 0;
  51. Iterator<Object> iterator = nameArray.iterator();
  52.  
  53. while (iterator.hasNext()) {
  54. if (count < (size - 1))
  55. sb.append(iterator.next() + ",");
  56. else
  57. sb.append(iterator.next() + ")");
  58. count++;
  59. }
  60. sb.append(" values(");
  61.  
  62. for (int i = 0; i < size; i++) {
  63. if (i < (size - 1))
  64. sb.append("?,");
  65. else
  66. sb.append("?)");
  67. }
  68. System.out.println(sb.toString());
  69. try {
  70. PreparedStatement pstmt = conn.prepareStatement(sb.toString());
  71. bindVariables(valArray, pstmt);
  72. pstmt.executeUpdate();
  73. } catch (SQLException e) {
  74. e.printStackTrace();
  75. }
  76. }
  77. private static void bindVariables(JSONArray valArray,
  78. PreparedStatement pstmt) throws SQLException {
  79. Iterator<Object> iterator = valArray.iterator();
  80. int cnt = 0;
  81. while (iterator.hasNext()) {
  82. Object obj = iterator.next();
  83. if (obj instanceof String) {
  84. pstmt.setString(++cnt, (String) obj);
  85. } else if (obj instanceof Integer) {
  86. pstmt.setLong(++cnt, (Integer) obj);
  87. } else if (obj instanceof Long) {
  88. pstmt.setLong(++cnt, (Long) obj);
  89. } else if (obj instanceof Double) {
  90. pstmt.setDouble(++cnt, (Double) obj);
  91. }
  92. }
  93. }
  94. private static Connection getConnection() {
  95. Connection con = null;
  96. String url = "jdbc:mysql://localhost:3306/";
  97. String db = "projet2";
  98. String driver = "com.mysql.jdbc.Driver";
  99. String user = "root";
  100. String pass = "password";
  101. try {
  102. Class.forName(driver);
  103. con = DriverManager.getConnection(url + db, user, pass);
  104. } catch (ClassNotFoundException e) {
  105. e.printStackTrace();
  106. } catch (SQLException e) {
  107. e.printStackTrace();
  108. }
  109. return con;
  110. }
  111. }
  112.  
  113. enter code here
  114.  
  115. import java.util.List;
  116. import javax.persistence.Entity;
  117. import javax.persistence.ManyToOne;
  118. import javax.persistence.OneToMany;
  119. import javax.persistence.Table;
  120. import java.util.List;
  121.  
  122. import javax.persistence.Entity;
  123. import javax.persistence.ManyToOne;
  124. import javax.persistence.OneToMany;
  125. import javax.persistence.OneToOne;
  126. import javax.persistence.Table;
  127.  
  128. @Entity
  129. @Table(name = "etudiants")
  130. public class Student extends User {
  131. @ManyToOne
  132. private Grade grade;
  133.  
  134.  
  135. public Grade getGrade() {
  136. return grade;
  137. }
  138. public void setGrade(Grade grade) {
  139. this.grade= grade;
  140. }
  141.  
  142. public Student() {
  143. super();
  144. }
  145.  
  146. public Student(Integer id) {
  147. super(id);
  148. }
  149. public Student(String firstname, String lastname, String login,
  150. String email, String password,UserType student) {
  151. super(firstname, lastname, login,email, password,student);
  152. }
  153. public Student(String firstname, String lastname, String login,
  154. String email,String password,UserType student,Grade grade) {
  155. super(firstname, lastname, login,email, password, student);
  156. this.grade = grade;
  157.  
  158. }
  159. public Student(String firstname, String lastname, String login,String email,
  160. String password,UserType student,Grade grade,UserType STUDENT) {
  161. super(firstname, lastname, login,email, password,student);
  162. this.grade = grade;
  163.  
  164. }
  165. }
  166.  
  167. enter code here
  168. {"profiles":[{"id":1, "email":"NULL", "firstname":"MARY", "lastname":"mahdi", "login":"mdi.MARY", "password":"pass", "userTypeID":2, "grade_id":1},
  169. {"id":2, "email":"jasmin.mal@hotmail.fr", "firstname":"jasmin", "lastname":"Mal", "login":"jasmin.Mal", "password":"pass", "userTypeID":2, "grade_id":1},
  170. {"id":3, "email":"kira.muip@msn.com", "firstname":"muip", "lastname":"kira", "login":"kira.muip", "password":"pass", "userTypeID":2, "grade_id":1}]
  171. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement