Java World Knowledge Sharing Portal: 2018

Friday, November 30, 2018

Creating custom Pipe and Directive in AngularJS6

1- Create your custom pipe using command ng g p change
2- This will create a change.pipe.ts and make its corresponding entries in module.ts file inside declarations[]
3- We can over ride transform(value: any, ...args) to perform our custom behaviour by implementing pipe
transform(value: any, ...args): any {
console.log(value, args);
if(args[0])
{
return value = value + 'first value is ture';
}
else if(args[1] === "singlequote")
{
return value = value + "'";
}
else{
return value;
}

}
4- In html file
{{"this is formated with custom pipes" | change : true : "singlequote"}}
1- Create your custom directive using command ng g d siddhucustome
2- Override the constructor
@Directive({
selector: '[appSiddhucustome]'
})
export class SiddhucustomeDirective {
constructor(eL: ElementRef) {
eL.nativeElement.style.color = 'green';
eL.nativeElement.style.background = 'black';
}
}
3- In html
<!--p appSiddhucustome>
this is custome directive example.
<!--/p>

Wednesday, November 28, 2018

How to use Route Guard

Route Guard :- this is the concept in AngularJS which allows the developer to fix/assist Guard on the router. i.e. This Guard will first check if the user is access right to route if yes then he will be allowed to go to that url else we can take action agains it.
Lets try to understand using exmple
Step 1- Let s first create guard using ng command i.e. ng generate guard Auth or ng g g auth
Step 2- we will find following file create in our project
import { AuthService } from './auth.service';
import { Injectable } from '@angular/core';
import { CanActivate, ActivatedRouteSnapshot, RouterStateSnapshot } from '@angular/router';
import { Observable } from 'rxjs';
@Injectable({
providedIn: 'root'
})
export class AuthGuard implements CanActivate {
public flag : boolean;
constructor()
{
}
canActivate(
next: ActivatedRouteSnapshot,
state: RouterStateSnapshot): Observable<boolean> | Promise<boolean> | boolean {
return true;
}
}
Step 3- configure this in our app.module.ts
providers: [ AuthService, AuthGuard],
{
path:'admin',
component:AdminComponent,
canActivate: [AuthGuard]
},
Step 4- as we can see this Guard return true so we can access /admin url by both the way i.e. using direct hit http://localhost:4200/admin or by going through programatically.
Now let see if we only want the user to get it access through programitically and not by direct hit to url i.e. http://localhost:4200/admin
To do this we had done following changes
1- On successful call to Service.ts we call this method of Auth.Guard.ts
this.myAuth.setFlagValue(true);
2- In AuthGuard.ts we have added following this method
setFlagValue(value : boolean)
{
this.flag = value;
}
and canActivate(
next: ActivatedRouteSnapshot,
state: RouterStateSnapshot): Observable<boolean> | Promise<boolean> | boolean {
//return true;
return this.flag;
}

So now when we go through programe we will be able to go to /admin url else when we hit the direct url we fails.

Note:- Code is available at
https://github.com/shdhumale/AJS6_Tutorial_Project.git

Tuesday, November 27, 2018

How to configure GIT in Visual Source Code for AJS6

Step 1:- Create your Repository on GItHiub https://github.com and take its *.git url.

Step 2:- Clone that repository
2.1 - using Torpoise GIT (As I am using Window) or
2.2 - you can use the Ctr + Shift+P and Git:clone command to create a clone directly from VSC. Our project name in GIT is AJS6_Tutorial_Project.git.

Step 3:- Now create AJS6 dummy project using command ng new my-app
i.e.
C:\VSC_WorkSpace_Angular6\AJS6_Tutorial_Project>npm install -g @angular/cli
C:\VSC_WorkSpace_Angular6\AJS6_Tutorial_Project>ng new my-app

Step 4:- Now import this folder inside your VSC and you will find all the items need to be check in empty repository

Step 5:- Start development and perform check in / check out option using VSC.

How to do proxy configuration in AngularJS project

1- In package.json change the start

"start": "ng serve --proxy-config proxyconfig.json",

2- Create one file called as proxyconfig.json

