in openjpa-kernel/src/main/java/org/apache/openjpa/meta/AbstractCFMetaDataFactory.java [644:960]
protected Set<String> parsePersistentTypeNames(ClassLoader loader)
throws IOException {
ClassArgParser cparser = newClassArgParser();
String[] clss;
Set<String> names = new HashSet<>();
if (files != null) {
File file;
for (File value : files) {
file = value;
if (AccessController.doPrivileged(J2DoPrivHelper
.isDirectoryAction(file))) {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-directory", file));
scan(new FileMetaDataIterator(file, newMetaDataFilter()),
cparser, names, true, file);
}
else if (file.getName().endsWith(".jar")) {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-jar", file));
try {
ZipFile zFile = AccessController
.doPrivileged(J2DoPrivHelper
.newZipFileAction(file));
scan(new ZipFileMetaDataIterator(zFile,
newMetaDataFilter()), cparser, names, true, file);
}
catch (PrivilegedActionException pae) {
throw (IOException) pae.getException();
}
}
else {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-file", file));
clss = cparser.parseTypeNames(new FileMetaDataIterator
(file));
List<String> newNames = Arrays.asList(clss);
if (log.isTraceEnabled())
log.trace(_loc.get("scan-found-names", newNames, file));
names.addAll(newNames);
File f = AccessController
.doPrivileged(J2DoPrivHelper
.getAbsoluteFileAction(file));
try {
mapPersistentTypeNames(AccessController
.doPrivileged(J2DoPrivHelper.toURLAction(f)), clss);
}
catch (PrivilegedActionException pae) {
throw (FileNotFoundException) pae.getException();
}
}
}
}
URL url;
if (urls != null) {
for (URL value : urls) {
url = value;
if ("file".equals(url.getProtocol())) {
File file = AccessController
.doPrivileged(J2DoPrivHelper
.getAbsoluteFileAction(new File(url.getFile())));
if (files != null && files.contains(file)) {
continue;
}
else if (AccessController
.doPrivileged(J2DoPrivHelper.isDirectoryAction(file))) {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-directory", file));
scan(
new FileMetaDataIterator(file, newMetaDataFilter()),
cparser, names, true, file);
continue;
}
}
if ("vfs".equals(url.getProtocol())) {
if (log.isTraceEnabled()) {
log.trace(_loc.get("scanning-vfs-url", url));
}
final URL finalUrl = url;
if (url.toString().endsWith(".jar")) {
ZipInputStream zis = AccessController.doPrivileged(new PrivilegedAction<ZipInputStream>() {
@SuppressWarnings({"rawtypes", "unchecked"})
@Override
public ZipInputStream run() {
try {
Class vfs = Class.forName("org.jboss.vfs.VFS");
Method getChild = vfs.getDeclaredMethod("getChild", URL.class);
Object jarFile = getChild.invoke(null, finalUrl);
Class virtualFileClass = Class.forName("org.jboss.vfs.VirtualFile");
Method openStream = virtualFileClass.getDeclaredMethod("openStream");
return (ZipInputStream) openStream.invoke(jarFile);
}
catch (Exception e) {
log.error(_loc.get("while-scanning-vfs-url", finalUrl), e);
}
return null;
}
});
if (zis != null) {
scan(new ZipStreamMetaDataIterator(zis, newMetaDataFilter()), cparser, names, true, url);
}
}
else {
final URLConnection conn = url.openConnection();
final Object vfsContent = conn.getContent();
File file = AccessController.doPrivileged(new PrivilegedAction<File>() {
@SuppressWarnings({"rawtypes", "unchecked"})
@Override
public File run() {
try {
Class virtualFileClass = Class.forName("org.jboss.vfs.VirtualFile");
Method getPhysicalFile = virtualFileClass.getDeclaredMethod("getPhysicalFile");
return (File) getPhysicalFile.invoke(vfsContent);
}
catch (Exception e) {
log.error(_loc.get("while-scanning-vfs-url", finalUrl), e);
}
return null;
}
});
if (file != null) {
scan(new FileMetaDataIterator(file, newMetaDataFilter()), cparser, names, true, file);
}
}
continue;
}
if ("jar".equals(url.getProtocol())) {
if (url.getPath().endsWith("!/")) {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-jar-url", url));
scan(new ZipFileMetaDataIterator(url,
newMetaDataFilter()), cparser, names, true, url);
}
else {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-jar-url", url));
scan(new JarFileURLMetaDataIterator(url,
newMetaDataFilter()), cparser, names, true, url);
}
}
else if (url.getPath().endsWith(".jar")) {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-jar-at-url", url));
try {
InputStream is = (InputStream)
AccessController.doPrivileged(
J2DoPrivHelper.openStreamAction(url));
scan(new ZipStreamMetaDataIterator(
new ZipInputStream(is),
newMetaDataFilter()), cparser, names, true, url);
}
catch (PrivilegedActionException pae) {
throw (IOException) pae.getException();
}
}
else {
// Open an InputStream from the URL and sniff for a zip header. If it is, then this is
// a URL with a jar-formated InputStream, as per the JPA specification. Otherwise, fall back
// to URLMetaDataIterator.
BufferedInputStream is = null;
try {
is = new BufferedInputStream((InputStream) AccessController.
doPrivileged(J2DoPrivHelper.openStreamAction(url)));
}
catch (PrivilegedActionException pae) {
throw (IOException) pae.getException();
}
// Check for zip header magic 0x50 0x4b 0x03 0x04
is.mark(0);
boolean zipHeaderMatch = is.read() == 0x50 && is.read() == 0x4b && is.read() == 0x03 &&
is.read() == 0x04;
is.reset();
if (zipHeaderMatch) {
// The URL provides a Jar-formatted InputStream, consume it with ZipStreamMetaDataIterator
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-jar-at-url", url));
scan(new ZipStreamMetaDataIterator(new ZipInputStream(is), newMetaDataFilter()),
cparser, names, true, url);
}
else {
// Fall back to URLMetaDataIterator
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-url", url));
clss = cparser.parseTypeNames(new URLMetaDataIterator(url));
List<String> newNames = Arrays.asList(clss);
if (log.isTraceEnabled())
log.trace(_loc.get("scan-found-names", newNames, url));
names.addAll(newNames);
mapPersistentTypeNames(url, clss);
}
}
}
}
if (rsrcs != null) {
String rsrc;
MetaDataIterator mitr;
for (String s : rsrcs) {
rsrc = s;
if (rsrc.endsWith(".jar")) {
url = AccessController.doPrivileged(
J2DoPrivHelper.getResourceAction(loader, rsrc));
if (url != null) {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-jar-stream-url", url));
try {
InputStream is = (InputStream)
AccessController.doPrivileged(
J2DoPrivHelper.openStreamAction(url));
scan(new ZipStreamMetaDataIterator
(new ZipInputStream(is),
newMetaDataFilter()), cparser, names, true,
url);
}
catch (PrivilegedActionException pae) {
throw (IOException) pae.getException();
}
}
}
else {
if (log.isTraceEnabled())
log.trace(_loc.get("scanning-resource", rsrc));
mitr = new ResourceMetaDataIterator(rsrc, loader);
OpenJPAConfiguration conf = repos.getConfiguration();
Map peMap = null;
if (conf instanceof OpenJPAConfigurationImpl)
peMap = ((OpenJPAConfigurationImpl) conf).getPersistenceEnvironment();
URL puUrl = peMap == null ? null : (URL) peMap.get(PERSISTENCE_UNIT_ROOT_URL);
List<String> mappingFileNames =
peMap == null ? null : (List<String>) peMap.get(MAPPING_FILE_NAMES);
List<URL> jars = peMap == null ? null : (List<URL>) peMap.get(JAR_FILE_URLS);
String puUrlString = puUrl == null ? null : puUrl.toString();
if (log.isTraceEnabled())
log.trace(_loc.get("pu-root-url", puUrlString));
URL puORMUrl = null;
try {
if (puUrlString != null) {
String puORMUrlStr = puUrlString + (puUrlString.endsWith("/") ? "" : "/") + rsrc;
puORMUrl = AccessController.doPrivileged(J2DoPrivHelper.createURL(puORMUrlStr));
}
}
catch (PrivilegedActionException e) {
throw new IOException("Error generating puORMUrlStr.", e.getCause());
}
List<URL> urls = new ArrayList<>(3);
while (mitr.hasNext()) {
url = (URL) mitr.next();
String urlString = url.toString();
if (log.isTraceEnabled())
log.trace(_loc.get("resource-url", urlString));
if (peMap != null) {
//OPENJPA-2102: decode the URL to remove such things a spaces (' ') encoded as '%20'
if (puUrlString != null && decode(urlString).indexOf(decode(puUrlString)) != -1) {
urls.add(url);
}
else if (puORMUrl != null && puORMUrl.equals(url)) {
// Check URL equality to support encapsulating URL protocols
urls.add(url);
}
if (mappingFileNames != null && mappingFileNames.size() != 0) {
for (String mappingFileName : mappingFileNames) {
if (log.isTraceEnabled())
log.trace(_loc.get("mapping-file-name", mappingFileName));
if (urlString.indexOf(mappingFileName) != -1)
urls.add(url);
}
}
if (jars != null && jars.size() != 0) {
for (URL jarUrl : jars) {
if (log.isTraceEnabled())
log.trace(_loc.get("jar-file-url", jarUrl));
if (urlString.indexOf(jarUrl.toString()) != -1)
urls.add(url);
}
}
}
else {
urls.add(url);
}
}
mitr.close();
for (Object obj : urls) {
url = (URL) obj;
clss = cparser.parseTypeNames(new URLMetaDataIterator
(url));
List<String> newNames = Arrays.asList(clss);
if (log.isTraceEnabled())
log.trace(_loc.get("scan-found-names", newNames,
rsrc));
names.addAll(newNames);
mapPersistentTypeNames(url, clss);
}
}
}
}
if (cpath != null) {
String[] dirs = (String[]) cpath.toArray(new String[cpath.size()]);
scan(new ClasspathMetaDataIterator(dirs, newMetaDataFilter()),
cparser, names, true, dirs);
}
if (types != null)
names.addAll(types);
if (log.isTraceEnabled())
log.trace(_loc.get("parse-found-names", names));
return names;
}