Package com.orientechnologies.orient.enterprise.channel.binary

Examples of com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryClient.writeString()

242
243
244
245
246
247
248
249
250
251
252
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_RECORD_LOAD);
        try {
          network.writeRID(iRid);
          network.writeString(iFetchPlan != null ? iFetchPlan : "");
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
445
446
447
448
449
450
451
452
453
454
455
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_COUNT);
        try {
          network.writeString(iClassName);
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
675
676
677
678
679
680
681
682
683
684
685
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_DATACLUSTER_ADD);
        try {
          network.writeString(iClusterType.toString());
          network.writeString(iClusterName);

          switch (iClusterType) {
          case PHYSICAL:
            // FILE PATH + START SIZE
View Full Code Here
676
677
678
679
680
681
682
683
684
685
686
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_DATACLUSTER_ADD);
        try {
          network.writeString(iClusterType.toString());
          network.writeString(iClusterName);

          switch (iClusterType) {
          case PHYSICAL:
            // FILE PATH + START SIZE
            network.writeString(iArguments.length > 0 ? (String) iArguments[0] : "").writeInt(
View Full Code Here
681
682
683
684
685
686
687
688
689
690
691
          network.writeString(iClusterName);

          switch (iClusterType) {
          case PHYSICAL:
            // FILE PATH + START SIZE
            network.writeString(iArguments.length > 0 ? (String) iArguments[0] : "").writeInt(
                iArguments.length > 0 ? (Integer) iArguments[1] : -1);
            break;

          case LOGICAL:
            // PHY CLUSTER ID
View Full Code Here
764
765
766
767
768
769
770
771
772
773
774
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_DATASEGMENT_ADD);
        try {
          network.writeString(iSegmentName).writeString(iSegmentFileName);
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
794
795
796
797
798
799
800
801
802
803
804
      try {
        final ORID rid = iRecord.getIdentity();

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_INDEX_PUT);
        try {
          network.writeString(iKey);
          network.writeByte(iRecord.getRecordType());
          network.writeRID(rid);
        } finally {
          endRequest(network);
        }
View Full Code Here
824
825
826
827
828
829
830
831
832
833
834
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_INDEX_LOOKUP);
        try {
          network.writeString(iKey);
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
851
852
853
854
855
856
857
858
859
860
861
    do {
      try {

        final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_INDEX_REMOVE);
        try {
          network.writeString(iKey.toString());
        } finally {
          endRequest(network);
        }

        try {
View Full Code Here
994
995
996
997
998
999
1000
1001
1002
1003
1004
  protected void openRemoteDatabase(final String iUserName, final String iUserPassword) throws IOException {
    createConnectionPool();

    final OChannelBinaryClient network = beginRequest(OChannelBinaryProtocol.REQUEST_DB_OPEN);
    try {
      network.writeString(name).writeString(iUserName).writeString(iUserPassword);
    } finally {
      endRequest(network);
    }

    try {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.