{
"/api":{
"target":"http://localhost:2303/",
"secure":false,
"changeOrigin":true
}
}

3- In serive now instead of calling whole url i.e. http://localhost:2303 use this one /api
return this.myHtpClient.get('/api');

4- do npm start or ng serve one more time

Note: If you see the chrome F12 network we will find the URL that is displayed to the end user is http://localhost:4200 rather than http://localhost:2303. This is the way we can do proxy configuration.

HTTP REST call using AngularJS6

1- We need to first import HttpClientModule in app.module.ts
import { HttpClientModule} from '@angular/common/http';
imports: [
BrowserModule,
AppRoutingModule,
FormsModule,
HttpClientModule
],
2- In service use import HttpClient

import { HttpClient} from '@angular/common/http';

and use below code to call Rest Service
return this.myHtpClient.get('http://localhost:2303/');
3- Calling above service from our Ts file
constructor(private myService : RecordService) {

}
ngOnInit() {
this.myService.getData().subscribe(data => {
//this will populate data on the screen.
this.myArrayData = data;
});
}

Note: You can download the code from belwo given git
https://github.com/shdhumale/AngularJS6.git
SOAP to expose Rest Service
Please add Access-Control-Allow-Origin *
SOAP

Monday, November 26, 2018

How to set AngularJS debug in Visual source Code

1- Install NodeJs and NPM from respective site
NodeJS = https://nodejs.org/en/download/
NPM = https://www.npmjs.com/get-npm
After installation make sure to both are installed properly using node -v and npm -v command
2- Create your first AngularJS project using following link
https://angular.io/guide/quickstart
3- Install Debugger for Chrome using visual source code
use Ctrl + Shift +X or simply click on the left icon and type "Debugger for Chrome" and install the plugin

3- Configure chrome in your debug setting using below image

4- Put your debug pointer and Start your application using ng serve and start debuging using F5 or start debug command and you will be able to debug the application live on visual source code.

Monday, October 29, 2018

how to do Masking of text field in AngularJS for phone number

Step 1:- Install ngx-mast using below site
https://www.npmjs.com/package/ngx-mask
Step 2:- Run follwing npm command to install
npm install --save ngx-mask
Step 3:- Import the same in your app.modules.ts
import {NgxMaskModule} from 'ngx-mask'
@NgModule({
(...)
imports: [
NgxMaskModule.forRoot()
]
(...)
})
Step4: Finnaly add the text in your application html file
<input type='text' prefix="+7 " mask="(000) 000 00 00" >
or
<input type='text' prefix="(7 " mask="00) 000 00 00" >

Sunday, October 21, 2018

How to add custom user in OpenDJ

Step 1:- Open the control-panel.bat from C:\OpenDJ\bat>control-panel.bat

Right click on cn=admin-data and add user as shown in the belwo screen

Now lets add new user in this new organization unit

Note: you can also used the Apache Directory Studio to check if the user created properly
- First create connection
- right click on search and click ok
- You will be able to see the screen

Friday, October 19, 2018

Setting OpenDJ ldap

Step 1- Down load required package from https://github.com/OpenIdentityPlatform/OpenDJ/
or https://github.com/OpenIdentityPlatform/OpenDJ/releases
Step 2:- Run the download msi file and installed in perticular folder i.e. C:\OpenDJ
Step 3:- Run setup.bat from C:\OpenDJ and follow the step provided in it.

If we want to open the control panel of OpenDJ click on Launch Control panel
Once it is set up we can use this command to start and stop the LDAP server
C:\OpenDJ\bin\start-ds.bat
C:\OpenDJ\bin\stop-ds.bat

Step 4:- To confirm the LDAP installation make sure to install
https://directory.apache.org/studio/
and connect using option
LDAP--> New Connection

Monday, October 15, 2018

Spring Transaction example

Many times we need to implements programitically Transaction to adhere to ACID=Atomicity, consistance, Isolation and Durability.
JAVA comes with JTA=Java transection API where in we are using explicitly begin and end key word to start and end the DB trasactions.
If we are using Spring Frame work it provide inbuild Transaction SPI with spring-tx.*.*.jar. We just need to add this jar in our class path and can use their api to achieve ACID for our application.
below is the code
1-POM.xml











