Metacat

            MetacatPopulator mp = new MetacatPopulator(

                    "http://knb.ecoinformatics.org/knb",  

                    /*"http://localhost:8080/knb"*/

                    "uid=kepler,o=unaffiliated,dc=ecoinformatics,dc=org", 

                    "kepler");

            mp.populate();

import java.math.BigInteger;

import java.net.HttpURLConnection;

import java.net.URL;

import java.util.Calendar;

import java.util.Date;

import java.util.Vector;

import javax.activation.DataHandler;

import org.dataone.client.MNode;

import org.dataone.client.ObjectFormatCache;

import org.dataone.client.auth.CertificateManager;

import org.dataone.service.exceptions.NotFound;

import org.dataone.service.types.v1.AccessPolicy;

import org.dataone.service.types.v1.AccessRule;

import org.dataone.service.types.v1.SystemMetadata;

import org.dataone.service.types.v1.util.ChecksumUtil;

import org.dataone.service.util.Constants;

import org.ecoinformatics.datamanager.DataManager;

import org.ecoinformatics.datamanager.database.DatabaseConnectionPoolInterface;

import org.ecoinformatics.datamanager.parser.DataPackage;

    private String username = null;

    private String password = null;

    private Session session = null;

    /**

     * create a new MetacatPopulator with given source and destination urls.  

        this.destinationUrl = destUrl;

        // TODO: use specific certificate?

        this.session = null; //new Session();

    }

    /**

        MNode mn = D1Client.getMN(destinationUrl + "/");

        printHeader("Processing " + docs.size() + " results.");

            //for each document in the query

            Document doc = docs.get(i);

            String docid = doc.docid;

        	DataManager dataManager = DataManager.getInstance(connectionPool, connectionPool.getDBAdapterName());

        	DataPackage dataPackage = dataManager.parseMetadata(is);

                continue;

            }

            //go through the DistributionMetadata and download any described data

            is = stringToStream(doctext);

            doc.doctext = doctext;

            printHeader("creating document on destination " + destinationUrl);            

            SystemMetadata sysmeta = generateSystemMetadata(doc);

            if (dataPackage.getEntityList() != null) {

	                String dataDocUrl = dataPackage.getEntityList()[j].getURL();

	                if (dataDocMimeType == null) {

		                dataDocMimeType = 

		                	ObjectFormatCache.getInstance().getFormat("application/octet-stream").getFmtid().getValue();

	                }

	                String dataDocLocalId = "";

	                    dataDocLocalId = dataDocUrl.substring(dataDocUrl.indexOf("ecogrid://knb/") + 

	                            "ecogrid://knb/".length(), dataDocUrl.length());

	                    //get the file

	                    Identifier did = new Identifier();

	                    did.setValue(dataDocLocalId);

	                    //create sysmeta for the data doc                    

	                    SystemMetadata dataDocSysMeta = generateSystemMetadata(doc);

	                    String sizeStr = 

	                    	Long.toString(dataDocText.getBytes(MetaCatServlet.DEFAULT_ENCODING).length);

	                    dataDocSysMeta.setSize(new BigInteger(sizeStr));

	                    boolean error = false;

	                    //create the data doc on d1

	                        mn.create(session, dataDocSysMeta.getIdentifier(), IOUtils.toInputStream(dataDocText), dataDocSysMeta);

	                    }

	                        error = true;

	                        System.out.println("ERROR: Could not create data document with id " + 

	                                dataDocSysMeta.getIdentifier().getValue() + " : " + e.getMessage());

	                    }

	                            printHeader("Insertion of document " + dataDocSysMeta.getIdentifier().getValue() + 

	                                    "FAILED.");

	                        }

	                            printHeader("Done inserting document " + dataDocSysMeta.getIdentifier().getValue() +

	                                " which is described by " + sysmeta.getIdentifier().getValue());

	                        }

	                    }

	                }

	                    System.out.println("WARNING: Could not process describes url " +

	                            dataDocUrl + " for document " + doc.docid + 

	                    ".  Only ecogrid://knb/ urls are currently supported.");

	            }

            }

              System.out.println("Success inserting document " + id.getValue());

            }

                e.printStackTrace();

                System.out.println("Could not create document with id " + 

                        sysmeta.getIdentifier().getValue() + " : " + e.getMessage());

            }

            }

        }

     * @return

     */

    private SystemMetadata generateSystemMetadata(Document doc)

        SystemMetadata sm = new SystemMetadata();

        //set the id

        Identifier id = new Identifier();

        //set the object format

        ObjectFormat format = ObjectFormatCache.getInstance().getFormat(doc.doctype);

                format = ObjectFormatCache.getInstance().getFormat("application/octet-stream");

            }

                format = ObjectFormatCache.getInstance().getFormat("text/plain");

            }

        }

        String sizeStr = Long.toString(doc.doctext.getBytes(MetaCatServlet.DEFAULT_ENCODING).length);

        sm.setSize(new BigInteger(sizeStr));

        Subject p = new Subject();

        sm.setSubmitter(p);

        sm.setRightsHolder(p);

            Date dateCreated = parseMetacatDate(doc.createDate);

            sm.setDateUploaded(dateCreated);

            Date dateUpdated = parseMetacatDate(doc.updateDate);

            sm.setDateSysMetadataModified(dateUpdated);

        }

            System.out.println("couldn't parse a date: " + e.getMessage());

            Date dateCreated = new Date();

            sm.setDateUploaded(dateCreated);

        subject.setValue(Constants.SUBJECT_PUBLIC);

		accessRule.addSubject(subject);

		accessPolicy.addAllow(accessRule);

		sm.setAccessPolicy(accessPolicy);

        return sm;

    }

        System.out.println("****** " + s + " *******");

    }

    /**

     * parse the metacat date which looks like 2010-06-08 (YYYY-MM-DD) into

     * a proper date object