Minor, removed old unused expeiment for hawtdb groovy scripts
This commit is contained in:
andrea
@@ -52,5 +52,5 @@ MOQUETTE_PATH=$MOQUETTE_HOME/
|
||||
#LOG_FILE_LEVEL=fine
|
||||
JAVA_OPTS_SCRIPT="-XX:+HeapDumpOnOutOfMemoryError -Djava.awt.headless=true"
|
||||
|
||||
$JAVA -server $JAVA_OPTS $JAVA_OPTS_SCRIPT -Dlog4j.configuration="file:$LOG_FILE" -Dmoquette.path="$MOQUETTE_PATH" -cp "$MOQUETTE_HOME/lib/moquette-broker-0.6-SNAPSHOT.jar:$MOQUETTE_HOME/lib/*" org.eclipse.moquette.server.Server
|
||||
$JAVA -server $JAVA_OPTS $JAVA_OPTS_SCRIPT -Dlog4j.configuration="file:$LOG_FILE" -Dmoquette.path="$MOQUETTE_PATH" -cp "$MOQUETTE_HOME/lib/moquette-broker-0.7-SNAPSHOT.jar:$MOQUETTE_HOME/lib/*" org.eclipse.moquette.server.Server
|
||||
|
||||
|
||||
@@ -1,81 +0,0 @@
|
||||
@Grab(group='org.fusesource.hawtdb', module='hawtdb', version='1.6')
|
||||
|
||||
import org.fusesource.hawtbuf.codec.StringCodec
|
||||
import org.fusesource.hawtdb.api.IndexFactory
|
||||
import org.fusesource.hawtdb.api.HashIndexFactory
|
||||
import org.fusesource.hawtdb.api.BTreeIndexFactory
|
||||
import org.fusesource.hawtdb.api.PageFile
|
||||
import org.fusesource.hawtdb.api.PageFileFactory
|
||||
import org.fusesource.hawtdb.api.MultiIndexFactory
|
||||
import org.fusesource.hawtdb.api.SortedIndex
|
||||
|
||||
|
||||
|
||||
File tmpFile = new File(System.getProperty("user.home") + File.separator + "test_hawtdb.dat")
|
||||
//tmpFile.createNewFile()
|
||||
|
||||
def writeSomeData(tmpFile) {
|
||||
def factory = new PageFileFactory()
|
||||
factory.file = tmpFile
|
||||
factory.open()
|
||||
def pageFile = factory.getPageFile()
|
||||
MultiIndexFactory multiIndexFactory = new MultiIndexFactory(pageFile);
|
||||
|
||||
BTreeIndexFactory<String, String> indexFactory = new BTreeIndexFactory<String, String>()
|
||||
indexFactory.setKeyCodec(StringCodec.INSTANCE)
|
||||
|
||||
BTreeIndexFactory<String, String> indexFactory2 = new BTreeIndexFactory<String, String>()
|
||||
|
||||
|
||||
SortedIndex<String, String> writeIndex = multiIndexFactory.openOrCreate("subscriptions", indexFactory)
|
||||
SortedIndex<String, String> retainedIndex = multiIndexFactory.openOrCreate("retained", indexFactory2)
|
||||
println "Hawt opened, try to read"
|
||||
println "Size: ${writeIndex.size()}"
|
||||
|
||||
println "write something"
|
||||
writeIndex.put("titolo", "capucetto rosso")
|
||||
retainedIndex.put("autore", "leggenda popolare")
|
||||
pageFile.flush()
|
||||
|
||||
println "check after write content: ${writeIndex.get("titolo")}, size ${writeIndex.size()}"
|
||||
|
||||
//pageFile.close()
|
||||
factory.close()
|
||||
}
|
||||
|
||||
|
||||
def readAllFileContents(tmpFile) {
|
||||
def factory = new PageFileFactory()
|
||||
factory.file = tmpFile
|
||||
factory.open()
|
||||
def pageFile = factory.getPageFile()
|
||||
|
||||
MultiIndexFactory multiIndexFactory = new MultiIndexFactory(pageFile);
|
||||
|
||||
IndexFactory<String, String> indexFactory = new BTreeIndexFactory<String, String>()
|
||||
BTreeIndexFactory<String, String> indexFactory2 = new BTreeIndexFactory<String, String>()
|
||||
indexFactory.setKeyCodec(StringCodec.INSTANCE)
|
||||
|
||||
SortedIndex<String, String> readingIndex = multiIndexFactory.openOrCreate("subscriptions", indexFactory)
|
||||
SortedIndex<String, String> retainedIndex = multiIndexFactory.openOrCreate("retained", indexFactory2)
|
||||
|
||||
println "read something, size ${readingIndex.size()}"
|
||||
for (def entry : readingIndex) {
|
||||
println "read k, v -> ${entry.key}, ${entry.value} "
|
||||
}
|
||||
|
||||
for (def entry : retainedIndex) {
|
||||
println "read k, v -> ${entry.key}, ${entry.value} "
|
||||
}
|
||||
|
||||
factory.close()
|
||||
}
|
||||
|
||||
|
||||
writeSomeData(tmpFile)
|
||||
readAllFileContents(tmpFile)
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,65 +0,0 @@
|
||||
@Grab(group='org.fusesource.hawtdb', module='hawtdb', version='1.6')
|
||||
|
||||
import org.fusesource.hawtbuf.codec.StringCodec
|
||||
import org.fusesource.hawtdb.api.BTreeIndexFactory
|
||||
import org.fusesource.hawtdb.api.PageFile
|
||||
import org.fusesource.hawtdb.api.PageFileFactory
|
||||
import org.fusesource.hawtdb.api.SortedIndex
|
||||
|
||||
|
||||
|
||||
File tmpFile = new File(System.getProperty("user.home") + File.separator + "test_hawtdb.dat")
|
||||
//tmpFile.createNewFile()
|
||||
|
||||
def writeSomeData(tmpFile) {
|
||||
def factory = new PageFileFactory()
|
||||
factory.file = tmpFile
|
||||
factory.open()
|
||||
def pageFile = factory.getPageFile()
|
||||
|
||||
BTreeIndexFactory<String, String> indexFactory = new BTreeIndexFactory<String, String>()
|
||||
indexFactory.setKeyCodec(StringCodec.INSTANCE)
|
||||
|
||||
SortedIndex<String, String> writeIndex = indexFactory.openOrCreate(pageFile)
|
||||
println "Hawt opened, try to read"
|
||||
println "Size: ${writeIndex.size()}"
|
||||
|
||||
println "write something"
|
||||
writeIndex.put("titolo", "capucetto rosso")
|
||||
pageFile.flush()
|
||||
|
||||
println "check after write content: ${writeIndex.get("titolo")}, size ${writeIndex.size()}"
|
||||
|
||||
//pageFile.close()
|
||||
factory.close()
|
||||
}
|
||||
|
||||
|
||||
def readAllFileContents(tmpFile) {
|
||||
def factory = new PageFileFactory()
|
||||
factory.file = tmpFile
|
||||
factory.open()
|
||||
def pageFile = factory.getPageFile()
|
||||
|
||||
BTreeIndexFactory<String, String> indexFactory = new BTreeIndexFactory<String, String>()
|
||||
indexFactory.setKeyCodec(StringCodec.INSTANCE)
|
||||
|
||||
SortedIndex<String, String> readingIndex = indexFactory.openOrCreate(pageFile)
|
||||
|
||||
println "read something, size ${readingIndex.size()}"
|
||||
for (def entry : readingIndex) {
|
||||
println "read k, v -> ${entry.key}, ${entry.value} "
|
||||
}
|
||||
|
||||
factory.close()
|
||||
}
|
||||
|
||||
|
||||
writeSomeData(tmpFile)
|
||||
readAllFileContents(tmpFile)
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -1,45 +0,0 @@
|
||||
@Grab(group='org.fusesource.hawtdb', module='hawtdb', version='1.6')
|
||||
|
||||
import org.fusesource.hawtbuf.codec.StringCodec
|
||||
import org.fusesource.hawtdb.api.BTreeIndexFactory
|
||||
import org.fusesource.hawtdb.api.PageFile
|
||||
import org.fusesource.hawtdb.api.PageFileFactory
|
||||
import org.fusesource.hawtdb.api.SortedIndex
|
||||
import org.fusesource.hawtbuf.Buffer
|
||||
|
||||
|
||||
|
||||
File tmpFile = new File(System.getProperty("user.home") + File.separator + "test_hawtdb.dat")
|
||||
//tmpFile.createNewFile()
|
||||
|
||||
def writeSomeData(tmpFile) {
|
||||
def factory = new PageFileFactory()
|
||||
factory.file = tmpFile
|
||||
factory.open()
|
||||
def pageFile = factory.getPageFile()
|
||||
int pageIdx = pageFile.alloc()
|
||||
pageFile.write(pageIdx, new Buffer("Test".getBytes()))
|
||||
println "writed at page index ${pageIdx}"
|
||||
pageFile.flush()
|
||||
pageFile.close()
|
||||
}
|
||||
|
||||
|
||||
def readTest(tmpFile) {
|
||||
def factory = new PageFileFactory()
|
||||
factory.file = tmpFile
|
||||
factory.open()
|
||||
def pageFile = factory.getPageFile()
|
||||
println "page size is: " + pageFile.pageSize
|
||||
Buffer b = new Buffer(512)
|
||||
pageFile.read(0, b)
|
||||
println "content try read " + b
|
||||
|
||||
pageFile.close()
|
||||
}
|
||||
|
||||
|
||||
writeSomeData(tmpFile)
|
||||
readTest(tmpFile)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user