<!--bean id="dataSource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<!--property name="driverClassName" value="com.mysql.jdbc.Driver" />
<!--property name="url" value="jdbc:mysql://localhost:3306/vscrum" />
<!--property name="username" value="siddhu" />
<!--property name="password" value="siddhu" />
<!--/bean>
<!--bean id="siddhuDAO" class="com.siddhu.dao.SiddhuDAOImpl">
<!--property name="dataSource" ref="dataSource"><!--/property>
<!--/bean>
<!--bean id="siddhuManager" class="com.siddhu.service.SiddhuManagerImpl">
<!--property name="siddhuDAO" ref="siddhuDAO"><!--/property>
<!--/bean>
<!--/beans>
3-MainTransaction
package com.siddhu.main;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.siddhu.model.AddressInfo;
import com.siddhu.model.CustomerInfo;
import com.siddhu.service.SiddhuManager;
import com.siddhu.service.SiddhuManagerImpl;
public class MainTransaction {
public static void main(String[] args) {
ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(
"spring.xml");
SiddhuManager siddhuManager = ctx.getBean("siddhuManager",
SiddhuManagerImpl.class);
CustomerInfo cust = createCustomer();
siddhuManager.createCustomer(cust);
ctx.close();
}
private static CustomerInfo createCustomer() {
CustomerInfo customerInfo = new CustomerInfo();
customerInfo.setId(1);
customerInfo.setName("Siddhu");
AddressInfo addressInfo = new AddressInfo();
addressInfo.setId(1);
// trying to save proper value in DB.
addressInfo.setAddress("Address1");
// trying to save proper value in DB.
//addressInfo.setAddress("BIG Address 11111111111111111111111111111111111111111111111111111");
customerInfo.setAddress(addressInfo);
return customerInfo;
}
}
4- SiddhuDAO
package com.siddhu.dao;
import com.siddhu.model.CustomerInfo;
public interface SiddhuDAO {
public void create(CustomerInfo customer);
}
5- SiddhuDAOImpl
package com.siddhu.dao;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import com.siddhu.model.CustomerInfo;
public class SiddhuDAOImpl implements SiddhuDAO {
private DataSource dataSource;
public void setDataSource(DataSource dataSource) {
this.dataSource = dataSource;
}
@Override
public void create(CustomerInfo customer) {
String queryCustomer = "insert into CustomerInfo (id, name) values (?,?)";
String queryAddress = "insert into AddressInfo (id, address) values (?,?)";
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.update(queryCustomer, new Object[] { customer.getId(),
customer.getName() });
System.out.println("Inserted into Customer Table Successfully");
jdbcTemplate.update(queryAddress, new Object[] { customer.getId(),
customer.getAddress().getAddress()});
System.out.println("Inserted into Address Table Successfully");
}
}

6- AddressInfo
package com.siddhu.model;
public class AddressInfo {
private int id;
private String address;

public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}

}
7- CustomerInfo
package com.siddhu.model;
public class CustomerInfo {
private int id;
private String name;
private AddressInfo address;

public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public AddressInfo getAddress() {
return address;
}
public void setAddress(AddressInfo address) {
this.address = address;
}

}
8- SiddhuManager
package com.siddhu.service;
import com.siddhu.model.CustomerInfo;
public interface SiddhuManager {

public void createCustomer(CustomerInfo custInfo);
}
9- SiddhuManagerImpl
package com.siddhu.service;
import org.springframework.transaction.annotation.Transactional;
import com.siddhu.dao.SiddhuDAO;
import com.siddhu.model.CustomerInfo;
public class SiddhuManagerImpl implements SiddhuManager {
private SiddhuDAO siddhuDAO;
public void setSiddhuDAO(SiddhuDAO siddhuDAO) {
this.siddhuDAO = siddhuDAO;
}
@Override
@Transactional
public void createCustomer(CustomerInfo custInfo) {
siddhuDAO.create(custInfo);
}
}

