Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class SQLUpdater extends AsyncTask<Pair<String, String[]>, String, Boolean> {
- @Override
- protected Boolean doInBackground(Pair<String, String[]>... query) {
- try {
- Class.forName("com.mysql.jdbc.Driver");
- } catch (ClassNotFoundException e) {
- System.out.println("No driver found");
- e.printStackTrace();
- return false;
- }
- try {
- if(connection == null)
- connection = DriverManager.getConnection("jdbc:mysql://" + Constants.databaseHost + ":" + Constants.databasePort + "/" + Constants.databaseName, Constants.databaseUser, Constants.databasePassword);
- stmt = connection.prepareStatement(query[0].first);
- String[] values = query[0].second;
- for (int i=1;i < values.length+1;i++){
- stmt.setString(i, values[i-1]);
- }
- stmt.executeUpdate();
- System.out.println("Executed Update: " + query[0].first);
- //statement.close();
- return true;
- } catch (SQLException e) {
- System.out.println("No database found");
- e.printStackTrace();
- return false;
- }
- }
- }
- public class SQLQuerier extends AsyncTask<String, String, ResultSet> {
- @Override
- protected ResultSet doInBackground(String... query) {
- try {
- Class.forName("com.mysql.jdbc.Driver");
- } catch (ClassNotFoundException e) {
- System.out.println("No driver found");
- e.printStackTrace();
- return null;
- }
- try {
- if(connection == null)
- connection = DriverManager.getConnection("jdbc:mysql://" + Constants.databaseHost + ":" + Constants.databasePort + "/" + Constants.databaseName, Constants.databaseUser, Constants.databasePassword);
- statement = connection.createStatement();
- System.out.println("Executed Query: " + query[0]);
- ResultSet rs = statement.executeQuery(query[0]);
- //statement.close();
- //connection.close();
- return rs;
- } catch (SQLException e) {
- System.out.println("No database found");
- e.printStackTrace();
- return null;
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement