| | |
| | | { |
| | | try |
| | | { |
| | | final Tree tree = volume.getTree(treeName.toString(), true); |
| | | final Tree tree = volume.getTree(mangleTreeName(treeName), true); |
| | | trees.put(treeName, tree); |
| | | } |
| | | catch (final PersistitException e) |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void renameTree(final TreeName oldTreeName, |
| | | final TreeName newTreeName) |
| | | public void renameTree(final TreeName oldTreeName, final TreeName newTreeName) |
| | | { |
| | | throw new UnsupportedOperationException(); |
| | | } |
| | |
| | | } |
| | | exchanges.clear(); |
| | | } |
| | | |
| | | private Exchange getNewExchange(final TreeName treeName, final boolean create) |
| | | throws PersistitException |
| | | { |
| | | return db.getExchange(volume, mangleTreeName(treeName), create); |
| | | } |
| | | } |
| | | |
| | | private static void clearAndCreateDbDir(final File dbDir) |
| | |
| | | return new ImporterImpl(); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | public String toSafeSuffixName(final String suffix) |
| | | private String mangleTreeName(final TreeName treeName) |
| | | { |
| | | return suffix.replaceAll("[,=]", "_"); |
| | | StringBuilder mangled = new StringBuilder(); |
| | | String name = treeName.toString(); |
| | | |
| | | for (int idx = 0; idx < name.length(); idx++) |
| | | { |
| | | char ch = name.charAt(idx); |
| | | if (ch == '=' || ch == ',') |
| | | { |
| | | ch = '_'; |
| | | } |
| | | mangled.append(ch); |
| | | } |
| | | return mangled.toString(); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | |
| | | return value; |
| | | } |
| | | |
| | | private Exchange getNewExchange(final TreeName treeName, final boolean create) |
| | | throws PersistitException |
| | | { |
| | | return db.getExchange(volume, treeName.toString(), create); |
| | | } |
| | | |
| | | private ByteString keyToBytes(final Key key) |
| | | { |
| | | return ByteString.wrap(key.reset().decodeByteArray()); |