summaryrefslogtreecommitdiff
path: root/src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java')
-rw-r--r--src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java162
1 files changed, 71 insertions, 91 deletions
diff --git a/src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java b/src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java
index 6656fcd..e6a7617 100644
--- a/src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java
+++ b/src/main/java/com/redstoner/misc/mysql/elements/MysqlTable.java
@@ -1,133 +1,113 @@
package com.redstoner.misc.mysql.elements;
+import com.redstoner.misc.mysql.MysqlQueryHandler;
+
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
-import com.redstoner.misc.mysql.MysqlQueryHandler;
-
-public class MysqlTable
-{
+public class MysqlTable {
private MysqlDatabase database;
- private String name;
-
- public MysqlTable(MysqlDatabase database, String name)
- {
+ private String name;
+
+ public MysqlTable(MysqlDatabase database, String name) {
this.database = database;
this.name = name;
}
-
- public String getName()
- {
+
+ public String getName() {
return this.name;
}
-
- public MysqlField[] describe()
- {
- try
- {
- List<MysqlField> description = new ArrayList<>();
- DatabaseMetaData metadata = database.getConnection().getMetaData();
- ResultSet queryResults = metadata.getColumns(null, null, name, null);
- while (queryResults.next())
- {
- description.add(new MysqlField(queryResults.getString(4),
- queryResults.getString(6).split(" ")[0] + "(" + queryResults.getString(7) + ")",
- queryResults.getBoolean(11)));
- }
- return description.toArray(new MysqlField[0]);
- }
- catch (SQLException e)
- {
- e.printStackTrace();
- return null;
- }
- }
-
- public boolean insert(String... values)
- {
+
+ public boolean insert(String... values) {
MysqlField[] description = describe();
- if (values.length > 0 && values.length == description.length)
- {
+ if (values.length > 0 && values.length == description.length) {
String val = "(\"" + String.join("\",\"", values) + "\")";
- return MysqlQueryHandler.queryNoResult(database.getConnection(),
- "INSERT INTO `" + name + "` VALUES " + val + ";");
- }
- else
- {
+ return MysqlQueryHandler.queryNoResult(
+ database.getConnection(),
+ "INSERT INTO `" + name + "` VALUES " + val + ";"
+ );
+ } else {
return false;
}
}
-
- public Object[] get(String fieldName, MysqlConstraint... constraints)
- {
- ResultSet results = MysqlQueryHandler.queryResult(database.getConnection(),
- "SELECT " + fieldName + " FROM `" + name + "`" + getConstraints(constraints) + ";");
- List<Object> resObj = new ArrayList<>();
- try
- {
- while (results.next())
- {
- resObj.add(results.getObject(1));
+
+ public MysqlField[] describe() {
+ try {
+ List<MysqlField> description = new ArrayList<>();
+ DatabaseMetaData metadata = database.getConnection().getMetaData();
+ ResultSet queryResults = metadata.getColumns(null, null, name, null);
+ while (queryResults.next()) {
+ description.add(new MysqlField(
+ queryResults.getString(4),
+ queryResults.getString(6).split(" ")[0] + "(" + queryResults.getString(7) + ")",
+ queryResults.getBoolean(11)
+ ));
}
- }
- catch (SQLException e)
- {
+ return description.toArray(new MysqlField[0]);
+ } catch (SQLException e) {
e.printStackTrace();
- return new Object[0];
+ return null;
}
- return resObj.toArray(new Object[0]);
}
-
- public Object[] get(String statement)
- {
- ResultSet results = MysqlQueryHandler.queryResult(database.getConnection(), statement);
+
+ public Object[] get(String fieldName, MysqlConstraint... constraints) {
+ ResultSet results = MysqlQueryHandler.queryResult(
+ database.getConnection(),
+ "SELECT " + fieldName + " FROM `" + name + "`" + getConstraints(constraints) + ";"
+ );
List<Object> resObj = new ArrayList<>();
- try
- {
- while (results.next())
- {
+ try {
+ while (results.next()) {
resObj.add(results.getObject(1));
}
- }
- catch (SQLException e)
- {
+ } catch (SQLException e) {
e.printStackTrace();
return new Object[0];
}
return resObj.toArray(new Object[0]);
}
-
- public boolean delete(MysqlConstraint... constraints)
- {
- return MysqlQueryHandler.queryNoResult(database.getConnection(),
- "DELETE FROM `" + name + "`" + getConstraints(constraints) + ";");
- }
-
- public boolean drop()
- {
- return MysqlQueryHandler.queryNoResult(database.getConnection(), "DROP TABLE `" + name + "`;");
- }
-
- private String getConstraints(MysqlConstraint... constraints)
- {
+
+ private String getConstraints(MysqlConstraint... constraints) {
String cons = "";
- if (constraints.length > 0)
- {
+ if (constraints.length > 0) {
cons += " WHERE ";
- for (int i = 0; i < constraints.length; i++)
- {
+ for (int i = 0; i < constraints.length; i++) {
MysqlConstraint constraint = constraints[i];
cons += constraint.getFieldName() + constraint.getOperator().toString() + "\"" + constraint.getValue()
- + "\"";
- if (i < constraints.length - 1)
- {
+ + "\"";
+ if (i < constraints.length - 1) {
cons += " AND ";
}
}
}
return cons;
}
+
+ public Object[] get(String statement) {
+ ResultSet results = MysqlQueryHandler.queryResult(database.getConnection(), statement);
+ List<Object> resObj = new ArrayList<>();
+ try {
+ while (results.next()) {
+ resObj.add(results.getObject(1));
+ }
+ } catch (SQLException e) {
+ e.printStackTrace();
+ return new Object[0];
+ }
+ return resObj.toArray(new Object[0]);
+ }
+
+ public boolean delete(MysqlConstraint... constraints) {
+ return MysqlQueryHandler.queryNoResult(
+ database.getConnection(),
+ "DELETE FROM `" + name + "`" + getConstraints(constraints) + ";"
+ );
+ }
+
+ public boolean drop() {
+ return MysqlQueryHandler.queryNoResult(database.getConnection(), "DROP TABLE `" + name + "`;");
+ }
}