示例：重新执行应用SQL

当主数据库节点故障且10s未恢复时，openGauss会将对应的备数据库节点升主，使openGauss正常运行。备升主期间正在运行的作业会失败；备升主后启动的作业不会再受影响。如果要做到数据库节点主备切换过程中，上层业务不感知，可参考此示例构建业务层SQL重试机制。

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.PreparedStatement;
4. import java.sql.ResultSet;
5. import java.sql.SQLException;
6. import java.sql.Statement;

8. class ExitHandler extends Thread {
9. private Statement cancel_stmt = null;

11. public ExitHandler(Statement stmt) {
12. super("Exit Handler");
13. this.cancel_stmt = stmt;
14. }
15. public void run() {
16. System.out.println("exit handle");
17. try {
18. this.cancel_stmt.cancel();
19. } catch (SQLException e) {
20. System.out.println("cancel query failed.");
21. e.printStackTrace();
22. }
23. }
24. }

26. public class SQLRetry {
27. //创建数据库连接。
28. public static Connection GetConnection(String username, String passwd) {
29. String driver = "org.opengauss.Driver";
30. String sourceURL = "jdbc:opengauss://10.131.72.136:8000/postgres";
31. Connection conn = null;
32. try {
33. //加载数据库驱动。
34. Class.forName(driver).newInstance();
35. } catch (Exception e) {
36. e.printStackTrace();
37. return null;
38. }

40. try {
41. //创建数据库连接。
42. conn = DriverManager.getConnection(sourceURL, username, passwd);
43. System.out.println("Connection succeed!");
44. } catch (Exception e) {
45. e.printStackTrace();
46. return null;
47. }

49. return conn;
50. }

52. //执行普通SQL语句，创建jdbc_test1表。
53. public static void CreateTable(Connection conn) {
54. Statement stmt = null;
55. try {
56. stmt = conn.createStatement();

59. Runtime.getRuntime().addShutdownHook(new ExitHandler(stmt));

61. //执行普通SQL语句。
62. int rc2 = stmt
63. .executeUpdate("DROP TABLE if exists jdbc_test1;");

65. int rc1 = stmt
66. .executeUpdate("CREATE TABLE jdbc_test1(col1 INTEGER, col2 VARCHAR(10));");

68. stmt.close();
69. } catch (SQLException e) {
70. if (stmt != null) {
71. try {
72. stmt.close();
73. } catch (SQLException e1) {
74. e1.printStackTrace();
75. }
76. }
77. e.printStackTrace();
78. }
79. }

81. //执行预处理语句，批量插入数据。
82. public static void BatchInsertData(Connection conn) {
83. PreparedStatement pst = null;

85. try {
86. //生成预处理语句。
87. pst = conn.prepareStatement("INSERT INTO jdbc_test1 VALUES (?,?)");
88. for (int i = 0; i < 100; i++) {
89. //添加参数。
90. pst.setInt(1, i);
91. pst.setString(2, "data " + i);
92. pst.addBatch();
93. }
94. //执行批处理。
95. pst.executeBatch();
96. pst.close();
97. } catch (SQLException e) {
98. if (pst != null) {
99. try {
100. pst.close();
101. } catch (SQLException e1) {
102. e1.printStackTrace();
103. }
104. }
105. e.printStackTrace();
106. }
107. }

109. //执行预编译语句，更新数据。
110. private static boolean QueryRedo(Connection conn){
111. PreparedStatement pstmt = null;
112. boolean retValue = false;
113. try {
114. pstmt = conn
115. .prepareStatement("SELECT col1 FROM jdbc_test1 WHERE col2 = ?");

117. pstmt.setString(1, "data 10");
118. ResultSet rs = pstmt.executeQuery();

120. while (rs.next()) {
121. System.out.println("col1 = " + rs.getString("col1"));
122. }
123. rs.close();

125. pstmt.close();
126. retValue = true;
127. } catch (SQLException e) {
128. System.out.println("catch...... retValue " + retValue);
129. if (pstmt != null) {
130. try {
131. pstmt.close();
132. } catch (SQLException e1) {
133. e1.printStackTrace();
134. }
135. }
136. e.printStackTrace();
137. }

139. System.out.println("finesh......");
140. return retValue;
141. }

143. //查询语句，执行失败重试，重试次数可配置。
144. public static void ExecPreparedSQL(Connection conn) throws InterruptedException {
145. int maxRetryTime = 50;
146. int time = 0;
147. String result = null;
148. do {
149. time++;
150. try {
151. System.out.println("time:" + time);
152. boolean ret = QueryRedo(conn);
153. if(ret == false){
154. System.out.println("retry, time:" + time);
155. Thread.sleep(10000);
156. QueryRedo(conn);
157. }
158. } catch (Exception e) {
159. e.printStackTrace();
160. }
161. } while (null == result && time < maxRetryTime);

163. }

165. /**
166. * 主程序，逐步调用各静态方法。
167. * @param args
168. * @throws InterruptedException
169. */
170. public static void main(String[] args) throws InterruptedException {
171. //创建数据库连接。
172. Connection conn = GetConnection("testuser", "test@123");

174. //创建表。
175. CreateTable(conn);

177. //批插数据。
178. BatchInsertData(conn);

180. //执行预编译语句，更新数据。
181. ExecPreparedSQL(conn);

183. //关闭数据库连接。
184. try {
185. conn.close();
186. } catch (SQLException e) {
187. e.printStackTrace();
188. }

190. }

192. }