ExecuteAddColumns.java 1.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. import java.sql.*;
  2. public class ExecuteAddColumns {
  3. public static void main(String[] args) {
  4. String url = "jdbc:dm://192.168.0.145:30236?charset=utf8";
  5. String username = "WATERSHED";
  6. String password = "WaterShed./1224";
  7. Connection conn = null;
  8. Statement stmt = null;
  9. try {
  10. Class.forName("dm.jdbc.driver.DmDriver");
  11. conn = DriverManager.getConnection(url, username, password);
  12. stmt = conn.createStatement();
  13. System.out.println("Connected to database successfully!");
  14. // 添加字段
  15. String[] addColumnSqls = {
  16. "ALTER TABLE BUSINESS_SCENE ADD COLUMN THIRD_PERSON_CAMERA_HEADING DECIMAL(10,6)",
  17. "ALTER TABLE BUSINESS_SCENE ADD COLUMN THIRD_PERSON_CAMERA_PITCH DECIMAL(10,6)",
  18. "ALTER TABLE BUSINESS_SCENE ADD COLUMN THIRD_PERSON_CAMERA_ROLL DECIMAL(10,6)",
  19. "ALTER TABLE BUSINESS_SCENE ADD COLUMN THIRD_PERSON_CAMERA_DIRECTION VARCHAR(200)",
  20. "ALTER TABLE BUSINESS_SCENE ADD COLUMN THIRD_PERSON_CAMERA_UP VARCHAR(200)"
  21. };
  22. for (String sql : addColumnSqls) {
  23. try {
  24. stmt.execute(sql);
  25. System.out.println("Success: " + sql);
  26. } catch (SQLException e) {
  27. System.out.println("Skip (may already exist): " + sql);
  28. System.out.println("Error: " + e.getMessage());
  29. }
  30. }
  31. System.out.println("\nAll columns added successfully!");
  32. } catch (Exception e) {
  33. e.printStackTrace();
  34. } finally {
  35. try {
  36. if (stmt != null) stmt.close();
  37. if (conn != null) conn.close();
  38. } catch (SQLException e) {
  39. e.printStackTrace();
  40. }
  41. }
  42. }
  43. }