それぞれ異なるシステムに 2 つのプロジェクトがあります。両方のシステムは LAN ケーブルで接続されています。私の PC には Try.java があり、HRIDYA-PC という別の PC には Hello.java があります。Try.java から MySum.java を呼び出したい。MySum.java を自分のシステムではなく他のシステムで実行したい。
これがTry.javaの私のコードです
package pkgtry;
import java.io.*;
public class Try
{
private static void runProcess(String command) throws Exception
{
Process pro = Runtime.getRuntime().exec(command);
pro.waitFor();
InputStream inputStream = pro.getInputStream();
int b = -1;
while ( (b = inputStream.read()) != -1 )
{
System.out.write(b);
}
}
public static void main(String[] args)
{
try
{
runProcess("javac -d . \\HRIDYA-PC\\Users\\Hridya\\Documents\\NetBeansProjects\\hello\\src\\hello\\Hello.java");
runProcess("java hello.Hello ");
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
他のシステムの Java プロジェクト MySum には、Connectdb.java と MYSum.java の 2 つの Java ファイルが含まれています。
MySum.java のコードは
package mysum;
import java.sql.*;
import java.util.Scanner;
public class MySum
{
public static String dbName="partition",dbName1="results",tableName="p1",query;
public static Connectdb con=new Connectdb();
public static Connection conn=null;
public static Connection conn1=null;
public static String[] tnames;
public static int sumTransactionId=0,sumCustomerId=0,sumDepositAmount=0,sumWithdrawAmount=0,totalNoOfRange=3;
public static int i=0,select=0,range,size;
public static int[] tid,id,amount;
public static String[] type,date;
public static void main(String[] args)
{
try
{
conn=con.connect(dbName);
conn1=con.connect(dbName1);
query="create table partialSum(Attribute varchar(20),Sum int)";
PreparedStatement ps=conn1.prepareStatement(query);
ps.executeUpdate();
Statement stm=conn.createStatement();
ResultSet rs=stm.executeQuery("select count(*) from "+tableName);
rs.next();
size=rs.getInt(1);
tid=new int[size];
id=new int[size];
date=new String[size];
type=new String[size];
amount=new int[size];
rs=stm.executeQuery("select * from "+tableName);
while(rs.next())
{
tid[i]=rs.getInt(1);
id[i]=rs.getInt(2);
date[i]=rs.getString(3);
type[i]=rs.getString(4);
amount[i]=rs.getInt(5);
i++;
}
switch(select)
{
case 0:
for(i=0;i<size;i++)
{
sumCustomerId+=id[i];
}
query="insert into partialSum values('Customer ID','"+sumCustomerId+"')";
ps=conn1.prepareStatement(query);
ps.executeUpdate();
break;
case 1:
for(i=0;i<size;i++)
{
sumTransactionId+=tid[i];
}
query="insert into partialSum values('Transaction ID','"+sumTransactionId+"')";
ps=conn1.prepareStatement(query);
ps.executeUpdate();
break;
case 2:
for(i=0;i<size;i++)
{
if("Deposit".equals(type[i]))
{
sumDepositAmount+=amount[i];
}
}
query="insert into partialSum values('Amount Deposited','"+sumDepositAmount+"')";
ps=conn1.prepareStatement(query);
ps.executeUpdate();
break;
case 3:
for(i=0;i<size;i++)
{
if("Withdrawal".equals(type[i]))
{
sumWithdrawAmount+=amount[i];
}
}
query="insert into partialSum values('Amount Withdrawed','"+sumWithdrawAmount+"')";
ps=conn1.prepareStatement(query);
ps.executeUpdate();
break;
}
}
catch(Exception e)
{
System.out.println(e);
}
}
}
Connectdb.java のコードは
package mysum;
import java.sql.*;
public class Connectdb {
public String hostname;
public String username;
public String password;
public String dbName;
public String connectionUrl1;
public Connection connect(String db)
{
hostname = "localhost";
username = "postgres";
password = "geethu";
dbName = db;
connectionUrl1 = "jdbc:postgresql://" + hostname + "/" + dbName;
Connection conn=null;
try{
Class.forName("org.postgresql.Driver");
} catch (ClassNotFoundException cnfe){
System.out.println("Could not find the JDBC driver!");
System.exit(1);
}
try {
System.out.println("before Connected successfully = "+connectionUrl1);
conn = DriverManager.getConnection(connectionUrl1,username, password);
System.out.println("Connected successfully");
} catch (SQLException sqle) {
System.out.println("Connection failed");
System.out.println(sqle);
System.exit(1);
}
return conn;
}
}
誰でも私を助けてください。