import com.wm.data.*;
import com.wm.util.Values;
import com.wm.app.b2b.server.Service;
import com.wm.app.b2b.server.ServiceException;
import com.softwareag.util.IDataMap;
import java.util.Properties;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Iterator;
import java.util.List;
import java.sql.*;

public final class connect_SVC

{


	public static final void connect(IData pipeline) throws ServiceException {
		 Connection jdbcConnection = null;
		 String retunValue = "";
		try {
			  
			 Class.forName("com.mysql.jdbc.Driver");
			 jdbcConnection = DriverManager.getConnection("jdbc:mysql://localhost:3306/sakila","root","password"); 
			
			 
			 if (jdbcConnection != null) {				 
				 retunValue="got connection!"; 
				 
				} else {
					retunValue="Failed to make connection!";
				}
			 
			
			
		}
		catch (Exception e) {
			throw (ServiceException) new ServiceException(e.toString()).initCause(e);
		}
		
		IDataCursor pipelineCursor_1 = pipeline.getCursor();
		IDataUtil.put( pipelineCursor_1, "jdbcConnection", jdbcConnection);
		IDataUtil.put( pipelineCursor_1, "retunValue", retunValue );
		pipelineCursor_1.destroy();
			
	}