{"id":2116,"date":"2011-08-25T15:24:24","date_gmt":"2011-08-25T05:24:24","guid":{"rendered":"http:\/\/redstack.dev\/?p=2116"},"modified":"2013-04-16T09:13:01","modified_gmt":"2013-04-15T23:13:01","slug":"getting-started-with-continuous-integration-for-osb","status":"publish","type":"post","link":"https:\/\/redstack.dev\/2011\/08\/25\/getting-started-with-continuous-integration-for-osb\/","title":{"rendered":"Getting started with Continuous Integration for OSB"},"content":{"rendered":"

As a first step towards including Oracle Service Bus projects into our Continuous Integration environment, let’s look at how to script exporting some project(s) from Oracle Enterprise Pack for Eclipse (the IDE for OSB) and deploying those project(s) to an OSB server.\u00a0 Later, we will include this into the Maven\/Hudson environment we have been constructing in this series of posts<\/a> on continuous integration.<\/p>\n

Here is our script, right up front, then we will discuss it:<\/p>\n

[source language=”text”]
\n@echo Export project from eclipse
\njava ^
\n -Dweblogic.home=c:\\oracle\\middleware\\wlserver_10.3 ^
\n -Dosb.home=c:\\oracle\\middleware\\Oracle_OSB1 ^
\n -Dosgi.bundlefile.limit=500 ^
\n -Dharvester.home=c:\\oracle\\middleware\\Oracle_OSB1\\harvester ^
\n -Dosgi.nl=en_US ^
\n -Dsun.lang.ClassLoader.allowArraySyntax=true ^
\n -jar c:\\Oracle\\OEPE\\oepe_11gR1PS4\\plugins\\org.eclipse.equinox.launcher_1.1.1.R36x_v20101122_1400.jar ^
\n -data c:\\src\\osb\\notsvn ^
\n -application com.bea.alsb.core.ConfigExport ^
\n -configProject "OSB Configuration 1" ^
\n -configJar c:\\src\\osb\\test_sbconfig.jar ^
\n -configSubProjects "OSB Project 1" ^
\n -includeDependencies true<\/p>\n

@echo Deploy ‘import’ to Service Bus
\nc:\\oracle\\middleware\\oracle_common\\common\\bin\\wlst import.py import.properties
\n[\/source]<\/p>\n

First of all, if you have not seen them before, the ‘^’ is a continuation character in Windows CMD files, such as this one, so that we can spread a command over many lines in our script, but it is executed as if it were all typed in on a single line.<\/p>\n

This script has not been made generic yet – it has a bunch of stuff hardcoded.\u00a0 Let’s take a look.<\/p>\n

First, we run java<\/strong> with a bunch of properties.\u00a0 You will need to set weblogic.home<\/strong>, osb.home<\/strong> and harvester.home<\/strong> to suit your environment.\u00a0 You can just include the others as they are.<\/p>\n

Following the properties, you see we point to a JAR file, this allows us to run eclipse in headless mode.\u00a0 The remainder of the parameters are passed to eclipse.\u00a0 You can see we need to specify the location of the workspace to use (in data<\/strong>) – this can also be the Subversion trunk (or similar).\u00a0 The application<\/strong> tells it to run the OSB exporter.<\/p>\n

The other important parameters are configProject<\/strong> which names the OSB Configuration project in the workspace you want to use, configSubProjects<\/strong> which is a comma separated list of the OSB projects you want to export, and configJar<\/strong> which is the name of the JAR file you want to create.<\/p>\n

If you want to know more about this command, take a look in the online help in your OSB IDE.\u00a0 Look under the OSB help topic, then ‘Tasks,’ ‘Working with projects, folders, resources & configurations,’ ‘exporting resources,’ ‘using command line,’ and then the ANT topic.<\/p>\n

When this command has run, we will have an OSB configuration JAR file (test_sbconfig.jar<\/strong> in this case) which is ready to import into (deploy to) an OSB server.<\/p>\n

The second part is to perform the deployment (import).\u00a0 We will do this using a WLST script from Oracle, import.py<\/strong> (see below).\u00a0 This script also expects a properties file.\u00a0 We need to set up some details in the properties file so the script knows what to do.<\/p>\n

Let’s take a look at the properties file:<\/p>\n

[source language=”text”]
\n##################################################################
\n# OSB Admin Security Configuration #
\n##################################################################
\nadminUrl=t3:\/\/localhost:7001
\nimportUser=weblogic
\nimportPassword=welcome1<\/p>\n

##################################################################
\n# OSB Jar to be exported, optional customization file #
\n##################################################################
\nimportJar=test_sbconfig.jar
\n#customizationFile=OSBCustomizationFile.xml<\/p>\n

##################################################################
\n# Optional passphrase and project name #
\n##################################################################
\n#passphrase=osb
\n#project=default
\n[\/source]<\/p>\n

You can see we have provided the URL for the Administration Server, and also the name of the OSB configuration JAR file (that we just created in the previous step).<\/p>\n

Here is the import.py<\/strong> sciript that WLST will run:<\/p>\n

[source language=”text”]
\nfrom java.util import HashMap
\nfrom java.util import HashSet
\nfrom java.util import ArrayList
\nfrom java.io import FileInputStream<\/p>\n

from com.bea.wli.sb.util import Refs
\nfrom com.bea.wli.config.customization import Customization
\nfrom com.bea.wli.sb.management.importexport import ALSBImportOperation<\/p>\n

import sys<\/p>\n

#=======================================================================================
\n# Entry function to deploy project configuration and resources
\n# into a ALSB domain
\n#=======================================================================================<\/p>\n

def importToALSBDomain(importConfigFile):
\n try:
\n SessionMBean = None
\n print ‘Loading Deployment config from :’, importConfigFile
\n exportConfigProp = loadProps(importConfigFile)
\n adminUrl = exportConfigProp.get("adminUrl")
\n importUser = exportConfigProp.get("importUser")
\n importPassword = exportConfigProp.get("importPassword")<\/p>\n

importJar = exportConfigProp.get("importJar")
\n customFile = exportConfigProp.get("customizationFile")<\/p>\n

passphrase = exportConfigProp.get("passphrase")
\n project = exportConfigProp.get("project")<\/p>\n

connectToServer(importUser, importPassword, adminUrl)<\/p>\n

print ‘Attempting to import :’, importJar, "on ALSB Admin Server listening on :", adminUrl<\/p>\n

theBytes = readBinaryFile(importJar)
\n print ‘Read file’, importJar
\n sessionName = createSessionName()
\n print ‘Created session’, sessionName
\n SessionMBean = getSessionManagementMBean(sessionName)
\n print ‘SessionMBean started session’
\n ALSBConfigurationMBean = findService(String("ALSBConfiguration.").concat(sessionName), "com.bea.wli.sb.management.configuration.ALSBConfigurationMBean")
\n print "ALSBConfiguration MBean found", ALSBConfigurationMBean
\n ALSBConfigurationMBean.uploadJarFile(theBytes)
\n print ‘Jar Uploaded’<\/p>\n

if project == None:
\n print ‘No project specified, additive deployment performed’
\n alsbJarInfo = ALSBConfigurationMBean.getImportJarInfo()
\n alsbImportPlan = alsbJarInfo.getDefaultImportPlan()
\n alsbImportPlan.setPassphrase(passphrase)
\n alsbImportPlan.setPreserveExistingEnvValues(true)
\n importResult = ALSBConfigurationMBean.importUploaded(alsbImportPlan)
\n SessionMBean.activateSession(sessionName, "Complete test import with customization using wlst")
\n else:
\n print ‘ALSB project’, project, ‘will get overlaid’
\n alsbJarInfo = ALSBConfigurationMBean.getImportJarInfo()
\n alsbImportPlan = alsbJarInfo.getDefaultImportPlan()
\n alsbImportPlan.setPassphrase(passphrase)
\n operationMap=HashMap()
\n operationMap = alsbImportPlan.getOperations()
\n print
\n print ‘Default importPlan’
\n printOpMap(operationMap)
\n set = operationMap.entrySet()<\/p>\n

alsbImportPlan.setPreserveExistingEnvValues(true)<\/p>\n

#boolean
\n abort = false
\n #list of created ref
\n createdRef = ArrayList()<\/p>\n

for entry in set:
\n ref = entry.getKey()
\n op = entry.getValue()
\n #set different logic based on the resource type
\n type = ref.getTypeId
\n if type == Refs.SERVICE_ACCOUNT_TYPE or type == Refs.SERVICE_PROVIDER_TYPE:
\n if op.getOperation() == ALSBImportOperation.Operation.Create:
\n print ‘Unable to import a service account or a service provider on a target system’, ref
\n abort = true
\n elif op.getOperation() == ALSBImportOperation.Operation.Create:
\n #keep the list of created resources
\n createdRef.add(ref)<\/p>\n

if abort == true :
\n print ‘This jar must be imported manually to resolve the service account and service provider dependencies’
\n SessionMBean.discardSession(sessionName)
\n raise<\/p>\n

print
\n print ‘Modified importPlan’
\n printOpMap(operationMap)
\n importResult = ALSBConfigurationMBean.importUploaded(alsbImportPlan)<\/p>\n

printDiagMap(importResult.getImportDiagnostics())<\/p>\n

if importResult.getFailed().isEmpty() == false:
\n print ‘One or more resources could not be imported properly’
\n raise<\/p>\n

#customize if a customization file is specified
\n #affects only the created resources
\n if customFile != None :
\n print ‘Loading customization File’, customFile
\n print ‘Customization applied to the created resources only’, createdRef
\n iStream = FileInputStream(customFile)
\n customizationList = Customization.fromXML(iStream)
\n filteredCustomizationList = ArrayList()
\n setRef = HashSet(createdRef)<\/p>\n

# apply a filter to all the customizations to narrow the target to the created resources
\n for customization in customizationList:
\n print customization
\n newcustomization = customization.clone(setRef)
\n filteredCustomizationList.add(newcustomization)<\/p>\n

ALSBConfigurationMBean.customize(filteredCustomizationList)<\/p>\n

SessionMBean.activateSession(sessionName, "Complete test import with customization using wlst")<\/p>\n

print "Deployment of : " + importJar + " successful"
\n except:
\n print "Unexpected error:", sys.exc_info()[0]
\n if SessionMBean != None:
\n SessionMBean.discardSession(sessionName)
\n raise<\/p>\n

#=======================================================================================
\n# Utility function to print the list of operations
\n#=======================================================================================
\ndef printOpMap(map):
\n set = map.entrySet()
\n for entry in set:
\n op = entry.getValue()
\n print op.getOperation(),
\n ref = entry.getKey()
\n print ref
\n print<\/p>\n

#=======================================================================================
\n# Utility function to print the diagnostics
\n#=======================================================================================
\ndef printDiagMap(map):
\n set = map.entrySet()
\n for entry in set:
\n diag = entry.getValue().toString()
\n print diag
\n print<\/p>\n

#=======================================================================================
\n# Utility function to load properties from a config file
\n#=======================================================================================<\/p>\n

def loadProps(configPropFile):
\n propInputStream = FileInputStream(configPropFile)
\n configProps = Properties()
\n configProps.load(propInputStream)
\n return configProps<\/p>\n

#=======================================================================================
\n# Connect to the Admin Server
\n#=======================================================================================<\/p>\n

def connectToServer(username, password, url):
\n connect(username, password, url)
\n domainRuntime()<\/p>\n

#=======================================================================================
\n# Utility function to read a binary file
\n#=======================================================================================
\ndef readBinaryFile(fileName):
\n file = open(fileName, ‘rb’)
\n bytes = file.read()
\n return bytes<\/p>\n

#=======================================================================================
\n# Utility function to create an arbitrary session name
\n#=======================================================================================
\ndef createSessionName():
\n sessionName = String("SessionScript"+Long(System.currentTimeMillis()).toString())
\n return sessionName<\/p>\n

#=======================================================================================
\n# Utility function to load a session MBeans
\n#=======================================================================================
\ndef getSessionManagementMBean(sessionName):
\n SessionMBean = findService("SessionManagement", "com.bea.wli.sb.management.configuration.SessionManagementMBean")
\n SessionMBean.createSession(sessionName)
\n return SessionMBean<\/p>\n

# IMPORT script init
\ntry:
\n # import the service bus configuration
\n # argv[1] is the export config properties file
\n importToALSBDomain(sys.argv[1])<\/p>\n

except:
\n print "Unexpected error: ", sys.exc_info()[0]
\n dumpStack()
\n raise
\n[\/source]<\/p>\n

You need to put the original script, import.py<\/strong> and import.properties<\/strong> all in to the same directory.\u00a0 Now you can run our original script and it will perform the export from eclipse and the deployment to OSB.<\/p>\n

In a future post, we will be parameterizing this and folding it into our Hudson\/Maven oriented continuous integration environment.<\/p>\n","protected":false},"excerpt":{"rendered":"

As a first step towards including Oracle Service Bus projects into our Continuous Integration environment, let’s look at how to script exporting some project(s) from Oracle Enterprise Pack for Eclipse (the IDE for OSB) and deploying those project(s) to an … Continue reading →<\/span><\/a><\/p>\n","protected":false},"author":4270085,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_coblocks_attr":"","_coblocks_dimensions":"","_coblocks_responsive_height":"","_coblocks_accordion_ie_support":"","_crdt_document":"","advanced_seo_description":"","jetpack_seo_html_title":"","jetpack_seo_noindex":false,"_jetpack_newsletter_access":"","_jetpack_dont_email_post_to_subs":false,"_jetpack_newsletter_tier_id":0,"_jetpack_memberships_contains_paywalled_content":false,"_jetpack_memberships_contains_paid_content":false,"footnotes":"","jetpack_publicize_message":"","jetpack_publicize_feature_enabled":true,"jetpack_social_post_already_shared":false,"jetpack_social_options":{"image_generator_settings":{"template":"highway","default_image_id":0,"font":"","enabled":false},"version":2},"jetpack_post_was_ever_published":false},"categories":[1],"tags":[163615,1377995],"class_list":["post-2116","post","type-post","status-publish","format-standard","hentry","category-uncategorized","tag-continuous-integration","tag-osb"],"jetpack_publicize_connections":[],"jetpack_featured_media_url":"","jetpack_likes_enabled":true,"jetpack_sharing_enabled":true,"jetpack_shortlink":"https:\/\/wp.me\/pgVeO-y8","jetpack-related-posts":[],"_links":{"self":[{"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/posts\/2116","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/users\/4270085"}],"replies":[{"embeddable":true,"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/comments?post=2116"}],"version-history":[{"count":1,"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/posts\/2116\/revisions"}],"predecessor-version":[{"id":2117,"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/posts\/2116\/revisions\/2117"}],"wp:attachment":[{"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/media?parent=2116"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/categories?post=2116"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/redstack.dev\/wp-json\/wp\/v2\/tags?post=2116"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}