2020
2121import com .arcadedb .log .LogManager ;
2222import com .arcadedb .serializer .json .JSONObject ;
23-
2423import org .junit .jupiter .api .Test ;
2524
26- import java .io .*;
27- import java .net .*;
28- import java .util .*;
29- import java .util .logging .*;
25+ import java .io .IOException ;
26+ import java .io .OutputStreamWriter ;
27+ import java .io .PrintWriter ;
28+ import java .net .HttpURLConnection ;
29+ import java .net .URL ;
30+ import java .util .Base64 ;
31+ import java .util .HashMap ;
32+ import java .util .logging .Level ;
3033
3134import static com .arcadedb .schema .Property .RID_PROPERTY ;
3235import static com .arcadedb .server .http .HttpSessionManager .ARCADEDB_SESSION_ID ;
33- import static org .assertj .core .api .Assertions .*;
3436import static org .assertj .core .api .Assertions .assertThat ;
3537import static org .assertj .core .api .Assertions .assertThatThrownBy ;
3638
@@ -166,7 +168,7 @@ public void simpleTx() throws Exception {
166168 public void checkUnique () throws Exception {
167169 testEachServer ((serverIndex ) -> {
168170 // BEGIN
169- HttpURLConnection connection = (HttpURLConnection ) new URL (
171+ final HttpURLConnection connection = (HttpURLConnection ) new URL (
170172 "http://127.0.0.1:248" + serverIndex + "/api/v1/begin/graph" ).openConnection ();
171173
172174 connection .setRequestMethod ("POST" );
@@ -188,36 +190,38 @@ public void checkUnique() throws Exception {
188190 }
189191
190192 // CREATE DOCUMENT
191- connection = (HttpURLConnection ) new URL ("http://127.0.0.1:248" + serverIndex + "/api/v1/command/graph" ).openConnection ();
193+ final HttpURLConnection connection2 = (HttpURLConnection ) new URL (
194+ "http://127.0.0.1:248" + serverIndex + "/api/v1/command/graph" ).openConnection ();
192195
193- connection .setRequestMethod ("POST" );
194- connection .setRequestProperty (ARCADEDB_SESSION_ID , sessionId );
195- connection .setRequestProperty ("Authorization" ,
196+ connection2 .setRequestMethod ("POST" );
197+ connection2 .setRequestProperty (ARCADEDB_SESSION_ID , sessionId );
198+ connection2 .setRequestProperty ("Authorization" ,
196199 "Basic " + Base64 .getEncoder ().encodeToString (("root:" + BaseGraphServerTest .DEFAULT_PASSWORD_FOR_TESTS ).getBytes ()));
197200
198- final JSONObject payload = new JSONObject ("{\" language\" :\" sqlScript\" , \" command\" :\" " +//
199- "CREATE VERTEX TYPE eltdev;" +//
200- "CREATE PROPERTY eltdev.SN string;" +//
201- "CREATE INDEX ON eltdev (SN) UNIQUE;" +//
202- "CREATE VERTEX eltdev SET SN='bubu';" +//
203- "CREATE VERTEX eltdev SET SN='bubu';" +//
204- "\" }" );
201+ final JSONObject payload = new JSONObject ("""
202+ {"language":"sqlScript", "command":"
203+ CREATE VERTEX TYPE eltdev;
204+ CREATE PROPERTY eltdev.SN string;
205+ CREATE INDEX ON eltdev (SN) UNIQUE;
206+ CREATE VERTEX eltdev SET SN='bubu';
207+ CREATE VERTEX eltdev SET SN='bubu';
208+ "}""" );
205209
206- connection .setRequestMethod ("POST" );
207- connection .setDoOutput (true );
210+ connection2 .setRequestMethod ("POST" );
211+ connection2 .setDoOutput (true );
208212
209- connection .connect ();
213+ connection2 .connect ();
210214
211215 final PrintWriter pw = new PrintWriter (new OutputStreamWriter (connection .getOutputStream ()));
212216 pw .write (payload .toString ());
213217 pw .close ();
214218
215- assertThatThrownBy (() -> readResponse (connection ))
219+ assertThatThrownBy (() -> readResponse (connection2 ))
216220 .isInstanceOf (IOException .class );
217221
218- String response = readError (connection );
219- assertThat (connection .getResponseCode ()).isEqualTo (503 );
220- connection .disconnect ();
222+ String response = readError (connection2 );
223+ assertThat (connection2 .getResponseCode ()).isEqualTo (503 );
224+ connection2 .disconnect ();
221225 assertThat (response .contains ("DuplicatedKeyException" )).isTrue ();
222226 });
223227 }
@@ -257,7 +261,7 @@ public static void checkDocumentWasCreated(final String databaseName, final int
257261 public void errorMissingIsolationLevel () throws Exception {
258262 testEachServer ((serverIndex ) -> {
259263 // BEGIN
260- HttpURLConnection connection = (HttpURLConnection ) new URL (
264+ final HttpURLConnection connection = (HttpURLConnection ) new URL (
261265 "http://127.0.0.1:248" + serverIndex + "/api/v1/begin/" + DATABASE_NAME ).openConnection ();
262266
263267 connection .setRequestMethod ("POST" );
0 commit comments