import com.orientechnologies.orient.core.exception.OSchemaException; //导入依赖的package包/类
@Test
public void csvBatchImporterTest() throws java.lang.Exception
{

    CSVBatchImporter importer = new CSVBatchImporter();

    importer.setDbName("__TEST__1");
    try {
        importer.importCSVFiles(
                "test/src/resources/nodes.csv",
                "test/src/resources/edges.csv");
    }
    catch (OSchemaException exception) {
        exception.printStackTrace();
        throw exception;
    }

    OrientGraph graph = new OrientGraph(
            "plocal:" + System.getProperty("ORIENTDB_HOME") + "/databases/" + "__TEST__1");

    Pipe pipe = Gremlin.compile("_().map");
    pipe.setStarts(graph.getVertices());
}
 

import com.orientechnologies.orient.core.exception.OSchemaException; //导入依赖的package包/类
protected void createProperties(Row row) {
    OClass clazz;
    if (className != null) {
        clazz = getOrCreateClass(className);
    } else {
        clazz = ((ODocument) row.getPayload()).getSchemaClass();
    }

    int count = row.getFieldCount();
    for (int i = 0; i < count; i++) {
        String fieldName = row.getFieldName(i);
        OProperty property = clazz.getProperty(fieldName);
        if (property == null) {
            OType type = OType.getTypeByClass(row.getFieldType(i));
            try {
                clazz.createProperty(fieldName, type);
            } catch (OSchemaException e) {
                log.error(e.getMessage(), e);
            }

            log.debug("Created property '{}' of type '{}'", fieldName, type);
        }
    }
}
 

import com.orientechnologies.orient.core.exception.OSchemaException; //导入依赖的package包/类
@Override
public IRequestHandler onException(RequestCycle cycle, Exception ex) {
	Throwable th = null;
	if((th=Exceptions.findCause(ex, OSecurityException.class))!=null
			|| (th=Exceptions.findCause(ex, OValidationException.class))!=null
			|| (th=Exceptions.findCause(ex, OSchemaException.class))!=null
			|| (th=Exceptions.findCause(ex, IllegalStateException.class))!=null && Exceptions.findCause(ex, WicketRuntimeException.class)==null)
	{
		Page page = extractCurrentPage(false);
		if(page==null) {
			return th instanceof OSecurityException ?
						new UnauthorizedInstantiationHandler(extractCurrentPage(true))
						:null; 
		}
		OrientDbWebSession.get().error(th.getMessage());
		return new RenderPageRequestHandler(new PageProvider(page),
		RenderPageRequestHandler.RedirectPolicy.ALWAYS_REDIRECT);
	}
	else if((th=Exceptions.findCause(ex, UnauthorizedActionException.class))!=null)
	{
		final UnauthorizedActionException unauthorizedActionException = (UnauthorizedActionException)th;
		return new UnauthorizedInstantiationHandler(unauthorizedActionException.getComponent());
	}
	else
	{
		return null;
	}
}
 

import com.orientechnologies.orient.core.exception.OSchemaException; //导入依赖的package包/类
protected void createProperty(final OClass cls, final String f, final Object fValue) {
  if (fValue != null) {
    final OType fType = OType.getTypeByClass(fValue.getClass());

    try {
      cls.createProperty(f, fType);
    } catch (OSchemaException e) {
    }

    log(OETLProcessor.LOG_LEVELS.DEBUG, "created property [%s.%s] of type [%s]", cls.getName(), f, fType);
  }
}