Now lets try to understand how the flow goes
MainTransaction is our main class. First by using Spring context we load our spring.xml and try to get the singleton bean with name siddhuManager i.e. SiddhuManager
Then we load/fill data inside our model class CustomerInfo and AddressInfo
After that we call createCustomer method of our bean class SiddhuManagerImpl.
Finally this createCustomer method call our *DAOimpl class to insert the data in two table i.e. CustomerInfo and AddressInfo.
Step 1:- First we will insert normal data and will check if the data is inserted into both the table properly.
Note: I am using MySQL as DB if you are using Oracle please make necessary changes in spring.xml

Check both the table and we will find 1 row inserted into both the table successfully
Now lets try to run the main method with large value of address i..e greater than 45 character. This will fail in inserting the data in AddressInfo table and due to implementation of Transaction it will also roll back CustomerInfo table data.

No data is inserted into AddressInfo and CustomerInfo table.
Project Structure

Note:- Through this example we will also understand how the flow work here for dependency injections
1- When we create the instance of SiddhuManagerImpl using spring it will call internally its setter method as per the property siddhuDAO to create new instace of beanid as name siddhuDAO.. which further internally called bean with id dataSource used to connect proper datasource.

Friday, September 14, 2018

How to use Apache FTP server for upload and download file

Step 1:- Down load FTP Server from below link
https://projects.apache.org/project.html?mina-ftpserver
Step 2:- You can start the using following command
C:\apache-ftpserver-1.1.1\apache-ftpserver-1.1.1\bin>ftpd.bat
Using default configuration
FtpServer started
Stopping server...
Step 3:- We are using java code to start the server at perticular port and then use below java code to do upload and download functionality

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import org.apache.commons.net.PrintCommandListener;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.ftpserver.FtpServer;
import org.apache.ftpserver.FtpServerFactory;
import org.apache.ftpserver.listener.ListenerFactory;
import org.apache.ftpserver.usermanager.PropertiesUserManagerFactory;

public class FTPFunctions {

// Creating FTP Client instance
FTPClient ftp = null;

public FTPFunctions()
{

}

public void StartServer()
{
try {
FtpServerFactory serverFactory = new FtpServerFactory();
ListenerFactory factory = new ListenerFactory();
// set the port of the listener
factory.setPort(21);
// define SSL configuration
/*SslConfigurationFactory ssl = new SslConfigurationFactory();
ssl.setKeystoreFile(new File("C:\\Test\\ftpserver.jks"));
ssl.setKeystorePassword("password");*/
// set the SSL configuration for the listener
/*factory.setSslConfiguration(ssl.createSslConfiguration());
factory.setImplicitSsl(true);*/
// replace the default listener
serverFactory.addListener("default", factory.createListener());
PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory();
userManagerFactory.setFile(new File("C:\\Test\\users.properties"));
serverFactory.setUserManager(userManagerFactory.createUserManager());
// start the server
FtpServer server = serverFactory.createServer();
server.start();
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("Exception occured ---------------------");
e.printStackTrace();
}
}

// Constructor to connect to the FTP Server
/**
* @param host
* @param port
* @param username
* @param password
* @throws Exception
*/
public FTPFunctions(String host, int port, String username, String password) throws Exception{

ftp = new FTPClient();
ftp.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));
int reply;
ftp.connect(host,port);
System.out.println("FTP URL is:"+ftp.getDefaultPort());
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect();
throw new Exception("Exception in connecting to FTP Server");
}
ftp.login(username, password);
ftp.setFileType(FTP.LOCAL_FILE_TYPE);
ftp.enterLocalPassiveMode();
}
// Method to upload the File on the FTP Server
public void uploadFTPFile(String localFileFullName, String fileName, String uploadDir)
throws Exception
{
try {
InputStream input = new FileInputStream(new File(localFileFullName));
this.ftp.storeFile(uploadDir + fileName, input);
}
catch(Exception e){
}
}

// Download the FTP File from the FTP Server
public void downloadFTPFile(String ftpSource, String destination) {
try (FileOutputStream fos = new FileOutputStream(destination)) {
this.ftp.retrieveFile(ftpSource, fos);
} catch (IOException e) {
e.printStackTrace();
}
}

// list the files in a specified directory on the FTP
public boolean listFTPFiles(String directory, String fileName) throws IOException {
// lists files and directories in the current working directory
boolean verificationFilename = false;
FTPFile[] files = ftp.listFiles(directory);
for (FTPFile file : files) {
String details = file.getName();
System.out.println(details);
if(details.equals(fileName))
{
System.out.println("Correct Filename");
verificationFilename=details.equals(fileName);
//assertTrue("Verification Failed: The filename is not updated at the CDN end.",details.equals(fileName));
}
}

return verificationFilename;
}

// Disconnect the connection to FTP
public void disconnect(){
if (this.ftp.isConnected()) {
try {
this.ftp.logout();
this.ftp.disconnect();
} catch (IOException f) {
// do nothing as file is already saved to server
}
}
}

// Main method to invoke the above methods
public static void main(String[] args) {
try {

FTPFunctions objFTPFunctions = new FTPFunctions();
objFTPFunctions.StartServer();
FTPFunctions ftpobj = new FTPFunctions("127.0.0.1", 21, "admin", "admin");
ftpobj.uploadFTPFile("C:\\Test\\siddhu.txt", "siddhuupload.txt", "/uploadftp/");
ftpobj.downloadFTPFile("/uploadftp/siddhuupload.txt","C:\\Test_New\\downloadftp\\siddhudownload.txt");
System.out.println("FTP File downloaded successfully");
//boolean result = ftpobj.listFTPFiles("C:\\Test_New\\downloadftp", "siddhu.txt");
//System.out.println(result);
ftpobj.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
}
We are starting the FTP server on localhost with 21 port and user id and password as admin admin.
Make sure you take users.properties from you C:\apache-ftpserver-1.1.1\apache-ftpserver-1.1.1\res\conf folder and place it on perticular location. This files we are using for login.
By defualt password of admin is admin

Note:First run the java program and then try to connect using FileZilla tool.

Also make sure that we need to map our local folder for FTP process as given below

ftpserver.user.admin.homedirectory=C:\\Test_New

Monday, August 13, 2018

Creating pipeline in Jenkin

Pipeline concept is well known in Devops. Pipeline can be define as the process of integration ll the aspect of devop(Build-Deploy-Test-Release) in sequential manner.
Jenkin has build in plugin call as "Delivery Pipeline Plugin" and "Build Pipeline view" which can be used in extensively manner for the same. Make sure Pipeline is wellknow in implementing CI,CD and CDI concept
CI:- Continueous Integration - Commit Code + Junit + Integration.
CDI :- Continueous Delivery - Commit Code + Junit + Integration + Deploy in Testing Env + Acceptance Testing.
CD :- Continueous Deployment- Commit Code + Junit + Integration + Deploy in Testing Env + Acceptance Testing + Deploy in production.
Lets take a small example how to build Jenikin Pipeline
Assume we have following fow jobs that need to be done before sending the deployment component in productions
1- Build the jobs
2- Deploy the jobs
3- Test the jobs
4- Release the jobs
For ease of this tutorial we are not explaining what the step you need to do in all steps i.e. Build step:- if it smaven you will need maven plugin and then configuration etc, Deploy :- You need to stop the tomcat and them depoly the war etc Test :- for Junit during maven build only we can suggest to do JUnit else trigger the external automation testing like selenium etc.
Here in our example we will keep it simple just window cmd command to execute as we are just trying to understand Jenkin Pipeline
Now lets try to create all belwo four jobs.
1- Build Job

2-Deploy Job

3- Test Job

4- Release

Now just check downstream and upstream proejct for our created jobs i.e. when we execute build job then on success it will auto trigger deploy and then it will auto trigger test and finally release jobs

Now check we have following plugin "Dilivery Pipeline Plugin"inside
Jenkin-- > Manage Jenkin -- > Manage Plugin -->Installed
If this plugin is not present then go to "Available" tab and installed the same.
Once you installed the Plugin then create a new view as given below
Jenkin --> New View
Now when you run our Build Job then open this newly created View and you will be able to see bekow screen.

Java World Knowledge Sharing Portal