Advertisement
Guest User

Untitled

a guest
Jul 17th, 2018
97
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.08 KB | None | 0 0
  1. final static String SQL_USER = "ephesoft";
  2. final static String SQL_PASSWORD = "C@pture2O2O";
  3. final static String SQL_DRIVER = "net.sourceforge.jtds.jdbc.Driver";
  4. final static String DATABASE_NAME = "ephesoft";
  5. final static String SQL_CONNECTION_STRING = "jdbc:jtds:sqlserver://localhost:1433/" + DATABASE_NAME;
  6. final static String SQL_TABLE = "batch_instance_groups";
  7.  
  8.  
  9. import java.io.File;
  10. import java.io.FileNotFoundException;
  11. import java.io.FileOutputStream;
  12. import java.io.FileWriter;
  13. import java.io.IOException;
  14. import java.io.OutputStream;
  15. import java.util.List;
  16. import java.util.zip.ZipEntry;
  17. import java.util.zip.ZipOutputStream;
  18.  
  19. import org.hibernate.HibernateException;
  20. import org.hibernate.SQLQuery;
  21. import org.hibernate.StatelessSession;
  22. import org.hibernate.Transaction;
  23. import org.jdom.Document;
  24. import org.jdom.Element;
  25. import org.jdom.input.SAXBuilder;
  26. import org.jdom.output.XMLOutputter;
  27.  
  28. import com.ephesoft.dcma.core.DCMAException;
  29. import com.ephesoft.dcma.core.component.ICommonConstants;
  30. import com.ephesoft.dcma.core.hibernate.DynamicHibernateDao;
  31. import com.ephesoft.dcma.script.IJDomScript;
  32. import com.ephesoft.dcma.util.ApplicationConfigProperties;
  33. import com.ephesoft.dcma.util.logger.EphesoftLogger;
  34. import com.ephesoft.dcma.util.logger.ScriptLoggerFactory;
  35.  
  36.  
  37.  
  38. //method to get batch instance identifier
  39. public static void assignedBatchInstanceGroup(String batchInstanceIdentifier, String userRole ) throws DCMAException {
  40.  
  41. DynamicHibernateDao dynamicHibernateDao = null;
  42. try {
  43. dynamicHibernateDao = new DynamicHibernateDao(SQL_USER, SQL_PASSWORD, SQL_DRIVER, SQL_CONNECTION_STRING);
  44. StatelessSession statelessSession = null;
  45.  
  46. statelessSession = dynamicHibernateDao.getStatelessSession();
  47. Transaction transaction = statelessSession.getTransaction();
  48. StringBuffer dbQueryBuffer = new StringBuffer();
  49. if (SQL_CONNECTION_STRING.contains("mysql")) {
  50. dbQueryBuffer.append("INSERT INTO ");
  51. dbQueryBuffer.append(SQL_TABLE);
  52. dbQueryBuffer.append(" (creation_date, last_modified, batch_instance_id, group_name) VALUES (NOW(), NOW(), '");
  53. dbQueryBuffer.append(batchInstanceIdentifier);
  54. dbQueryBuffer.append("', '");
  55. dbQueryBuffer.append(userRole);
  56. dbQueryBuffer.append("')");
  57. } else if (SQL_CONNECTION_STRING.contains("sqlserver")) {
  58. dbQueryBuffer.append("INSERT INTO ");
  59. dbQueryBuffer.append(SQL_TABLE);
  60. dbQueryBuffer.append(" (creation_date, last_modified, batch_instance_id, group_name) VALUES (GETDATE(), GETDATE(), '");
  61. dbQueryBuffer.append(batchInstanceIdentifier);
  62. dbQueryBuffer.append("', '");
  63. dbQueryBuffer.append(userRole);
  64. dbQueryBuffer.append("')");
  65. }
  66.  
  67. SQLQuery query = statelessSession.createSQLQuery(dbQueryBuffer.toString());
  68. transaction.begin();
  69. query.executeUpdate();
  70. transaction.commit();
  71. statelessSession.close();
  72. } catch (HibernateException e) {
  73. System.err.println(e.getMessage());
  74. e.printStackTrace();
  75. } finally {
  76. if (dynamicHibernateDao != null) {
  77. dynamicHibernateDao.closeSession();
  78. }
  79. }
  80.  
  81.  
  82. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement