Advertisement
joseph_pravato

JDBC Transaction Test Case

Feb 28th, 2013
178
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.10 KB | None | 0 0
  1. import java.sql.Connection;
  2. import java.sql.Driver;
  3. import java.sql.DriverManager;
  4. import java.sql.ResultSet;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  7.  
  8. public class PostgresJDBCTest
  9. {
  10. private static final String URL = "url";
  11. private static final String USERNAME = "username";
  12. private static final String PASSWORD = "password";
  13.  
  14. private static final String CLASS_NAME = "org.postgresql.Driver";
  15.  
  16. public static void main(String[] args)
  17. {
  18. try
  19. {
  20. Driver driver = (Driver)Class.forName(CLASS_NAME).newInstance();
  21. DriverManager.registerDriver(driver);
  22. }
  23. catch(Exception e)
  24. {
  25. System.err.println("Postgres Driver initialization failed: " + e.getMessage());
  26. System.exit(0);
  27. }
  28.  
  29. Connection conn = null;
  30.  
  31. try
  32. {
  33. conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
  34. conn.setAutoCommit(false);
  35. }
  36. catch(Exception e)
  37. {
  38. System.err.println("Url, username,or password incorrect: " + e.getMessage());
  39. System.exit(0);
  40. }
  41.  
  42. try
  43. {
  44. Statement st1 = conn.createStatement();
  45. st1.execute("create table example ( " +
  46. " name varchar(255), " +
  47. " primary key(name) " +
  48. ")");
  49. st1.close();
  50. conn.commit();
  51.  
  52. try
  53. {
  54. Statement query = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
  55. query.executeQuery("select nam from example");
  56. query.close();
  57. }
  58. catch(Exception e)
  59. {
  60. e.printStackTrace();
  61. }
  62.  
  63. Statement query2 = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
  64. query2.executeQuery("select name from example");
  65. query2.close();
  66. conn.rollback();
  67.  
  68. Statement st3 = conn.createStatement();
  69. st3.execute("drop table example");
  70. st3.close();
  71. conn.commit();
  72.  
  73. System.out.println("Finished.");
  74. }
  75. catch(SQLException e)
  76. {
  77. e.printStackTrace();
  78. }
  79.  
  80. if(conn != null)
  81. {
  82. try
  83. {
  84. conn.close();
  85. }
  86. catch(SQLException e)
  87. {
  88. try
  89. {
  90. conn.rollback();
  91. conn.close();
  92. }
  93. catch(Exception f)
  94. {
  95. }
  96. }
  97. }
  98. }
  99. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement