-
Notifications
You must be signed in to change notification settings - Fork 11
/
Insert.java
59 lines (51 loc) · 2.42 KB
/
Insert.java
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
/*******************************************************************************
* * Copyright 2018 Impetus Infotech.
* *
* * Licensed under the Apache License, Version 2.0 (the "License");
* * you may not use this file except in compliance with the License.
* * You may obtain a copy of the License at
* *
* * http://www.apache.org/licenses/LICENSE-2.0
* *
* * Unless required by applicable law or agreed to in writing, software
* * distributed under the License is distributed on an "AS IS" BASIS,
* * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* * See the License for the specific language governing permissions and
* * limitations under the License.
******************************************************************************/
package com.impetus.blkchn.eth;
import java.sql.*;
import java.util.Properties;
import java.util.concurrent.CompletableFuture;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.web3j.protocol.core.methods.response.TransactionReceipt;
import com.impetus.eth.jdbc.DriverConstants;
import com.impetus.eth.jdbc.EthStatement;
public class Insert {
private static final Logger LOGGER = LoggerFactory.getLogger(Insert.class);
public static void main(String[] ar) throws Exception{
ReadConfig.loadConfig();
String keystorePath = ReadConfig.keystorePath;
String keystorePassword = ReadConfig.keystorePassword;
String address = ReadConfig.address;
String url = "jdbc:blkchn:ethereum://ropsten.infura.io/1234";
String driverClass = "com.impetus.eth.jdbc.EthDriver";
String query = "insert into transaction (toAddress, value, unit, async) values ('"+ address +"', 1.11, 'ether', true)";
try {
Class.forName(driverClass);
Properties prop = new Properties();
prop.put(DriverConstants.KEYSTORE_PATH, keystorePath);
prop.put(DriverConstants.KEYSTORE_PASSWORD, keystorePassword);
Connection conn = DriverManager.getConnection(url, prop);
Statement stmt = conn.createStatement();
ResultSet ret = ((EthStatement) stmt).executeAndReturn(query);
while (ret.next()) {
LOGGER.info(
((TransactionReceipt) (((CompletableFuture) ret.getObject(1)).get())).getTransactionHash());
}
} catch (SQLException | ClassNotFoundException e1) {
e1.printStackTrace();
}
}
}