|
25 | 25 | import com.vesoft.nebula.storage.ScanEdgeRequest; |
26 | 26 | import com.vesoft.nebula.storage.ScanVertexRequest; |
27 | 27 | import com.vesoft.nebula.storage.VertexProp; |
| 28 | + |
28 | 29 | import java.io.Serializable; |
29 | 30 | import java.io.UnsupportedEncodingException; |
30 | 31 | import java.util.ArrayList; |
|
34 | 35 | import java.util.List; |
35 | 36 | import java.util.Map; |
36 | 37 | import java.util.Set; |
| 38 | + |
37 | 39 | import org.slf4j.Logger; |
38 | 40 | import org.slf4j.LoggerFactory; |
39 | 41 |
|
@@ -1205,10 +1207,17 @@ private void authUser() throws AuthFailedException, IOErrorException, |
1205 | 1207 | if (graphAddrAndPort.length != 2) { |
1206 | 1208 | throw new IllegalArgumentException("the graph address is invalid."); |
1207 | 1209 | } |
1208 | | - graphConnection.open(new HostAddress(graphAddrAndPort[0].trim(), |
1209 | | - Integer.valueOf(graphAddrAndPort[1].trim())), timeout, false, |
1210 | | - new HashMap<>(), |
1211 | | - version); |
| 1210 | + if (sslParam == null) { |
| 1211 | + graphConnection.open(new HostAddress(graphAddrAndPort[0].trim(), |
| 1212 | + Integer.valueOf(graphAddrAndPort[1].trim())), timeout, false, |
| 1213 | + new HashMap<>(), |
| 1214 | + version); |
| 1215 | + } else { |
| 1216 | + graphConnection.open(new HostAddress(graphAddrAndPort[0].trim(), |
| 1217 | + Integer.valueOf(graphAddrAndPort[1].trim())), timeout, sslParam, false, |
| 1218 | + new HashMap<>(), |
| 1219 | + version); |
| 1220 | + } |
1212 | 1221 | AuthResult authResult = graphConnection.authenticate(user, password); |
1213 | 1222 | long sessionId = authResult.getSessionId(); |
1214 | 1223 |
|
|
0 commit comments