-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathSQLConsoleDemo.java
More file actions
136 lines (91 loc) · 3.71 KB
/
Copy pathSQLConsoleDemo.java
File metadata and controls
136 lines (91 loc) · 3.71 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import javafx.application.Application;
import javafx.scene.Scene;
import javafx.scene.control.TextArea;
import javafx.scene.control.TextField;
import javafx.stage.Stage;
public class SQLConsoleDemo extends Application {
SQLConsolePane pane = new SQLConsolePane();
@Override // Override the start method in the Application class
public void start(Stage primaryStage) throws SQLException, ClassNotFoundException {
/////////////////////////////////////////////////////////////SQL////////////////////////////////////////////////////////////////////////////
//LOAD JBDC
Class.forName("com.mysql.cj.jdbc.Driver");
System.out.println("Driver Loaded");
//ESTABLISH CONNECTION
//MODIFY '(port)/database' & 'user' & 'password' to connect to a specific database
Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:(port)/database", "user", "password");
System.out.println("Database connected!");
//CREATE STATEMENT
Statement statement = connection.createStatement();
/////////////////////////////////////////////////////////////SQL////////////////////////////////////////////////////////////////////////////
//TEXT AREA DEFAULTS
pane.textArea.setWrapText(false);
pane.textArea.setEditable(false);
pane.textField.setEditable(true);
//ACTION EVENT
pane.btFire.setOnAction(e -> {
if(pane.textField.getText().trim().toUpperCase().startsWith("SELECT")) {
//SELECT
try {
selectTable(statement, pane.textField.getText(), pane.textArea);
} catch (SQLException e1) {
e1.printStackTrace();
}
}else{
try {
insertTable(statement, pane.textField);
if(pane.textField.getText().trim().toUpperCase().startsWith("INSERT")) {
System.out.println("INSERT successful");
}
if(pane.textField.getText().trim().toUpperCase().startsWith("UPDATE")) {
System.out.println("UPDATE successful");
}
if(pane.textField.getText().trim().toUpperCase().startsWith("DELETE")) {
System.out.println("DELETE successful");
}
} catch (SQLException e1) {
e1.printStackTrace();
}
}
});//btFire SET ON ACTION EVENT
pane.btClear.setOnAction(e -> {
pane.textField.clear();
pane.textArea.clear();
});//btClear SET ON ACTION EVENT
//SCENE
Scene scene = new Scene(pane, 800,770);
primaryStage.setTitle("SQL Console");
primaryStage.setScene(scene);
primaryStage.show();
}//START STAGE
private void selectTable(Statement statement, String t, TextArea textArea) throws SQLException {
ResultSet resultSet = statement.executeQuery(t);
//CREATE META OBJECT
ResultSetMetaData rsmd = resultSet.getMetaData();
//PRINT ROW HEADERS
int columnCount = rsmd.getColumnCount();
for(int i=1; i<=columnCount; i++) {
textArea.appendText(String.format("%-23s", rsmd.getColumnName(i) + "\t"));
}
while(resultSet.next()) {
textArea.appendText("\n");
for(int i=1; i<=columnCount; i++) {
textArea.appendText(String.format("%-25s", resultSet.getString(i) + "\t"));
}
textArea.appendText("\n");
}
}//SELECT TABLE
private void insertTable(Statement statement, TextField textField) throws SQLException{
String t = textField.getText();
statement.executeUpdate(t);
}//INSERT / UPDATE / DELETE TABLE
public static void main(String[] args) {
Application.launch(args);
}//MAIN
}//CLASS