PrepareDB_root.java

Go to the documentation of this file.

package p2pserver;

import java.sql.*;

public class PrepareDB_root
{

    private static boolean prepare( boolean disperr, boolean dispok, 
                                    String dbroot, String userroot, String pswdroot,
                                    String userp2p, String pswdp2p, String dbp2p
                                  )
    {
        boolean ret = true;
        
        Connection db = p2pserver.Connecttodbms.connect(disperr,dbroot,userroot,pswdroot);
        pswdroot = "";
        if(db == null) return false;
        
        Statement s = p2pserver.Connecttodbms.createStat(disperr,db);
        if(s==null) return false;
                 
        boolean ok = false;
        String msg = "";
        
        
        ok = p2pserver.Connecttodbms.noRSetQuery(disperr,s,"drop database "+dbp2p+";");
        msg = "now";
        if(ok) msg = "already";
        if(dispok) p2putility.Util.logServer("Clean DB workspace "+msg+" ok.");
        
        
        ok = p2pserver.Connecttodbms.noRSetQuery(disperr,s,"drop user "+userp2p+"@localhost;");
        msg = "now";
        if(ok) msg = "already";
        if(dispok) p2putility.Util.logServer("Clean DB "+userp2p+" "+msg+" ok.");
        
        
        ok = p2pserver.Connecttodbms.noRSetQuery(disperr,s,"create database "+dbp2p+";");
        msg = "now";
        if(ok) msg = "already";
        else ret = false;
        
        if(dispok) p2putility.Util.logServer("Create DB "+dbp2p+" "+msg+" ok.");
        
        
        ok = p2pserver.Connecttodbms.noRSetQuery(disperr,s,"grant all on "+dbp2p+".* to "+
                                                   userp2p+"@localhost IDENTIFIED BY '"+pswdp2p+"';");
        pswdp2p = "";
        msg = "now";
        if(ok) msg = "already";
        else ret = false;
        if(dispok) p2putility.Util.logServer("Create DB's user "+userp2p+" "+msg+" ok.");

                  
        p2pserver.Connecttodbms.closeStat(disperr,s);
        p2pserver.Connecttodbms.disconnect(disperr,db);
        
        return ret;
        
    }

    public PrepareDB_root(  boolean dispthis, boolean dispallok, boolean dispallerr,
                            String dbroot, String userroot, String pswdroot,
                            String userp2p, String pswdp2p, String dbp2p
                         )
    {
        super();
        @SuppressWarnings("static-access")
        boolean ok = this.prepare(dispallerr,dispallok,dbroot,userroot,pswdroot,userp2p,pswdp2p,dbp2p);
        pswdp2p = "";
        pswdroot = "";
        
        if(dispthis)
            if(ok)  p2putility.Util.logServer("SETTING DataBase OK!");
            else    p2putility.Util.logServer("SETTING DataBase ERROR!");
            
    }
}