Websphere + Jython. Сборник готовый функций для всевозможных операций по созданию j2ee ресурсов

Все эти методы пригодятся Вам при использовании кода из раздела Websphere + Jython.

Если в одном из постов Вы нашли подходящий пример кода на житоне, но в нем не достает некоторых вспомогательных функций, вы можете обратиться к коду ниже. Там Вы его точно найдете. 

Процедура начинается, например, с такого определения:

def createBusDestination( busName, destName, type ):

а заканчивается так:

#endDef

Код:

import java.util as util import java.io as javaio _modules = [ 'sys', 'time', 're', 'glob', 'os', 'os.path', 'getopt', 'traceback' ] # Load imported modules for module in _modules: try: locals()[module] = __import__(module, {}, {}, []) except ImportError: print 'Error importing %s.' % module # Print SVN file and version information. # Define False, True (False, True) = (0, 1) def createBusDestination( busName, destName, type ): #----------------------------------------------------------------------------- # Create a SIB Destination on the given SIBus #----------------------------------------------------------------------------- global AdminTask global AdminConfig print '\n====== Create '+destName+' on the '+busName+' SIBus' SIDestList = AdminTask.listSIBDestinations('-bus '+busName).split(lineSeparator) # Check for existence of SIB Destination for dest in SIDestList: ident = AdminConfig.showAttribute(dest, "identifier") if (ident == destName): print destName+" already exists." return #endIf #endFor parms = "-bus", busName, "-name", destName, "-type", type, if (type == "TopicSpace"): parms += "-topicAccessCheckRequired", "true" #endIf try: _excp_ = 0 result = AdminTask.createSIBDestination(parms) except: _type_, _value_, _tbck_ = sys.exc_info() result = `_value_` _excp_ = 1 #endTry if (_excp_ ): print "Error creating SIB Destination "+destName print "Error = "+result return #endIf print "SIB Destination successfully created." #endDef def deleteBusDestination( busName, destName, destType): m = "deleteBusDestination: " params = "-bus %s -name %s" % (busName, destName) sop (m, 'Attempting to delete bus destination:%s on bus:%s' % (destName, busName)) AdminTask.deleteSIBDestination(params) AdminConfig.save() sop (m, 'Bus destination successfully deleted') #endDef def createSIBus(clusterName, nodeName, serverName, SIBusName, scope, busSecurity=""): """ This method encapsulates the actions needed to create a bus on the current cell. It will check to see if the bus already exists. If not, it will add the member. Parameters: clusterName - Name of the cluster to add onto bus in String format. If value is "none", server-node will be added instead of cluster nodeName - Name of node containing server to add onto bus in String format. serverName - Name of server to add onto bus in String format. SIBusName - Name of bus to create in String format. scope - Identification of object (such as server or node) in String format. busSecurity - Set this option to TRUE to enforce the authorization policy for the bus Returns: No return value """ m = "createSIBus: " #-------------------------------------------------------------------- # Create a bus in the current cell. As well as creating a bus, the # createSIBus command will create a default topic space on the bus. #-------------------------------------------------------------------- try: bus = AdminConfig.getid('/SIBus:%s' % SIBusName) if((len(bus) == 1) or (len(bus) == 0)): params = ["-bus", SIBusName, "-description", "Messaging bus for testing"] if(not(busSecurity == "")): params.append("-busSecurity") params.append(busSecurity) else: # Use deprecated -secure option for compatibility with prior versions of this script. params.append("-secure") params.append("FALSE") #endElse AdminTask.createSIBus(params) else: sop(m, "The %s already exists." % SIBusName) #endElse #-------------------------------------------------------------------- # Add SI bus member #-------------------------------------------------------------------- addSIBusMember(clusterName, nodeName, serverName, SIBusName) sop(m, "Bus %s successfully created." % SIBusName) #-------------------------------------------------------------------- # Enable SIB service #-------------------------------------------------------------------- enableService("SIBService", scope) sop(m, "SIBService enabled.") AdminConfig.save() except Exception, e: sop(m, "Exception during BUS creation: " + str(e)) #endDef ############################################################################### # JMS Resource Management def enableService(serviceName, scope): """ This method encapsulates the base action of enabling a service for use in WAS. Parameters: serviceName - Name of the service to be enabled in String format scope - Identification of object (such as server or node) in String format. Returns: No return value """ m = "enableService: " #-------------------------------------------------------------------- # Get a list of service objects. There should only be one. # If there's more than one, use the first one found. #-------------------------------------------------------------------- services = _splitlines(AdminConfig.list(serviceName, scope)) if (len(services) == 0): sop(m, "The %s service could not be found." % serviceName) return #endIf serviceID = services[0] #-------------------------------------------------------------------- # Set the service enablement #-------------------------------------------------------------------- if (AdminConfig.showAttribute(serviceID, "enable") == "true"): sop(m, "The %s service is already enabled." % serviceName) else: AdminConfig.modify(serviceID, [["enable", "true"]]) #endElse #endDef def addSIBusMember(clusterName, nodeName, serverName, SIBusName): """ This method encapsulates the actions needed to add a server-node or a cluster to a bus. It will scan the member list to determine if cluster or server-node is already on the specified bus. If not, it will add the member. Parameters: clusterName - Name of the cluster to add onto bus in String format. If value is "none", server-node will be added instead of cluster nodeName - Name of node containing server to add onto bus in String format. serverName - Name of server to add onto bus in String format. SIBusName - Name of bus to add member onto in String format. Returns: No return value """ m = "addSIBusMember: " if(clusterName == "none"): for member in _splitlines(AdminTask.listSIBusMembers(["-bus", SIBusName])): memberNode = AdminConfig.showAttribute(member, "node") memberServer = AdminConfig.showAttribute(member, "server") if((memberNode == nodeName) and (memberServer == serverName)): sop(m, "The bus member already exists.") return #endIf #endFor AdminTask.addSIBusMember(["-bus", SIBusName, "-node", nodeName, "-server", serverName]) else: for member in _splitlines(AdminTask.listSIBusMembers(["-bus", SIBusName])): memberCluster = AdminConfig.showAttribute(member, "cluster") if(memberCluster == clusterName): sop(m, "The bus member already exists.") return #endIf #endFor AdminTask.addSIBusMember(["-bus", SIBusName, "-cluster", clusterName]) sop(m, "Server successfully added to SIB.") AdminConfig.save() #endElse #endDef def createSIBJMSActivationSpec(activationSpecName, activationSpecJNDI, jmsQJNDI, destinationType, messageSelector, authAlias, SIBusName, scope, subscriptionName, clientId, durableSubscription): """ This method encapsulates the actions needed to create a JMS Activation Specification. Parameters: activationSpecName - Name of activation spec in String format actiovationSpecJNDI - JNDI Identifier of activation spec in String format jmsQJNDI - JNDI Identifier of the JMS queue to associate spec with in String format destinationType - Type of destination end point in String format messageSelector - Identifier of the message selector in String format authAlias - Authentication alias for activation spec in String format SIBusName - Name of bus to connect activation spec to in String format scope - Identification of object (such as server or node) in String format. Returns: No return value """ m = "createSIBJMSActivationSpec: " activationSpecifications = AdminTask.listSIBJMSActivationSpecs(scope) if activationSpecifications: for spec in _splitlines(activationSpecifications): name = AdminConfig.showAttribute(spec, "name") if (name == activationSpecName): sop(m, "The %s SIB JMS activation spec already exists." % activationSpecName) return #endIf #endFor #-------------------------------------------------------------------- # Create SIB JMS activation spec #-------------------------------------------------------------------- params = ["-name", activationSpecName, "-jndiName", activationSpecJNDI, "-busName", SIBusName, "-destinationJndiName", jmsQJNDI, "-destinationType", destinationType, "-subscriptionName", subscriptionName, "-clientId", clientId, "-subscriptionDurability", "Durable", "-durableSubscriptionHome", durableSubscription] if(not(authAlias == "")): params.append("-authenticationAlias") params.append(authAlias) #endIf if(not(messageSelector == "")): params.append("-messageSelector") params.append(messageSelector) #endIf AdminTask.createSIBJMSActivationSpec(scope, params) sop(m, "Activation specification %s successfully created." % activationSpecName) AdminConfig.save() #endDef def createSIBJMSConnectionFactory(clusterName, cellName, serverName, jmsCFName, jmsCFJNDI, jmsCFDesc, jmsCFType, SIBusName, provEndPoints, scope, authAlias=""): """ This method encapsulates the actions needed to create a JMS Connection Factory for handling connections between communicators and queues. Parameters: clusterName - Name of the cluster to associate connection factory with in String format. If value is "none", server will be used instead of cluster serverName - Name of server to associate connection factory with in String format. jmsCFName - Name to use for connection factory in String format. jmsCFJNDI - JNDI Identifier to use for connection factory in String format. jmsCFDesc - Description of the connection factory in String format. jmsCFType - Type of the connection factory in String format SIBusName - Name of bus to associate connection factory with in String format. provEndPoints - Provider of connection factory in String format scope - Identification of object (such as server or node) in String format. authAlias - Authentication alias for connection factory in String format Returns: No return value """ m = "createSIBJMSConnectionFactory: " #-------------------------------------------------------------------- # Create SIB JMS connection factory #-------------------------------------------------------------------- if(clusterName == "none"): jmsCF = AdminConfig.getid('/Cell:%s/J2CResourceAdapter:SIB JMS Resource Adapter/J2CConnectionFactory:%s' % (cellName, jmsCFName)) else: jmsCF = AdminConfig.getid('/ServerCluster:%s/J2CResourceAdapter:SIB JMS Resource Adapter/J2CConnectionFactory:%s' % (clusterName, jmsCFName)) #endElse if (len(jmsCF) != 0): sop(m, "The %s JMS connection factory already exists." % jmsCFName) return #endIf #-------------------------------------------------------------------- # Create the SIB JMS connection factory #-------------------------------------------------------------------- params = ["-name", jmsCFName, "-jndiName", jmsCFJNDI, "-busName", SIBusName, "-description", jmsCFDesc] if(not(jmsCFType == "")): params.append("-type") params.append(jmsCFType) #endIf if(not(provEndPoints == "")): params.append("-providerEndPoints") params.append(provEndPoints) #endIf if(not(authAlias == "")): params.append("-containerAuthAlias") params.append(authAlias) #endIf AdminTask.createSIBJMSConnectionFactory(scope, params) sop(m, "SIB JMS connection factory %s successfully created." % jmsCFName) AdminConfig.save() #endDef def createSIBJMSTopic(jmsTName, jmsTJNDI, jmsTDesc, SIBTName, SIBTopicSpace, scope, busName): """ This method encapsulates the actions needed to create a JMS Topic. Parameters: jmsTName - Name of topic in String format jmsTJNDI - JNDI Identifier of topic in String format jmsTDesc - Description of topic in String format SIBTName - Topic name value used in SIB in String format SIBTopicSpace - Topic space value used in SIB in String format scope - Identification of object (such as server or node) in String format. busName - Name of bus to append topic Returns: No return value """ m = "createSIBJMSTopic: " #-------------------------------------------------------------------- # Create SIB JMS topic #-------------------------------------------------------------------- for topic in _splitlines(AdminTask.listSIBJMSTopics(scope)): name = AdminConfig.showAttribute(topic, "name") if (name == jmsTName): sop(m, "The %s SIB JMS topic already exists." % jmsTName) return #endIf #endFor params = ["-name", jmsTName, "-jndiName", jmsTJNDI, "-description", jmsTDesc, "-topicName", SIBTName, "-topicSpace", SIBTopicSpace, "-busName", busName] AdminTask.createSIBJMSTopic(scope, params) sop(m, "JMS Topic %s successfully created." % jmsTName) AdminConfig.save() #endDef def createSIBJMSQueue(jmsQName, jmsQJNDI, jmsQDesc, SIBQName, scope, busName, nodeName, serverName): """ This method encapsulates the actions needed to create a JMS Queue for messages. Parameters: jmsQName - Name to use for queue in String format. jmsQJNDI - JNDI Identifier to use for queue in String format. jmsQDesc - Description of the queue in String format. SIBQName - Queue Name value used in protocol in String format scope - Identification of object (such as server or node) in String format. Returns: No return value """ m = "createSIBJMSQueue: " #-------------------------------------------------------------------- # Create SIB JMS queue #-------------------------------------------------------------------- for queue in _splitlines(AdminTask.listSIBJMSQueues(scope)): name = AdminConfig.showAttribute(queue, "name") if (name == jmsQName): sop(m, "The %s SIB JMS queue already exists." % jmsQName) return #endIf #endFor sibDestinationParams = ["-bus", busName, "-name", SIBQName, "-type", "Queue", "-node", nodeName, "-server", serverName] AdminTask.createSIBDestination(sibDestinationParams) params = ["-name", jmsQName, "-jndiName", jmsQJNDI, "-description", jmsQDesc, "-queueName", SIBQName, "-busName", busName] AdminTask.createSIBJMSQueue(scope, params) sop(m, "JMS Queue %s successfully created." % jmsQName) AdminConfig.save() #endDef ############################################################################### # JDBC def removeAndCreate(type, parent, attrs, objectKeyNames, parentAttrName=None): """Creates an object of a specific type under the parent with the given attributes. If such an object already exists, and if that object has existing attributes matching attributes named by objectKeyNames, the existing object is first removed.""" return _create(type, parent, attrs, objectKeyNames, parentAttrName, None) #endDef def _create(type, parent, attrs, objectKeyNames, parentAttrName, template): """Creates an object of a specific type under a specific parent with the given attrs and template. parentAttrName defines the attribute name in the parent you want to create a type under. If an existing object has existing attributes matching attributes named by objectKeyNames, it will first be removed.""" m = "_create:" if objectKeyNames: matchingAttrs = [] for objectKeyName in objectKeyNames: for attr in attrs: if attr[0] == objectKeyName: # assume that objectKeyNames are not specified more than once matchingAttrs.append([objectKeyName, attr[1]]) if len(matchingAttrs) > 0: findAndRemove(type, matchingAttrs, parent) if parentAttrName: sop(m, 'AdminConfig.create(%s, %s, %s, %s)' % (repr(type), repr(parent), repr(attrs), repr(parentAttrName))) object = AdminConfig.create(type, parent, attrs, parentAttrName) else: if template: sop(m, 'AdminConfig.create(%s, %s, %s, %s)' % (repr(type), repr(parent), repr(attrs), repr(template))) object = AdminConfig.create(type, parent, attrs, template) else: sop(m, 'AdminConfig.create(%s, %s, %s)' % (repr(type), repr(parent), repr(attrs))) object = AdminConfig.create(type, parent, attrs) return object #endDef def findAndRemove(type, attrs, parent=None): """Removes all the objects of a specific type under a specific parent that have attributes matching attrs""" children = getFilteredTypeList(type, attrs, parent) for child in children: remove(child) #endDef def remove(object): """Removes the specified object""" sop("remove:", 'AdminConfig.remove(%s)' % (repr(object))) AdminConfig.remove(object) #endDef def getFilteredTypeList(type, attrs, parent=None): """Produces a list of all the objects of a specific type under a specific parent that have attributes matching attrs""" myList = getObjectsOfType(type, parent) return filterTypeList(myList, attrs) #endDef def filterTypeList(list, attrs): """Filters the input list for items with an attribute names matching the input attribute list""" newlist = [] for item in list: # assume that the item is wanted addItem = 1 for attr in attrs: value = getObjectAttribute(item, attr[0]) if value != attr[1]: # if any attribute of an item is not wanted, then the item is not wanted addItem = 0 if addItem: newlist.append(item) return newlist #endDef def getObjectAttribute(objectid, attributename): """Return the value of the named attribute of the config object with the given ID. If there's no such attribute, returns None. If the attribute value looks like a list, converts it to a real python list. TODO: handle nested "lists" """ result = AdminConfig.showAttribute(objectid, attributename) if result != None and result.startswith("[") and result.endswith("]"): # List looks like "[value1 value2 value3]" result = _splitlist(result) return result #endDef def getObjectsOfType(typename, scope=None): """Return a python list of objectids of all objects of the given type in the given scope (another object ID, e.g. a node's object id to limit the response to objects in that node) Leaving scope default to None gets everything in the Cell with that type. ALWAYS RETURNS A LIST EVEN IF ONLY ONE OBJECT. """ m = "getObjectsOfType:" if scope: #sop(m, "AdminConfig.list(%s, %s)" % ( repr(typename), repr(scope) ) ) return _splitlines(AdminConfig.list(typename, scope)) else: #sop(m, "AdminConfig.list(%s)" % ( repr(typename) ) ) return _splitlines(AdminConfig.list(typename)) #endDef def create(type, parent, attrs, parentAttrName=None): """Creates an object of a specific type under the parent with the given attributes.""" return _create(type, parent, attrs, None, parentAttrName, None) #endDef def createJdbcProvider (name, providerName, cellName, nodeName, serverName, implementationClass, driverPath): """Creates a JDBCProvider in the specified parent scope; removes existing objects with the same name Parameters: providerName - Name to use for queue in String format. For example, "Oracle JDBC Driver (XA)" cellName - Target cell name nodeName - Target node name serverName - Target server name implementationClass - Implementation class for JDBC provider. For example, "oracle.jdbc.xa.client.OracleXADataSource" driverPath - Local path to the driver. For example ojdbc14.jar for Oracle thin client Returns: No return value """ m = "createJdbcProvider: " sop(m, 'Creating JDBC Provider. Trying to obtain provider templates for %s...' % providerName) providerTemplate = AdminConfig.listTemplates('JDBCProvider', providerName) sop(m, 'Creating JDBC Provider. Trying to identify node as /Cell:%s/Node:%s/' % (cellName, nodeName)) node = AdminConfig.getid('/Node:%s/Server:%s/' % (nodeName, serverName)) provName = ['name', name] implClassName = ['implementationClassName', implementationClass] classpath = ['classpath', driverPath] jdbcAttrs = [provName, implClassName, classpath] sop(m, 'Creating JDBC Provider using template: node=%s jdbcAttrs=%s providerTemplate=%s' % (node, jdbcAttrs, providerTemplate)) try: AdminConfig.createUsingTemplate('JDBCProvider', node, jdbcAttrs, providerTemplate) sop(m, "JDBC Provider %s successfully created." % providerName) AdminConfig.save() except Exception, err: sop(m, 'Error during creating JDBC provdier: %s' % str(err)) #endDef def createDataSource (scope, clusterName, nodeName, adminServerName, jdbcProviderName, datasourceName, datasourceDescription, datasourceJNDIName, statementCacheSize, authAliasName, datasourceHelperClassname, dbType, nonTransDS='', xaRecoveryAuthAlias=None, databaseName=None, serverName=None, portNumber=None, driverType=None, URL=None): """Creates a DataSource under the given JDBCProvider; removes existing objects with the same jndiName Parameters: scope - ID of the target cell/node/server to append data source clusterName - Target cluster name nodeName - Target node name adminServerName - Name of the server jdbcProviderName - Provider Name. For example, 'Oracle JDBC Driver (XA)' for oracle thin client datasourceName - Name of the data source datasourceDescription - Data source description datasourceJNDIName - Data source JNDI name statementCacheSize - Cache size for SQL statements authAliasName - Authentication alias to use datasourceHelperClassname - Data source helper class name. For example, 'com.ibm.websphere.rsadapter.Oracle10gDataStoreHelper'. dbType - Type of database. 'Oracle' for oracle nonTransDS - '' xaRecoveryAuthAlias - Authentication alias for XA Recovery databaseName - Database name serverName - Database server name portNumber - Target database server port driverType - '' URL - !Important. Connection String a.k.a URL. For Oracle thin client use: 'jdbc:oracle:thin:@server-name:1522:database-name' Returns: No return value """ try: m = "createDataSource: " sop (m, "Entering createDataSource...") mapping = [] mapping.append([ 'authDataAlias', authAliasName ]) mapping.append([ 'mappingConfigAlias', 'DefaultPrincipalMapping' ]) attrs = [] attrs.append([ 'name', datasourceName ]) attrs.append([ 'description', datasourceDescription ]) attrs.append([ 'jndiName', datasourceJNDIName ]) attrs.append([ 'statementCacheSize', statementCacheSize ]) attrs.append([ 'authDataAlias', authAliasName ]) attrs.append([ 'datasourceHelperClassname', datasourceHelperClassname ]) attrs.append([ 'mapping', mapping ]) attrs.append([ 'xaRecoveryAuthAlias', xaRecoveryAuthAlias]) serverId = AdminConfig.getid('/Node:%s/Server:%s/' % (nodeName, adminServerName)) print serverId j2cAdapters = _splitlines(AdminConfig.list('J2CResourceAdapter', serverId)) for resourceAdapter in j2cAdapters: if contains(resourceAdapter, "WebSphere Relational Resource Adapter") != 0: attrs.append([ 'relationalResourceAdapter', resourceAdapter]) jdbcProvider = AdminConfig.getid('/Node:' + nodeName + '/Server:'+ adminServerName + '/JDBCProvider:' + jdbcProviderName + '/') sop(m, "jdbcProvider: %s" % jdbcProvider) sop (m, "calling removeAndCreate to create datasource") datasourceID = removeAndCreate('DataSource', jdbcProvider, attrs, ['jndiName']) create('J2EEResourcePropertySet', datasourceID, [], 'propertySet') sop (m, "Create properties for the datasource based on the specified database type") dsProps = [] retcode = 0 if dbType == 'Oracle': if URL == None: sop (m, "All required properties for an Oracle datasource (URL) were not specified.") retcode = 4 else: dsProps.append([ 'URL', 'java.lang.String', URL ]) if retcode == 0: if (nonTransDS != ""): dsProps.append([ 'nonTransactionalDataSource', 'java.lang.Boolean', nonTransDS ]) #endif for prop in dsProps: propName = prop[0] propType = prop[1] propValue = prop[2] propDesc = "" sop (m, "calling setJ2eeResourceProperty") setJ2eeResourceProperty (\ datasourceID, propName, propType, propValue, propDesc, ) sop (m, "returned from calling setJ2eeResourceProperty") return datasourceID else: return None #endif except Exception, err: sop(m, 'Exception during creating DataSource: %s' % str(err)) #endDef def setJ2eeResourceProperty (parent, propName, propType, propValue, propDescription): """Sets a J2EEResourceProperty on the object specified by parent; parent must have a PropertySet child attribute named 'propertySet'""" attrs = [] attrs.append([ 'name', propName ]) attrs.append([ 'type', propType ]) attrs.append([ 'value', propValue ]) attrs.append([ 'description', propDescription ]) propSet = getObjectAttribute(parent, 'propertySet') removeAndCreate('J2EEResourceProperty', propSet, attrs, ['name']) #endDef # Security def createJAAS(authAlias, authUsername, authPassword): """ This method encapsulates the actions needed to create a J2C authentication data entry. Parameters: auth_alias - Alias to identify authentication entry in String format auth_username - Name of user in authentication entry in String format auth_password - User password in authentication entry in String format Returns: No return value """ m = "createJAAS: " #--------------------------------------------------------- # Check if the alias already exists #--------------------------------------------------------- auth = _splitlines(AdminConfig.list("JAASAuthData")) for autItem in auth: if (authAlias == AdminConfig.showAttribute(autItem, "alias")): sop("createJAAS", "The %s Resource Environment Provider already exists." % authAlias) return #endIf #endFor #--------------------------------------------------------- # Get the config id for the Cell's Security object #--------------------------------------------------------- cell = AdminControl.getCell() sec = AdminConfig.getid('/Cell:%s/Security:/' % cell) #--------------------------------------------------------- # Create a JAASAuthData object for authentication #--------------------------------------------------------- alias_attr = ["alias", authAlias] desc_attr = ["description", "authentication information"] userid_attr = ["userId", authUsername] password_attr = ["password", authPassword] attrs = [alias_attr, desc_attr, userid_attr, password_attr] appauthdata = AdminConfig.create("JAASAuthData", sec, attrs) sop(m, "createJAAS: J2XC authentication data entry %s successfully created" % authAlias) AdminConfig.save() #endDef ############################################################################## # Really basic stuff for messing around with configuration objects def _splitlist(s): """Given a string of the form [item item item], return a list of strings, one per item. WARNING: does not yet work right when an item has spaces. I believe in that case we'll be given a string like '[item1 "item2 with spaces" item3]'. """ if s[0] != '[' or s[-1] != ']': raise "Invalid string: %s" % s return s[1:-1].split(' ') def _splitlines(s): rv = [s] if '\r' in s: rv = s.split('\r\n') elif '\n' in s: rv = s.split('\n') if rv[-1] == '': rv = rv[:-1] return rv ############################################################ # misc methods def getFritzComponent(testpath): """ Gets the name of the Fritz component (i.e PXY,SIP) """ array = testpath.split('/') return array[-3] def enableDebugMessages(): """ Enables tracing by making future calls to the sop() method actually print messages. A message will also be printed to notify the user that trace messages will now be printed. """ global DEBUG_SOP DEBUG_SOP = 1 sop('enableDebugMessages', 'Verbose trace messages are now enabled; future debug messages will now be printed.') def disableDebugMessages(): """ Disables tracing by making future calls to the sop() method stop printing messages. If tracing is currently enabled, a message will also be printed to notify the user that future messages will not be printed. (If tracing is currently disabled, no message will be printed and no future messages will be printed). """ global DEBUG_SOP sop('enableDebugMessages', 'Verbose trace messages are now disabled; future debug messages will not be printed.') DEBUG_SOP = 0 def sop(methodname, message): """Prints the specified method name and message with a nicely formatted timestamp. (sop is an acronym for System.out.println() in java)""" print "%s %s" % (methodname, message) def emptyString(strng): """Returns True if the string is null or empty.""" if None == strng or "" == strng: return True return False #endDef def loadProperties(strng): global properties properties = util.Properties() propertiesfis = javaio.FileInputStream(strng) properties.load(propertiesfis) #endDef def filter_non_printable(str): return ''.join([c for c in str if ord(c) > 31 or ord(c) == 9]) #endDef # Delete functions def removeAllJdbcProviders(name): items = AdminConfig.list('JDBCProvider') itemList = items.split('\n') print 'Number of items = ', len(itemList) print itemList for objectName in itemList: if (objectName != ""): if contains(objectName, name) != 0: print 'Removing JDBC Provider ' + filter_non_printable(objectName) AdminConfig.remove(filter_non_printable(objectName)) else: print 'Skipping JDBC Provider that not belong to discovery' #endDef def contains(theString, theQueryValue): return theString.find(theQueryValue) > -1 #endDef def deleteAllSIBuses(): """Deletes all SIB bus objects in the configuration.""" m = "deleteAllSIBuses: " #sop(m,"Entry.") try: bus_list = _splitlines(AdminTask.listSIBuses()) #sopY(m,"bus_list=%s" % ( bus_list )) for bus in bus_list: #sop(m,"bus=%s" % ( bus )) bus_name = getNameFromId(bus) sop(m,"Deleting bus_name=%s" % ( bus_name )) AdminTask.deleteSIBus('[-bus %s ]' % (bus_name)) AdminConfig.save() except AttributeError, e: sop(m, str(e)) return #sop(m,"Exit.") #endDef def deleteSIBus(busName): m = "deleteSiIBus:" exist = 0 sop(m, "Checking for bus existance:%s" % (busName)) try: bus_list = _splitlines(AdminTask.listSIBuses()) #sopY(m,"bus_list=%s" % ( bus_list )) for bus in bus_list: print 'Investigating current bus: %s' % bus if contains(bus, busName) != 0: bus_name = getNameFromId(bus) sop(m,"Deleting bus_name=%s" % ( bus_name )) AdminTask.deleteSIBus('[-bus %s ]' % (bus_name)) AdminConfig.save() exist = 1 except AttributeError, e: sop(m, str(e)) return if (exist == 0): sop(m, "Bus with name: %s was not found" % busName) #endDef def getNameFromId(obj_id): """Returns the name from a wsadmin object id string. For example, returns PAP_1 from the following id: PAP_1(cells/ding6Cell01|coregroupbridge.xml#PeerAccessPoint_1157676511879) Returns the original id string if a left parenthesis is not found. """ # print "getNameFromId: Entry. obj_id=" + obj_id name = obj_id ix = obj_id.find('(') # print "getNameFromId: ix=%d" % (ix) if ix != -1 : name = obj_id[0:ix] # print "getNameFromId: Exit. name=" + name return name #endDef def deleteSIBJMSActivationSpec(jmsASName, clusterName, scope, objectName): """ This method encapsulates the actions needed to delete a SIB JMS Activation Specification. Parameters: jmsASName - Name of activation spec in String format. clusterName - Name of the cluster to associate queue with in String format. If value is "none", server will be used instead of cluster. serverName - Name of server to associate queue with in String format. Returns: No return value """ m = "deleteSIBJMSActivationSpec: " #-------------------------------------------------------------------- # Retrieve specific Resource Adapter Type ID for SIB JMS Resource Adapter #-------------------------------------------------------------------- if(clusterName == "none"): ra = AdminConfig.getid('/%s:%s/J2CResourceAdapter:SIB JMS Resource Adapter' % (scope, objectName)) else: ra = AdminConfig.getid('/Cluster:%s/J2CResourceAdapter:SIB JMS Resource Adapter' % clusterName) #endElse #-------------------------------------------------------------------- # Remove the Activation Spec found in the SIB JMS Resource Adapter #-------------------------------------------------------------------- for spec in _splitlines(AdminTask.listJ2CActivationSpecs(ra, ["-messageListenerType", "javax.jms.MessageListener"])): name = AdminConfig.showAttribute(spec, "name") if (name == jmsASName): AdminConfig.remove(spec) sop(m, "Deleted ActivationSpec %s" % jmsASName) return #endIf #endFor sop(m, "ActivationSpec %s not found" % jmsASName) #endDef def deleteJAAS(auth_alias): """ This method encapsulates the actions needed to remove a J2C authentication data entry. Parameters: auth_alias - Alias to identify authentication entry in String format Returns: No return value """ #--------------------------------------------------------- # Get JAASAuthDat object #--------------------------------------------------------- auth = _splitlines(AdminConfig.list("JAASAuthData")) for autItem in auth: if (auth_alias == AdminConfig.showAttribute(autItem, "alias")): AdminConfig.remove(autItem) break #endIf #endFor #endDef def deleteSIBJMSConnectionFactory(jmsCFName, clusterName, scope, objectName): """ This method encapsulates the actions needed to delete a SIB JMS Connection Factory. Parameters: jmsCFName - Name of connection factory in String format. clusterName - Name of the cluster to associate queue with in String format. If value is "none", server will be used instead of cluster. serverName - Name of server to associate queue with in String format. Returns: No return value """ m = "deleteSIBJMSConnectionFactory: " #-------------------------------------------------------------------- # Retrieve specific Object ID and remove Connection Factory using ID #-------------------------------------------------------------------- if(clusterName == "none"): jmsCF = AdminConfig.getid('/%s:%s/J2CResourceAdapter:SIB JMS Resource Adapter/J2CConnectionFactory:%s' % (scope, objectName,jmsCFName)) else: jmsCF = AdminConfig.getid('/Cluster:%s/J2CResourceAdapter:SIB JMS Resource Adapter/J2CConnectionFactory:%s' % (clusterName,jmsCFName)) #endElse if(not(jmsCF == "")): AdminConfig.remove(jmsCF) sop(m, "Deleted connection factory %s" % jmsCFName) else: sop(m, "ConnectionFactory %s not found" % jmsCFName) #endElse #endDef def deleteSIBJMSQueue(qName, scope): """ This method encapsulates the actions needed to delete a SIB JMS Queue. Parameters: qName - Name of JMS queue in String format. scope - Identification of object (such as server or node) in String format. Returns: No return value """ m = "deleteSIBJMSQueue: " #-------------------------------------------------------------------- # Search for queue based on scope and delete #-------------------------------------------------------------------- for queue in _splitlines(AdminTask.listSIBJMSQueues(scope)): name = AdminConfig.showAttribute(queue, "name") if (name == qName): AdminTask.deleteSIBJMSQueue(queue) sop(m, "Deleted jms queue %s" % qName) return #endIf #endFor #endDef def deleteSIBJMSTopic(tName, scope): """ This method encapsulates the actions needed to delete a SIB JMS Topic. Parameters: tName - Name of JMS queue in String format. scope - Identification of object (such as server or node) in String format. Returns: No return value """ m = "deleteSIBJMSTopic: " #-------------------------------------------------------------------- # Search for topic based on scope and delete #-------------------------------------------------------------------- for topic in _splitlines(AdminTask.listSIBJMSTopics(scope)): name = AdminConfig.showAttribute(topic, "name") if (name == tName): AdminTask.deleteSIBJMSTopic(topic) sop(m, "Deleted jms topic %s" % tName) return #endIf #endFor #endDef def wsadminToList(inStr): outList=[] if (len(inStr)>0 and inStr[0]=='[' and inStr[-1]==']'): tmpList = inStr[1:-1].split(" ") else: tmpList = inStr.split("\n") #splits for Windows or Linux for item in tmpList: item = item.rstrip(); #removes any Windows "\r" if (len(item)>0): outList.append(item) return outList #endDef def checkIfAppExists ( appName ): appExists = 1 application = AdminConfig.getid("/Deployment:"+appName+"/" ) if (len(application) == 0): appExists = 0 return appExists #endDef def StopApplication ( appName, nodeName, serverName ): print 'Obtaining appManager' appMgrID = AdminControl.queryNames("type=ApplicationManager,node="+nodeName+",process="+serverName+",*" ) length = len(appMgrID) if (length >= 1): stopped = "" try: print 'Attempting to stop application...' stopped = AdminControl.invoke(appMgrID, "stopApplication", appName ) except Exception, e: print 'Unable to stop application' + appName #print str(e) #endTry #endDef def uninstallEAR ( appName ): print 'Trying to uninstall application: ' + appName uninstalled = AdminApp.uninstall(appName ) appExists = checkIfAppExists(appName ) if (appExists): print "Failed to uninstallEAR" + appName return 0 #endIf print 'Application successfully uninstalled.' return 1 #endDef def checkApplicationRunning ( nodeName, serverName, appName ): appID = "" try: status = 0 appID = AdminControl.completeObjectName("type=Application,node="+nodeName+",Server="+serverName+",name="+appName+",*" ) except: print 'Unable to get application ID...' #endTry length = len(appID) print 'Check application running...' retries = 0 while (( retries < 1 ) and ( length == 0 ) ): retries = retries+1 print 'Application not yet started' try: _excp_ = 0 sleepDelay(10 ) appID = AdminControl.completeObjectName("type=Application,node="+nodeName+",Server="+serverName+",name="+appName+",*" ) if (len(appID) == 0): appExists = checkIfAppExists(appName ) if (appExists): pass else: print 'Application is not installed' return #endElse #endIf except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ if (temp > 0): print 'Exception trying to getID for application' #endIf length = len(appID) if (length > 0): print 'Application is STARTED...' return 1 else: print 'Application is not STARTED...' return 0 #endElse #endDef def deleteAllApplications(appName,cellName, nodeName, serverName): import java.lang.System as sys lineSeparator = sys.getProperty('line.separator') appManager = AdminControl.queryNames('node=%s,type=ApplicationManager,process=%s,*' % ( nodeName, serverName)) print 'App Manager' + appManager apps = AdminApp.list() apps = wsadminToList(apps) #AdminControl.queryNames('cell=%s,node=%s,type=Application,process=%s,*' % (cellName, nodeName, serverName)) print 'Number of installed applications = ', len(apps) print apps for application in apps: print 'Current application is %s' % application if (application != "" and application == appName): print 'This application is to be removed...' print 'Checking if application exists...' print checkIfAppExists( application ) print 'Checking if application running...' running = checkApplicationRunning(nodeName, serverName, application) if (running > 0): print 'Stopping application...' StopApplication('"'+application+'"', nodeName, serverName) StopApplication('"'+application+'"', nodeName, serverName) else: print 'Uninstalling application...' uninstallEAR(application) print 'Saving configuration...' AdminConfig.save() #endDef def startNDServer ( nodeName, serverName ): print 'Start server: nodeName=%s serverName=%s' % (nodeName, serverName) started = "" try: _excp_ = 0 started = AdminControl.startServer(serverName, nodeName, 100000 ) except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ print "startServer: failed" retries = 0 while ((temp > 0) and (retries < 5) ): retries = retries+1 print "startNDServer: start failed exception="+`temp`+" for "+nodeName+" "+serverName+", retries="+`retries`+" ..." try: _excp_ = 0 started = AdminControl.startServer(serverName, nodeName, 100000 ) except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ print "startNDServer: temp="+temp+" started="+started+" ..." #endWhile checkServerStarted(nodeName, serverName ) print "Start server: DONE." #endDef def checkServerStarted ( nodeName, serverName ): print "checkServerStarted: nodeName="+nodeName+" serverName="+serverName+" ..." serverID = "" retries = -1 while ((len(serverID) == 0) and (retries < 1) ): retries = retries+1 print "checkServerStarted: server not yet started, retries="+`retries`+" ..." try: _excp_ = 0 serverID = AdminControl.completeObjectName("node="+nodeName+",name="+serverName+",type=Server,*" ) except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ if (temp != 0): print "checkServerStarted AdminControl exception="+`temp`+" serverID="+serverID #endIf #endWhile if (retries > 0): print "checkServerStarted: "+nodeName+" "+serverName+" had slow start, status retries="+`retries` #endIf if (serverID == ""): print "checkServerStarted: "+nodeName+" "+serverName+" server FAILED TO START." return #endIf state = AdminControl.getAttribute(serverID, "state" ) state = state.upper() if (state == "STARTED"): print "checkServerStarted: "+nodeName+" "+serverName+" state="+state else: print "checkServerStarted: "+nodeName+" "+serverName+" INCORRECT state="+state #endElse print "checkServerStarted: DONE." #endDef def stopNDServer ( nodeName, serverName ): print "stopNDServer: nodeName="+nodeName+" serverName="+serverName serverID = AdminControl.completeObjectName("node="+nodeName+",name="+serverName+",type=Server,*" ) if (len(serverID) == 0): msg = "stopNDServer: cannot access node="+nodeName+" server="+serverName+" state=STOPPED?" print msg return #endIf state = AdminControl.getAttribute(serverID, "state" ) state = state.upper() print "stopNDServer: nodeName="+nodeName+" serverName="+serverName+" state="+state if (state== "STOPPED"): print nodeName+" "+serverName+" state=STOPPED" else: stopped = AdminControl.stopServer(serverName, nodeName, "immediate" ) if (len(stopped) != 0): print "stopNDServer: stopServer response="+stopped #endIf checkServerStopped(nodeName, serverName ) #endElse print "stopNDServer: DONE." #endDef def checkServerStopped ( nodeName, serverName ): print "checkServerStopped: nodeName="+nodeName+" serverName="+serverName desiredState = "STOPPED" serverID = "" try: _excp_ = 0 serverID = AdminControl.completeObjectName("node="+nodeName+",name="+serverName+",type=Server,*" ) except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ if (temp != 0): print "checkServerStopped: exception="+`temp`+" trying to access "+nodeName+" "+serverName #endIf if (len(serverID) == 0): print "checkServerStopped: cannot access node="+nodeName+" server="+serverName+" (STOPPED?)" actualState = desiredState else: actualState = AdminControl.getAttribute(serverID, "state" ) #endElse actualState = actualState.upper() print "checkServerStopped: "+nodeName+" "+serverName+" actualState="+actualState+" desiredState="+desiredState if (actualState != desiredState): msg = "ERROR: checkServerStopped: "+nodeName+" "+serverName+" actualState="+actualState+" instead of desiredState="+desiredState print msg #endIf #endDef def checkNodeAgentStopped ( nodeName, serverName ): print "checkServerStopped: nodeName="+nodeName+" serverName="+serverName desiredState = "STOPPED" serverID = "" try: _excp_ = 0 serverID = AdminControl.completeObjectName("node="+nodeName+",name="+serverName+",type=Server,*" ) except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ if (temp != 0): print "checkServerStopped: exception="+`temp`+" trying to access "+nodeName+" "+serverName #endIf if (len(serverID) == 0): print "checkServerStopped: cannot access node="+nodeName+" server="+serverName+" (STOPPED?)" actualState = desiredState else: actualState = AdminControl.getAttribute(serverID, "state" ) #endElse actualState = actualState.upper() print "checkServerStopped: "+nodeName+" "+serverName+" actualState="+actualState+" desiredState="+desiredState if (actualState != desiredState): msg = "ERROR: checkServerStopped: "+nodeName+" "+serverName+" actualState="+actualState+" instead of desiredState="+desiredState print msg #endIf #endDef def restartNodeAgent(nodeName): print 'Retreiving nodeAgent for node %s' % nodeName #nodeAgent = AdminControl.queryNames('type=NodeAgent,node=%s,*' % nodeName) nodeAgent = returnNodeAgentName() print nodeAgent print 'Restarting nodeAgent' AdminControl.invoke(nodeAgent,'restart','true true') checkNodeAgentStartedWait() #endDef def checkNodeAgentStartedWait(): started = 0 retries = 0 while ( (started != 1) and (retries < 10) ): retries = retries+1 sleepDelay(3) started = checkNodeAgentState() #endDef def checkNodeAgentState() : servers = AdminConfig.list('Server' ).splitlines(); for server in servers : objName = AdminConfig.getObjectName( server ); isCluster = AdminConfig.showAttribute( server, 'clusterName' ); servertype = AdminConfig.showAttribute( server, 'serverType' ); sname = AdminConfig.showAttribute( server, 'name' ); nodeName = server.split( '/' )[ 3 ].split( ':' )[ 0 ]; if ( len( objName ) == 0 ) : if ( servertype == 'NODE_AGENT' ) : print 'Node Agent ' + nodeName + ' is not running'; return 0; #endIf else : result = AdminControl.getAttribute( objName, 'state' ); if ( servertype == 'NODE_AGENT' ) : print 'Node Agent ' + nodeName + ' is in the State of ' + result; return 1; #endIf #endFor #endDef def returnNodeAgentName(): print 'Trying to find node agent..' servers = AdminConfig.list('Server' ).splitlines(); for server in servers : objName = AdminConfig.getObjectName( server ); isCluster = AdminConfig.showAttribute( server, 'clusterName' ); servertype = AdminConfig.showAttribute( server, 'serverType' ); sname = AdminConfig.showAttribute( server, 'name' ); nodeName = server.split( '/' )[ 3 ].split( ':' )[ 0 ]; if ( servertype == 'NODE_AGENT' ) : print 'Node Agent ' + nodeName + ' was found'; return server; #endIf #endFor #endDef def sleepDelay ( secs ): import time tstart = time.strftime( "%H:%M:%S", time.localtime() ) #IGNORE: package require java try: _excp_ = 0 java.lang.Thread.sleep( (secs * 1000) ) except: _type_, _value_, _tbck_ = sys.exc_info() _excp_ = 1 #endTry temp = _excp_ tdone = time.strftime( "%H:%M:%S", time.localtime() ) print "sleepDelay seconds="+`secs`+" start="+tstart+" done="+tdone #endDef def getVariableMap ( nodeName=None, serverName=None, clusterName=None ): """Returns the VariableMap for the specified cell, node, server, or cluster""" target='(cells/'+getCellName() if clusterName: target=target+'/clusters/'+clusterName else: if nodeName: target=target+'/nodes/'+nodeName if serverName: target=target+'/servers/'+serverName target=target+'|variables.xml#VariableMap' maps=getObjectsOfType('VariableMap') for map in maps: if map.startswith(target): return map return map #endDef def setWebSphereVariable ( name, value, nodeName, serverName): """Creates a VariableSubstitutionEntry at the specified scope, removing any previously existing entry in the process""" map = getVariableMap(nodeName, serverName) print 'Retreived variables map' print map attrs = [] attrs.append( [ 'symbolicName', name ] ) attrs.append( [ 'value', value ] ) print 'Remove and create...' return removeAndCreate('VariableSubstitutionEntry', map, attrs, ['symbolicName']) #endDef def getCellName(): """Return the name of the cell we're connected to""" # AdminControl.getCell() is simpler, but only # available if we're connected to a running server. cellObjects = getObjectsOfType('Cell') # should only be one cellname = getObjectAttribute(cellObjects[0], 'name') return cellname def getCellId(cellname = None): """Return the config object ID of the cell we're connected to""" if cellname == None: cellname = getCellName() return AdminConfig.getid( '/Cell:%s/' % cellname ) def getNodeId( nodename ): """Given a node name, get its config ID""" return AdminConfig.getid( '/Cell:%s/Node:%s/' % ( getCellName(), nodename ) ) #endDef def getNodeVariable(nodename, varname): """Return the value of a variable for the node -- or None if no such variable or not set""" vmaps = _splitlines(AdminConfig.list('VariableMap', getNodeId(nodename))) if 0 < len(vmaps): # Tolerate nodes with no such maps, for example, IHS nodes. map_id = vmaps[-1] # get last one entries = AdminConfig.showAttribute(map_id, 'entries') # this is a string '[(entry) (entry)]' entries = entries[1:-1].split(' ') for e in entries: name = AdminConfig.showAttribute(e,'symbolicName') value = AdminConfig.showAttribute(e,'value') if name == varname: return value return None #endDef def removeWebSphereVariable ( name, nodeName=None, serverName=None, clusterName=None ): """Removes a VariableSubstitutionEntry at the specified scope""" map = getVariableMap(nodeName, serverName, clusterName) findAndRemove('VariableSubstitutionEntry', [['symbolicName', name]], map) #endDef def getWasInstallRoot(nodename): """Return the absolute path of the given node's WebSphere installation""" return getNodeVariable(nodename, "WAS_INSTALL_ROOT") def setJvmProperty(nodename,servername,propertyname,value): """Set a particular JVM property for the named server. Some useful examples: 'maximumHeapSize': 512 , 'initialHeapSize':512, 'verboseModeGarbageCollection':"true", 'genericJvmArguments':"-Xgcpolicy:gencon -Xdump:heap:events=user -Xgc:noAdaptiveTenure,tenureAge=8,stdGlobalCompactToSatisfyAllocate -Xconcurrentlevel1 -Xtgc:parallel", """ jvm = getServerJvm(nodename,servername) print '--------------------------------------------------' print 'Current value for property: %s is:' % propertyname currentValue = AdminConfig.showAttribute(jvm, propertyname) print currentValue print ' ' toChange = value # if (propertyname == 'genericJvmArguments'): # toChange = currentValue + " " + toChange print 'Setting new value: %s' % toChange print '--------------------------------------------------' AdminConfig.modify(jvm, [[propertyname, toChange]]) def getServerJvm(nodename,servername): """Return the config ID of the JVM object for this server""" server_id = getServerId(nodename,servername) # the pdefs come back as a string [item item item] pdefs = _splitlist(AdminConfig.showAttribute(server_id, 'processDefinitions')) pdef = None for p in pdefs: if -1 != p.find("JavaProcessDef"): pdef = p break if pdef: # found Java ProcessDef return _splitlist(AdminConfig.showAttribute(pdef, 'jvmEntries'))[0] def getServerId(nodename,servername): """Return the config id for a server or proxy. Could be an app server or proxy server, etc""" id = getObjectByNodeAndName(nodename, "Server", servername) # app server if id == None: id = getObjectByNodeAndName(nodename, "ProxyServer", servername) return id def getObjectByNodeAndName( nodename, typename, objectname ): """Get the config object ID of an object based on its node, type, and name""" # This version of getObjectByName distinguishes by node, # which should disambiguate some things... node_id = getNodeId(nodename) all = _splitlines(AdminConfig.list( typename, node_id )) result = None for obj in all: name = AdminConfig.showAttribute( obj, 'name' ) if name == objectname: if result != None: raise "FOUND more than one %s with name %s" % ( typename, objectname ) result = obj return result def startApplication ( nodeName, serverName, appName ): print 'Obtaining appManager' appMgrID = AdminControl.queryNames("type=ApplicationManager,node="+nodeName+",process="+serverName+",*" ) length = len(appMgrID) if (length >= 1): stopped = "" try: print 'Attempting to start application...' stopped = AdminControl.invoke(appMgrID, "startApplication", appName ) except Exception, e: print 'Unable to start application' + appName #print str(e) #endTry #endDef def setServerPort( nodename, servername, endPointName, port, hostname = None ): """Change a named port number on a server. E.g. setServerPort('xxxNode', 'proxy1', 'SIP_DEFAULTHOST', 5678). Also changes the hostname. If hostname is None, sets it to "*" (all hosts) """ sop('', 'Starting port change') # First see if port number is in use already specialEndPoint = findSpecialEndPoint(nodename = nodename, servername = servername, port = port) sop('', 'Checking if port is already in use : %s' % specialEndPoint) if specialEndPoint: name = AdminConfig.showAttribute(specialEndPoint, "endPointName") if name != endPointName: # DUP! raise Exception("ERROR: node %s, server %s: trying to set endpoint %s to port number %d, but endpoint %s is already using that port" % (nodename,servername,endPointName,port,name)) ePoint = getEndPoint( nodename = nodename, servername = servername, endPointName = endPointName) if ePoint == None: raise Exception("COULD NOT FIND END POINT %s" % endPointName) AdminConfig.modify( ePoint, [['port', "%d"%port]] ) if hostname == None: AdminConfig.modify( ePoint, [['host', '*']] ) else: AdminConfig.modify( ePoint, [['host', hostname]] ) print 'Port %s was changed to %s for server %s on node %s' % (endPointName, port, servername, nodename) def findSpecialEndPoint( nodename, servername, port ): """Return endPoint object config ID""" node_id = getNodeId(nodename) if node_id == None: raise "Could not find node: name=%s" % nodename server_id = getServerId(nodename, servername) if server_id == None: raise "Could not find server: node=%s name=%s" % (nodename,servername) serverEntries = _splitlines(AdminConfig.list( 'ServerEntry', node_id )) serverName = AdminConfig.showAttribute( server_id, "name" ) for serverEntry in serverEntries: #print "serverEntry: %s" % serverEntry sName = AdminConfig.showAttribute( serverEntry, "serverName" ) #print "looking at server %s" % sName if sName == serverName: specialEndPoints = AdminConfig.showAttribute( serverEntry, "specialEndpoints" ) # that returned a string like [ep1 ep2 ep3], sigh - strip the # [] and split on ' ' specialEndPoints = specialEndPoints[1:len( specialEndPoints )-1].split( " " ) #print "specialEndPoints=%s" % repr(specialEndPoints) for specialEndPoint in specialEndPoints: endPoint = AdminConfig.showAttribute(specialEndPoint, "endPoint") portnum = int(AdminConfig.showAttribute(endPoint, "port")) if portnum == port: return specialEndPoint #print "COULD NOT FIND END POINT '%s' on server %s" % ( endPointName, serverName ) return None def getEndPoint( nodename, servername, endPointName): """Find an endpoint on a given server with the given endpoint name and return endPoint object config ID""" node_id = getNodeId(nodename) if node_id == None: raise "Could not find node: name=%s" % nodename server_id = getServerId(nodename, servername) if server_id == None: raise "Could not find server: node=%s name=%s" % (nodename,servername) serverEntries = _splitlines(AdminConfig.list( 'ServerEntry', node_id )) serverName = AdminConfig.showAttribute( server_id, "name" ) for serverEntry in serverEntries: #print "serverEntry: %s" % serverEntry sName = AdminConfig.showAttribute( serverEntry, "serverName" ) #print "looking at server %s" % sName if sName == serverName: specialEndPoints = AdminConfig.showAttribute( serverEntry, "specialEndpoints" ) # that returned a string like [ep1 ep2 ep3], sigh - strip the # [] and split on ' ' specialEndPoints = specialEndPoints[1:len( specialEndPoints )-1].split( " " ) #print "specialEndPoints=%s" % repr(specialEndPoints) for specialEndPoint in specialEndPoints: endPointNm = AdminConfig.showAttribute( specialEndPoint, "endPointName" ) #print "endPointNm=%s" % endPointNm if endPointNm == endPointName: #print "serverEntry = %s" % serverEntry return AdminConfig.showAttribute( specialEndPoint, "endPoint" ) # Don't complain - caller might anticipate this and handle it #print "COULD NOT FIND END POINT '%s' on server %s" % ( endPointName, serverName ) return None def setWarClassLoaderPolicy(applicationName, policyType): m = "setWarClassLoaderPolicy: " applicationId = AdminConfig.getid("/Deployment:%s/" % applicationName) deployedObject = AdminConfig.showAttribute(applicationId, "deployedObject") print 'Getting current class loader policy...' AdminConfig.show(deployedObject, 'warClassLoaderPolicy') print 'Setting policyType to: %s' % policyType AdminConfig.modify(deployedObject, [['warClassLoaderPolicy', policyType]]) AdminConfig.save() print 'ClassLoader policy changed' #endDef def getWebModule(config, applicationName): webModules = _splitlines(config.list('WebModuleDeployment')) for webModule in webModules: if (webModule.find(applicationName) != -1): return webModule return None #endDef def setApplicationClassLoaderOrder(applicationName, order): print 'Current application is %s' % applicationName applicationId = AdminConfig.getid("/Deployment:%s/" % applicationName) deployedObject = AdminConfig.showAttribute(applicationId, "deployedObject") print 'Setting class loader to %s' % order classldr = AdminConfig.showAttribute(deployedObject, 'classloader') AdminConfig.modify(classldr, [['mode', order]]) print 'Operation completed.' AdminConfig.save() #endDef def getServerPort( nodename, servername, endPointName ): """Return port number for the given endpoint. e.g. getServerHostnamePort(node_id, server_id, 'SIP_DEFAULTHOST')""" return getServerHostnamePort(nodename,servername,endPointName)[1] #endDef def getServerHostnamePort( nodename, servername, endPointName ): """Return [host,portnum] for the given endpoint. e.g. getServerHostnamePort(node_id, server_id, 'SIP_DEFAULTHOST')""" ePoint = getEndPoint(nodename = nodename, servername = servername, endPointName = endPointName ) if ePoint == None: raise Exception("COULD NOT FIND END POINT %s" % endPointName) host = AdminConfig.showAttribute( ePoint, "host" ) port = AdminConfig.showAttribute( ePoint, "port" ) return ( host, port ) #endDef def listAllServerPorts(nodeName, serverName): import java.lang.System as sys lineSeparator = sys.getProperty('line.separator') print "============================================" print "SERVER %s on NODE %s has ports:" % (serverName, nodeName) print " " portNames = [ 'BOOTSTRAP_ADDRESS', 'ORB_LISTENER_ADDRESS', 'SIB_ENDPOINT_ADDRESS', 'WC_adminhost', 'WC_defaulthost' ] for portName in portNames: print " > " + portName + ':' + getServerPort(nodeName, serverName, portName) print "============================================" #endDef def setSecurityProperty ( propName, propValue ): global AdminConfig print "Setting Security property" print "Locating security configuration IDs ..." security = AdminConfig.list("Security" ) print "Locating the configuration IDs of all the properties in that security system ..." props = AdminConfig.showAttribute(security, "properties" ) properties = props[1:len(props)-1].split(" ") print "Locating the property named "+propName+" ..." for property in properties: name = AdminConfig.showAttribute(property, "name" ) if (propName == name): prop = property print "Found it!" #endIf #endFor if (prop == ""): print "No property named "+`propName`+" could be found! Nothing to do!" else: print "Setting the value of the "+`propName`+" property to "+`propValue`+" ..." value = ["value", propValue] attrs = [value] AdminConfig.modify(prop, attrs ) print "Done!" #endElse #endDef def addConnectionFactoryToResourceAdapter(applicationName, factoryName, factoryJndiName): deployments = AdminConfig.getid("/Deployment:%s/" % applicationName ) print 'Retreived Deployment for application: %s' % applicationName deploymentObject = AdminConfig.showAttribute(deployments, 'deployedObject') print 'Retreived ID for application: %s' % applicationName print 'Fetching modules from application...' modules = AdminConfig.showAttribute(deploymentObject, 'modules') arrayModules = modules.replace('["', '').replace('"]', '').split('" "') print 'Modules fetched. Searching for resource adapters...' for module in arrayModules: if module.find('ConnectorModuleDeployment') != -1: print 'Found resource adapter: %s' % module resourceAdapter = AdminConfig.showAttribute( module, 'resourceAdapter') print 'Found ID for resourceAdapter: %s' % resourceAdapter name = ['name', factoryName] jndiName = ['jndiName', factoryJndiName] attributes = [name, jndiName] j2cConnectionFactory = AdminConfig.create('J2CConnectionFactory', resourceAdapter, attributes) print 'Created factory id: %s' % j2cConnectionFactory AdminConfig.save() print 'Connection Factory %s with jndiName %s successfully created for application %s' % (factoryName, factoryJndiName, applicationName) return j2cConnectionFactory #endDef def setJ2eeResourceProperty ( parent, propName, propType, propValue, propDescription ): """Sets a J2EEResourceProperty on the object specified by parent; parent must have a PropertySet child attribute named 'propertySet'""" attrs = [] attrs.append( [ 'name', propName ] ) attrs.append( [ 'type', propType ] ) attrs.append( [ 'value', propValue ] ) attrs.append( [ 'description', propDescription ] ) propSet = getObjectAttribute(parent, 'propertySet') removeAndCreate('J2EEResourceProperty', propSet, attrs, ['name']) def createServer( nodename, servername, templatename = None, extraArgs = None ): """Create new app server, return its object id. Specify a templatename of 'DeveloperServer' for a development server. Specify extraArgs as a String in the format '-arg1 value1 -arg2 value2'. These will be appended to the AdminTask.createApplicationServer call.""" # Append specified args to servername arg args = ['-name %s' % (servername)] if templatename: args.append('-templateName %s' % (templatename)) if extraArgs: args.append(extraArgs) print 'Sending create request to deployment manager' AdminTask.createApplicationServer( nodename, '[%s]' % ( ' '.join(args) ) ) print 'Server created. Validating..' return getServerByNodeAndName( nodename, servername ) #endDef def getServerByNodeAndName( nodename, servername ): """Return config id for a server""" return getObjectByNodeAndName( nodename, 'Server', servername ) def getObjectByNodeAndName( nodename, typename, objectname ): """Get the config object ID of an object based on its node, type, and name""" # This version of getObjectByName distinguishes by node, # which should disambiguate some things... node_id = getNodeId(nodename) all = _splitlines(AdminConfig.list( typename, node_id )) result = None for obj in all: name = AdminConfig.showAttribute( obj, 'name' ) if name == objectname: if result != None: raise "FOUND more than one %s with name %s" % ( typename, objectname ) result = obj return result def createServerIfNotExist(nodeName, serverName): checkServer = getServerByNodeAndName(nodeName, serverName) if (checkServer == None): print 'Server %s on node %s was not found. Creating new...' % (serverName, nodeName) createServer(nodeName, serverName, None, None) AdminConfig.save() print 'Server successfully created.' else: print 'Server %s on node %s already exists. Continuing installation...' % (serverName, nodeName) #endDef def modifyDataSourceCustomProperty(cellName, serverName, dataSourceName): dataSourceList = AdminConfig.list('DataSource').splitlines() for dataSource in dataSourceList: if contains(dataSource, dataSourceName + '(') != 0: print 'Found datasource %s' % dataSource print 'Setting properties...' setJ2eeResourceProperty ( dataSource , "transactionBranchesLooselyCoupled", "java.lang.Boolean", "true", "This property is introduced as a result of Oraclebug 2511780, Oracle Patch for 2511780 must be installed before setting this property to true, failure to do that would cause a program error. Please check the WebSphere readme file for more info ." ) #endDef def createVirtualHost(virtualhostname, templatename="default_host"): """Create a virtual host and return its ID. templatename might be e.g. "default_host" """ m = "createVirtualHost:" sop(m,"virtualhostname=%s templatename=%s" % (virtualhostname,templatename)) x = AdminConfig.listTemplates('VirtualHost') sop(m,"x=%s" % repr(x)) templates = _splitlines(x) sop(m,"templates=%s" % repr(templates)) # templates look like 'default_host(templates/default:virtualhosts.xml#VirtualHost_1)' template_id = None for t in templates: if t.startswith(templatename + "("): template_id = t break if template_id == None: raise "Cannot locate VirtualHost template named %s" % templatename sop(m,"template_id = %s" % template_id) return AdminConfig.createUsingTemplate('VirtualHost', getCellId(getCellName()), [['name', virtualhostname]], template_id) #endDef def getVirtualHostByName( virtualhostname ): """Return the id of the named VirtualHost""" hosts = AdminConfig.list( 'VirtualHost' ) hostlist = _splitlines(hosts) for host_id in hostlist: name = AdminConfig.showAttribute( host_id, "name" ) if name == virtualhostname: return host_id return None def hostAliasExists( virtualhostname, aliashostname, port ): """Return true if the specified host alias already exists""" host_id = getVirtualHostByName( virtualhostname ) if host_id == None: return 0 # can't exist, no such virtual host port = "%d" % int(port) # force port to be a string aliases = AdminConfig.showAttribute( host_id, 'aliases' ) #sop(m,"aliases=%s" % ( repr(aliases) )) aliases = aliases[1:-1].split( ' ' ) #sop(m,"after split, aliases=%s" % ( repr(aliases) )) for alias in aliases: #sop(m,"alias=%s" % ( repr(alias) )) if alias != None and alias != '': # Alias is a HostAlias object h = AdminConfig.showAttribute( alias, 'hostname' ) p = AdminConfig.showAttribute( alias, 'port' ) if ( aliashostname, port ) == ( h, p ): # We're good - found what we need return 1 return 0 #endDef def addHostAlias( virtualhostname, aliashostname, port ): """Add new host alias""" # Force port to be a string - could be string or int on input port = "%d" % int( port ) print "adding host alias on %s: %s %s" % (virtualhostname, aliashostname, port) host_id = getVirtualHostByName(virtualhostname) if host_id == None: host_id = createVirtualHost(virtualhostname) new_alias = AdminConfig.create( 'HostAlias', host_id, [['hostname', aliashostname], ['port', port]] ) print "alias added for virtualhost %s hostname %s port %s" % (virtualhostname,aliashostname,port) configured_port = getObjectAttribute(new_alias, 'port') if configured_port != port: raise "ERROR: requested host alias port %s but got %s" % (port,configured_port) else: print "wsadmin says the configured port is %s" % configured_port if not hostAliasExists(virtualhostname, aliashostname, port): raise "ERROR: host alias does not exist after creating it" #endDef def deleteServerByNodeAndName ( nodename, servername ): """Delete the named server - raises exception on error""" sid = getServerByNodeAndName( nodename, servername ) if not sid: raise "Could not find server %s to delete" % servername AdminTask.deleteServer( '[-serverName %s -nodeName %s ]' % ( servername, nodename ) ) #endDef def deleteVirtualHost( virtualHostName): print 'Attempting to remove virtual host %s ' % virtualHostName virtualHost = AdminConfig.getid("/VirtualHost:%s/" % virtualHostName) if len(virtualHost) > 1: AdminConfig.remove(virtualHost) print 'Virtual Host %s successfully removed.' % virtualHostName else: print 'Virtual Host %s not found ' % virtualHostName #endDef def setCustomPropertyOnObject(object_id, propname, propvalue): propSet = _splitlines(AdminConfig.showAttribute(object_id, 'propertySet')) print AdminConfig.required('J2EEResourceProperty') for prop in propSet: name = AdminConfig.showAttribute(prop, 'name') if name == propname: print 'name=name' AdminConfig.remove(prop) name = ['name', propname] value = ['value', propvalue] rpAttrs = [name, value] print AdminConfig.modify('J2EEResourceProperty', propSet, rpAttrs) AdminConfig.save() #AdminConfig.modify(object_id, [['properties', [[['name', propname], ['value', propvalue]]]]]) #endDef def getObjectCustomProperty(object_id, propertiesType, propname): """Return the VALUE of the specified custom property of the server, or None if there is none by that name. This is to be used only on objects that store their custom properties as a list of Property objects in their 'properties' attribute. This includes, for example, application servers and SIP containers. There are other objects that store J2EEResourceProperty objects instead; don't use this for those. Intended for private use within wsadminlib only. Write wrappers to be called externally. """ x = AdminConfig.showAttribute(object_id, propertiesType)[1:-1] if len(x) == 0: return None # no properties set yet #print "value of properties attribute=%s" % x # This can be of the format "[foo(value) bar(baz)]" where the values are "foo(value)", # "bar(baz)". It also seems to be able to be just "foo(value)" # FIXME: should we use _splitlist here? If so, we need to change it to work when no [] are given if x.startswith("["): propsidlist = x[1:-1].split(' ') else: propsidlist = [x] #print "List of properties = %s" % repr(propsidlist) for id in propsidlist: #print "id=%s" % id name = AdminConfig.showAttribute(id, 'name') if name == propname: return AdminConfig.showAttribute(id, 'value') return None def loadResourceAdapterDefinitions(regdbFile, applicationName): import fileinput resourceAdapterProperties = ['contextFactory', 'dbHost', 'dbName', 'licenseType', 'password', 'providerUrl', 'user'] for line in fileinput.input([regdbFile]): if (line.startswith('#') == False and len(line) > 2): j2cParams = line.strip().split(';') # We expect, that it will be exactly 9 parameters if len(j2cParams) == 9: print 'Found valid record to insert:' for j2cParam in j2cParams: print ' > ' + j2cParam print 'Inserting resource adapter with name="%s" and jndiname="%s"' % (j2cParams[0], j2cParams[1]) resourceAdapter = addConnectionFactoryToResourceAdapter(applicationName, j2cParams[0], j2cParams[1]) print 'Adding custom properties to resource adapter' for i in range (2, len(j2cParams)): print 'Inserting custom property "%s" with value "%s"' % (resourceAdapterProperties[i-2], j2cParams[i]) setJ2eeResourceProperty ( resourceAdapter, resourceAdapterProperties[i-2], "java.lang.String", j2cParams[i], resourceAdapterProperties[i-2] ) print 'Resource adapter properties upload completed' #endDef