Package org.exoplatform.services.jcr.impl.dataflow.persistent

Examples of org.exoplatform.services.jcr.impl.dataflow.persistent.ByteArrayPersistedValueData

1803
1804
1805
1806
1807
1808
1809
      }

      if (buffer == null)
         return new CleanableFileStreamValueData(swapFile, orderNumber, swapCleaner);

      return new ByteArrayPersistedValueData(buffer, orderNumber);
   }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
{

   public void testCreateByteArrayValueData() throws Exception
   {
      byte[] buf = "0123456789".getBytes();
      ByteArrayPersistedValueData vd = new ByteArrayPersistedValueData(0, buf);
      assertTrue(vd.isByteArray());
      assertEquals(10, vd.getLength());
      assertEquals(0, vd.getOrderNumber());
      assertEquals(10, vd.getAsByteArray().length);
      assertTrue(vd.getAsStream() instanceof ByteArrayInputStream);
   }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
      if (isByteArray)
      {
         byte[] data = new byte[in.readInt()];
         in.readFully(data);
         return new ByteArrayPersistedValueData(orderNumber, data);
      }
      else
      {
         // read file id - used for reread data optimization
         String id = in.readString();
View Full Code Here
2532
2533
2534
2535
2536
2537
2538
      if (buffer == null)
      {
         return new CleanableFilePersistedValueData(orderNumber, swapFile, swapCleaner);
      }

      return new ByteArrayPersistedValueData(orderNumber, buffer);
   }
View Full Code Here
2626
2627
2628
2629
2630
2631
2632
      if (buffer == null)
      {
         return new CleanableFilePersistedValueData(orderNumber, swapFile, swapCleaner);
      }

      return new ByteArrayPersistedValueData(orderNumber, buffer);
   }
View Full Code Here
2847
2848
2849
2850
2851
2852
2853
      }

      public TempPropertyData(ResultSet item, boolean readValue) throws SQLException
      {
         orderNum = item.getInt(COLUMN_VORDERNUM);
         data = readValue ? new ByteArrayPersistedValueData(orderNum, item.getBytes(COLUMN_VDATA)) : null;
      }
View Full Code Here
2414
2415
2416
2417
2418
2419
2420
      if (buffer == null)
      {
         return new CleanableFilePersistedValueData(orderNumber, swapFile, swapCleaner);
      }

      return new ByteArrayPersistedValueData(orderNumber, buffer);
   }
View Full Code Here
1804
1805
1806
1807
1808
1809
1810
      }

      if (buffer == null)
         return new CleanableFileStreamValueData(swapFile, orderNumber, swapCleaner);

      return new ByteArrayPersistedValueData(buffer, orderNumber);
   }
View Full Code Here
2900
2901
2902
2903
2904
2905
2906
2907
      protected void readData(ResultSet item) throws SQLException, ValueStorageNotFoundException, IOException
      {
         byte[] internalData = item.getBytes(COLUMN_VDATA);

         data = new ByteArrayPersistedValueData(orderNum, internalData);
         size = internalData.length;
      }
View Full Code Here
422
423
424
425
426
427
428
429
430
431
432
            {
               //make a copy
               List<ValueData> newValues = new ArrayList<ValueData>();
               for (ValueData vd : values)
               {
                  newValues.add(new ByteArrayPersistedValueData(vd.getOrderNumber(), vd.getAsByteArray()));
               }

               PersistedPropertyData pdata =
                  new PersistedPropertyData(prop.getIdentifier(), prop.getQPath(), prop.getParentIdentifier(), prop
                     .getPersistedVersion(), prop.getType(), prop.isMultiValued(), newValues);
View Full Code Here
TOP

Related Classes of org.exoplatform.services.jcr.impl.dataflow.persistent.ByteArrayPersistedValueData

  • org.exoplatform.services.jcr.impl.dataflow.ByteArrayValueData
  • org.exoplatform.services.jcr.impl.dataflow.serialization.PersistedValueDataReader
  • org.exoplatform.services.jcr.impl.dataflow.StreamValueData
  • org.exoplatform.services.jcr.impl.dataflow.TransientValueData
  • org.exoplatform.services.jcr.impl.dataflow.ValueDataUtil
  • org.exoplatform.services.jcr.impl.storage.jdbc.JDBCStorageConnection
  • org.exoplatform.services.jcr.impl.storage.jdbc.JDBCStorageConnection$TempPropertyData
  • org.exoplatform.services.jcr.impl.storage.jdbc.optimisation.CQJDBCStorageConnection
  • org.exoplatform.services.jcr.impl.storage.value.fs.operations.ValueFileIOHelper
  • org.exoplatform.services.jcr.impl.value.TestPersistedValueData
    • Copyright © 2018 www.massapicom. 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.