Step 3: Now we need to create company.xml file under project- create one xml file add the below xml to that file.
siva34Male3500001/07/1983PresentBangaloreKarnatakaIndiaPermanentKadapaAndharaPradeshIndiaSanjay27Male5500001/07/1988PresentBangaloreKarnatakaIndiaPermanentHyderabadTelanganaIndiaMadhan34Male80000001/07/1983Present and PermanentBangaloreKarnatakaIndia
Step 4: Create pojo classes , which need to be parsed as per above xml.
i have created 3 classes - Company.java -> List of Employee.java -> List Of Address.java
Company.java - xmlroot elment is company which is there in xml.
package xmltofile;
import java.util.ArrayList;
import java.util.List;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
@XmlRootElement(name="company")
public class Company {
private List employee = new ArrayList();
@XmlElement(name="employee")
public List getEmployee() {
return employee;
}
public void setEmployee(List employee) {
this.employee = employee;
}
}
Employee.java
package xmltofile;
import java.util.ArrayList;
import java.util.List;
import javax.xml.bind.annotation.XmlElement;
public class Employee {
private String name;
private int age;
private String gender;
private Double salary;
private String dob;
Listaddress = new ArrayList();
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getGender() {
return gender;
}
public void setGender(String gender) {
this.gender = gender;
}
public Double getSalary() {
return salary;
}
public void setSalary(Double salary) {
this.salary = salary;
}
@XmlElement
public ListgetAddress() {
return address;
}
public void setAddress(Listaddress) {
this.address = address;
}
public String getDob() {
return dob;
}
public void setDob(String dob) {
this.dob = dob;
}
}
Address.java
package xmltofile;
import javax.xml.bind.annotation.XmlRootElement;
public class Address {
private String city;
private String type;
private String state;
private String country;
public String getCity() {
return city;
}
public void setCity(String city) {
this.city = city;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public String getState() {
return state;
}
public void setState(String state) {
this.state = state;
}
public String getCountry() {
return country;
}
public void setCountry(String country) {
this.country = country;
}
}
Step 6: Now we need to write test class to Parse the employee.xml using JAXB context and create the Flat file
and write the xml data into file at specified index.
XMLReaderAndWriteToFile.java
package xmltofile;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import javax.xml.bind.JAXBContext;
import javax.xml.bind.Unmarshaller;
import com.ancientprogramming.fixedformat4j.format.FixedFormatManager;
import com.ancientprogramming.fixedformat4j.format.impl.FixedFormatManagerImpl;
import xmltofile.fixedformat.CompanyHeader;
import xmltofile.fixedformat.EmployeeHeader;
public class XMLReaderAndWriteToFile {
public static void main(String[] args) {
BufferedWriter bw = null;
try {
JAXBContext context = JAXBContext.newInstance(Company.class);
// Create Unmarshaller using JAXB context
Unmarshaller unmarshaller = context.createUnmarshaller();
System.out.println("xml file started to load...");
Company company = (Company) unmarshaller.unmarshal(new File("employee.xml"));
System.out.println("xml file loaded and parsed successfully..");
// Write to file with fixedformat
System.out.println("Flat file started to create...");
bw = new BufferedWriter(new FileWriter("fixedLength.txt", true));
System.out.println("empty flat file created...");
getCompanyHeader(bw);
System.out.println("company header written successfully to file.");
getEmployeeHeader(bw);
System.out.println("employee header written successfully to file.");
for (Employee employee : company.getEmployee()) {
EmployeeHeader employeeDetails = new EmployeeHeader();
employeeDetails.setNameHeader(employee.getName());
employeeDetails.setAgeHeader(String.valueOf(employee.getAge()));
employeeDetails.setGenderHeader(employee.getGender());
employeeDetails.setDobHeader(String.valueOf(employee.getDob()));
employeeDetails.setSalaryHeader(String.valueOf(employee.getSalary()));
String completeAddress = " ";
for (Address address : employee.getAddress()) {
String addressDetails = address.getCity() + " " + address.getState() + " " + address.getCountry()
+ " - " + address.getType();
completeAddress = completeAddress.concat(addressDetails) + " ";
}
employeeDetails.setAddressHeader(completeAddress);
FixedFormatManager manager1 = new FixedFormatManagerImpl();
String data1 = manager1.export(employeeDetails);
bw.write(data1);
bw.newLine();
}
System.out.println("Employee details written successfully to file.");
} catch (Exception ex) {
ex.printStackTrace();
} finally {
try {
bw.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
private static void getEmployeeHeader(BufferedWriter bw) throws IOException {
EmployeeHeader employeeHeader = new EmployeeHeader();
employeeHeader.setNameHeader("Employee Name");
employeeHeader.setAgeHeader("Age");
employeeHeader.setGenderHeader("Gender");
employeeHeader.setDobHeader("DOB");
employeeHeader.setSalaryHeader("Salary");
employeeHeader.setAddressHeader("Address");
FixedFormatManager manager = new FixedFormatManagerImpl();
String data = manager.export(employeeHeader);
bw.write(data);
bw.newLine();
bw.newLine();
bw.newLine();
}
private static void getCompanyHeader(BufferedWriter bw) throws IOException {
CompanyHeader companyHeader = new CompanyHeader();
companyHeader.setHeader1("ABC Company");
companyHeader.setHeader2("Bangalore");
companyHeader.setHeader3("India");
FixedFormatManager manager = new FixedFormatManagerImpl();
String data = manager.export(companyHeader);
bw.write(data);
bw.newLine();
bw.newLine();
bw.newLine();
}
}
Output file will be like this.
ABC Company Bangalore
Employee Name Age Gender Salary DOB Address
siva 34 Male 35000.0 01/07/1983 Bangalore Karnataka India - Present Kadapa AndharaPradesh India - Permanent
Sanjay 27 Male 55000.0 01/07/1988 Bangalore Karnataka India - Present Hyderabad Telangana India - Permanent
Madhan 34 Male 800000.0 01/07/1983 Bangalore Karnataka India - Present and Permanent
Thank you verymuch for viewing this post. If you like this don't forget to share.
This Post will explain , how to Deploy Spring Boot Application on Pivotal Cloud Foundry Platform
Now a days Cloud Computing and Microservice have become very popular concept and almost all the organizations are investing and adapting it very fast. Currently there are only
few popular cloud providers in the market and Pivotal Cloud Foundry is one of them. It is a PaaS(Platform AS A Servcie) service where we can easily deploy and manage our
applications and the Cloud Foundry will take care of the rest of the cloud based offerings like scalability, high availability etc.
Today we will learn to deploy spring boot application in Pivotal cloud foundry platform called as Pivotal Web Services.
Step 1: What is Cloud Foundry?
Cloud Foundry is an open-source platform as a service (PaaS) that provides you with a choice of clouds, developer frameworks, and application services. It is open source and it is governed by the Cloud Foundry Foundation. The original Cloud Foundry was developed by VMware and currently it is managed by Pivotal
Step 2: Now we need to install Cloud Foundary on Windows
Step 8: Provide necessary details and sign up the same.
Once sign up is completed, we can log into the Pivotal webservice console through the login screen of the pivotal web service console.
After providing login credentials successfully we will get into the cloud foundry console where we can see all the deployed applications, can monitor the applications and do many more activities. Here we need to add org and space etc...
Step 9: Once we have created org and space successfully.. now we need to deploy the spring boot application in PCF.
Step 10: Before that , Login in to PWS (Pivotal Webservice Console) using CLI
c:/> cf login -a api.run.pivotal.io
Provide username and password which is given , while registering the PWS.
same way we can use Logout
c:/> cf logout
Step 11: Now login and logout is working with out any issues.
Step 12: Now write simple spring boot application and run the same in locally.
If you want to write simple one follow the https://start.spring.io/ - which will create sample spring boot application for you and modify as per your requirment.
i have created one sample arthimetic operations spring boot application.. check in my previous post for the same.
add the below code into bootstrap.properties under src\main\resources
Step 19: This is how we will implement spring boot application and we can deploy the same in Pivotal Cloud Foundary.
Thank you very much for viewing this post. if you like this please share the same
If you face any issues.. write a comment and you will get reply the same
This post will explain you about , how to start pivotal Gemfire on Windows Step 1: What is Gemfire? In-Memory Data Grid powered by Apache Geode Scale your data services on demand to support high-performance, real-time apps you can check more info on Gemfire docs Step 2: Download - pivotal-gemfire-9.1.0.tar.gz using Download Pivotal Gemfire Step 3: Unzip the downloaded file and set the PATH in environement variables. Step 4: check the version of the pivotal gemfire, which is available in your system gfsh version --full Step 5: Now we need to create a locator - Go to the place which ever the location you want to create locator in command prompt. Step 6:Start the gfsh.bat file from command prompt. Step 7: start locator --name=test --J=-Dgemfire.http-service-port=8080 --J=-Dgemfire.http-service.bind-address=localhost or
gfsh>start locator --name=test --J=-Dgemfire.http-service-port=8080 --J=-Dgemfire.http-service-bind-address=LAPTOP-2U8NKC7I
Starting a Geode Locator in F:\softwares\CloudFoundary_apache_gemFire\pivotal-gemfire-9.1.0\bin\test...
.....
Locator in F:\softwares\CloudFoundary_apache_gemFire\pivotal-gemfire-9.1.0\bin\test on LAPTOP-2U8NKC7I[10334] as test is currently online.
Process ID: 11740
Uptime: 3 seconds
Geode Version: 9.1.0
Java Version: 1.8.0_131
Log File: F:\softwares\CloudFoundary_apache_gemFire\pivotal-gemfire-9.1.0\bin\test\test.log
JVM Arguments: -Dgemfire.enable-cluster-configuration=true -Dgemfire.load-cluster-configuration-from-dir=false -Dgemfire.http-service-port=8080 -Dgemfire.http-service-bind-address=LAPTOP-2U8NKC7I -Dgemfire.launcher.registerSignalHandlers=true -Djava.awt.headless=true -Dsun.rmi.dgc.server.gcInterval=9223372036854775806
Class-Path: F:\softwares\CloudFoundary_apache_gemFire\pivotal-gemfire-9.1.0\lib\geode-core-9.1.0.jar;F:\softwares\CloudFoundary_apache_gemFire\pivotal-gemfire-9.1.0\lib\geode-dependencies.jar
Successfully connected to: JMX Manager [host=LAPTOP-2U8NKC7I, port=1099]
Cluster configuration service is up and running.
gfsh>start pulse
Step 8: Open the start pulse
Step 9: Open the browser and enter port as 8080 -> http://laptop-2u8nkc7i:8080/pulse and provide username as admin and password as admin
Step 10 cluster details will display after successful login.
Thank you verymuch for viewing this post. If you like this post please write comment and share.
Step 2: Login into google cloud.
Step 3: Register Cloud application with free trail - Cloud Application Registration
Step 4:Create a new Project -
Provide necessary details and signup the same.
Step 5: Now you are completed signup process . Spring boot application needs to be deployed.
Step 6: Create a maven java project with name - helloworld-springboot and below code to pom.xml file.
4.0.0com.java.gcloud.springboothelloworld-springboot0.0.1-SNAPSHOTjarhelloworld-springbootDemo project for Spring Boot with google cloud1.8${java.version}${java.version}UTF-81.3.1org.springframework.bootspring-boot-starter-web1.5.7.RELEASEorg.springframework.bootspring-boot-maven-plugin1.5.7.RELEASErepackagecom.google.cloud.toolsappengine-maven-plugin${appengine.maven.plugin}
Step 7: Now we need to write controller class name HelloworldApplication.java
package com.java.gcloud.springboot;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
@SpringBootApplication
@RestController
public class HelloworldApplication {
@RequestMapping("/")
public String home() {
return "Hello World.. Welcome to Spring Boot.. which is deployed on Google cloud appengine!";
}
@RequestMapping(value = "/add/{a}/{b}", method = RequestMethod.GET)
public String add(@PathVariable("a") int a,@PathVariable("b") int b) {
return "Addition of a["+a+"] and b ["+b+"]is ====== " + (a+b) ;
}
@RequestMapping(value = "/substract/{a}/{b}", method = RequestMethod.GET)
public String substract(@PathVariable("a") int a,@PathVariable("b") int b) {
return "Substract of a["+a+"] and b ["+b+"]is ====== " + (a-b) ;
}
@RequestMapping(value = "/multiply/{a}/{b}", method = RequestMethod.GET)
public String multiply(@PathVariable("a") int a,@PathVariable("b") int b) {
return "Multiply of a["+a+"] and b ["+b+"]is ====== " + (a*b) ;
}
@RequestMapping(value = "/division/{a}/{b}", method = RequestMethod.GET)
public String division(@PathVariable("a") int a,@PathVariable("b") int b) {
return "Division of a["+a+"] and b ["+b+"]is ====== " + (a/b) ;
}
public static void main(String[] args) {
SpringApplication.run(HelloworldApplication.class, args);
}
}
Step 8: Run the pom.xml file using mvn clean install
Step 9: Now we need to run the application. go to the directory , where jar created and run the
java -jar
another way to execute the application is right click on the HelloWorldApplication Run As- JavaApplication.
Step 10: Once spring boot started successfully then go to browser and hit http://localhost:8080 .
you should get the -Hello World.. Welcome to Spring Boot.. which is deployed on Google cloud appengine!
Step 11: That is done. Now we need to deploy this application on google cloud.
Step 12: Install the Google Cloud SDK for windows version and set the PATH in environment variables.
Step 13: Go to the place where pom.xml file is there in command prompt. gcloud config set project p7259000552 After this command mvn appengine:deploy
Step 14: You will get Build Success message. So application has been deployed successfully.
Step 15: Verify, whether it has been deployed or not - https://.appspot.com/
Step 16: This application will have simple math operations like add,sustarct,multiply,division if you click any of this links you will get appropriate results.
This post will explain you. How to work with Spring boot and Mysql CRUD(create,read,update,delete) operations
Step 1: Open eclipse and create a java project.. more details please check my previous post getting started with spring boot.
Step 2: create a new pom.xml file under project and the below code to that file.
package springboot.model;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;
@Entity
@Table
public class User {
@Id
@Column
private long id;
@Column
private String name;
@Column
private String gender;
@Column
private String country;
@Column
private String password;
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getGender() {
return gender;
}
public void setGender(String gender) {
this.gender = gender;
}
public String getCountry() {
return country;
}
public void setCountry(String country) {
this.country = country;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
Step 4: Create UserService and UserServiceImpl under package springboot.service
package springboot.service;
import java.util.List;
import springboot.model.User;
public interface UserService {
public List getUsers();
public List createOrUpdateUser( User user);
public List deleteUser( User user);
}
Step 5: Add below code in UserServiceImpl.
package springboot.service;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import springboot.dao.UserDAO;
import springboot.model.User;
@Component
public class UserServiceImpl implements UserService{
@Autowired
private UserDAO userDAO;
@Override
public List getUsers() {
return userDAO.getUsers();
}
public List createOrUpdateUser( User user){
return userDAO.createOrUpdateUser(user);
}
public List deleteUser( User user){
return userDAO.deleteUser(user);
}
public void setUserDAO(UserDAO userDAO) {
this.userDAO = userDAO;
}
}
Step 6: Create UserDAO and UserDAOImpl under package springboot.dao as mentioned below
package springboot.dao;
import java.util.List;
import javax.transaction.Transactional;
import org.springframework.data.repository.CrudRepository;
import springboot.model.User;
@Transactional
public interface UserDAO {
public List getUsers();
public List createOrUpdateUser( User user);
public List deleteUser( User user);
}
Step 7: Add below code inside UserDAOImpl
package springboot.dao;
import java.util.List;
import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import springboot.model.User;
@Component
public class UserDAOImpl implements UserDAO{
@Autowired
private SessionFactory sessionFactory;
public List getUsers(){
Criteria criteria = sessionFactory.openSession().createCriteria(User.class);
return criteria.list();
}
public List createOrUpdateUser( User user){
Session session = sessionFactory.openSession();
User oldUser = session.get(User.class, user.getId() );
//System.out.println("oldUser id["+ oldUser.getId()+"]");
if(oldUser == null){
session.save(user);
session.flush();
System.out.println("Created or Update Successful");
}
Criteria criteria = sessionFactory.openSession().createCriteria(User.class);
return criteria.list();
}
public List deleteUser( User user){
Session session = sessionFactory.openSession();
User oldUser = session.get(User.class, user.getId() );
if(oldUser != null){
session.delete(oldUser);
session.flush();
System.out.println("Deleted successfully");
}
Criteria criteria = sessionFactory.openSession().createCriteria(User.class);
return criteria.list();
}
public void setSessionFactory(SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
}
Step 8: Create BeanConfig class. which will create EntityManagerFactory.
package springboot;
import javax.persistence.EntityManagerFactory;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class BeanConfig {
@Autowired
private EntityManagerFactory entityManagerFactory;
@Bean
public SessionFactory getSessionFactory() {
if (entityManagerFactory.unwrap(SessionFactory.class) == null) {
throw new NullPointerException("factory is not a hibernate factory");
}
return entityManagerFactory.unwrap(SessionFactory.class);
}
public void setEntityManagerFactory(EntityManagerFactory entityManagerFactory) {
this.entityManagerFactory = entityManagerFactory;
}
}
Step 9: Now we need to add code related to database details called application.properties
# ===============================
# = DATA SOURCE
# ===============================
# Set here configurations for the database connection
spring.datasource.url = jdbc:mysql://localhost:3306/employee?useSSL=false
# Username and password
spring.datasource.username = root
spring.datasource.password = root
spring.jpa.show-sql = true
spring.jpa.hibernate.ddl-auto = update
spring.jpa.hibernate.naming-strategy = org.hibernate.cfg.ImprovedNamingStrategy
spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect
Step 10: Create a RestController class. Name it as UserController
package springboot;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import springboot.model.User;
import springboot.service.UserService;
@Controller
public class UserController {
@Autowired
private UserService userService;
@RequestMapping(value = "/list", method = RequestMethod.GET)
public ResponseEntity userDetails() {
List userDetails = userService.getUsers();
return new ResponseEntity(userDetails, HttpStatus.OK);
}
@RequestMapping(value = "/create/{id}/{name}/{password}/{gender}/{country}/", method = RequestMethod.GET)
public ResponseEntity createOrUpdateUserDetails(@PathVariable("id") long id, @PathVariable("name") String name,
@PathVariable("password") String password,@PathVariable("gender") String gender,@PathVariable("country") String country) {
User user = new User();
user.setId(id);
user.setName(name);
user.setCountry(country);
user.setGender(gender);
user.setPassword(password);
List userDetails = userService.createOrUpdateUser(user);
return new ResponseEntity(userDetails, HttpStatus.OK);
}
@RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)
public ResponseEntity deleteUserDetails(@PathVariable("id") long id) {
User user = new User();
user.setId(id);
List userDetails = userService.deleteUser(user);
return new ResponseEntity(userDetails, HttpStatus.OK);
}
public void setUserService(UserService userService) {
this.userService = userService;
}
}
Step 11: Now we need to run this application through spring boot. So we have to write Application class.
package springboot;
import java.util.Arrays;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Bean
public CommandLineRunner commandLineRunner(ApplicationContext ctx) {
return args -> {
System.out.println("Let's inspect the beans provided by Spring Boot:");
String[] beanNames = ctx.getBeanDefinitionNames();
Arrays.sort(beanNames);
for (String beanName : beanNames) {
System.out.println(beanName);
}
};
}
}
Step 12: Now we need to build and run this application.
Right click on the pom.xml file and Run As - clean install
Once that is done. Right click on the Application.java and Run As-> Java Application. Below details will be printed in Console
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v1.5.1.RELEASE)
2017-10-12 17:17:15.600 INFO 13036 --- [ main] springboot.Application : Starting Application on LAPTOP-2U8NKC7I with PID 13036 (F:\eclipse_workspace\spring_boot_first\target\classes started by Siva in F:\eclipse_workspace\spring_boot_first)
2017-10-12 17:17:15.626 INFO 13036 --- [ main] springboot.Application : No active profile set, falling back to default profiles: default
2017-10-12 17:17:16.033 INFO 13036 --- [ main] ationConfigEmbeddedWebApplicationContext : Refreshing org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@23bb8443: startup date [Thu Oct 12 17:17:15 IST 2017]; root of context hierarchy
Step 13: Use http://localhost:8080/list -- it will display all the records which is there inside user table.
If it askes username and password - then username will be - user and password will be check Using default security password: in console. that is your password.
Step 14: Use http://localhost:8080/create/16/sanju/sam/M/India/ - it will insert record inside DB and will display all the records from user table.
Step 15 : http://localhost:8080/delete/16 - it will delete where id is 16 and display all the results from user table.
Step 16 : Now we will learn how to create database and create a table.
Step 17: Install mysql and create database with name- employee. and create a table name called User with columns as mentioned below.
CREATE TABLE user (
id int(11) NOT NULL,
name varchar(45) DEFAULT NULL,
gender varchar(10) DEFAULT NULL,
password varchar(45) DEFAULT NULL,
country varchar(45) DEFAULT NULL,
PRIMARY KEY (`id`))
Step 18: If you want to use another database. simply change the application.properties respective DB details and dialect along with respective connecter in pom.xml
Thanks for viewing this post. If you like this please share and write comments.
Step 4: Right click on Project-> Configure->Convert To Maven Project
Step 5: If maven plugin not installed in your eclipse then got to market place of eclipse and search for maven , install from there.
Step 6: Now we need to create source folder -
create a folder with name main under src folder
create a folder with name java under main folder
create a folder with name test under main folder
Step 7: Link created folder to src.
Right click on src -> new -> Source folder -> browse on Folder Name-> Give upto main/java
Check the first check box
Right click on src -> new -> Source folder -> browse on Folder Name-> Give upto main/test
Check the first check box
Step 8: Create package wiht name springboot and create a class called HelloController.java
package springboot;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.RequestMapping;
@RestController
public class HelloController {
@RequestMapping("/")
public String index() {
return "Greetings from Spring Boot you have done the greate job!";
}
}
Step 9: Create a class called Application . This is the main class to run the spring boot application.
Step 10:Now we need to run this project. Right click on the pom.xml file and Run As -> maven install
Step 11: After Build success . Now we Need to run the Spring Boot Applcation.
Step 12 : Right click on the Application.java Run As - Java Application.
Step 13 : Once executed successfully, then open any Browser and type - http://localhost:8080/
Step 14: Out put will be -Greetings from Spring Boot you have done the greate job! - This details will be available in HelloController.java
Step 15: If you notice that , spring boot will have in built tomcat. Once we started Spring boot, then it will start the tomcat. No external server configuration required.
Step 16 : if you want to know more about spring boot please check the Spring Boot
Step 17 : if you want to change the out put in HelloController. change the return value and again try to run the Application.java.
In this case you may get the below error
2017-10-05 11:23:38.382 INFO 9172 --- [ main] o.s.c.support.DefaultLifecycleProcessor : Starting beans in phase 0
2017-10-05 11:23:41.318 ERROR 9172 --- [ main] o.a.coyote.http11.Http11NioProtocol : Failed to start end point associated with ProtocolHandler ["http-nio-8080"]
java.net.BindException: Address already in use: bind
at sun.nio.ch.Net.bind0(Native Method) ~[na:1.8.0_131]
at sun.nio.ch.Net.bind(Unknown Source) ~[na:1.8.0_131]
at sun.nio.ch.Net.bind(Unknown Source) ~[na:1.8.0_131]
service.getName(): "Tomcat"; Protocol handler start failed
at org.apache.catalina.connector.Connector.startInternal(Connector.java:1029) ~[tomcat-embed-core-8.5.20.jar:8.5.20]
at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) ~[tomcat-embed-core-8.5.20.jar:8.5.20]
... 13 common frames omitted
Caused by: java.net.BindException: Address already in use: bind
The Tomcat connector configured to listen on port 8080 failed to start. The port may already be in use or the connector may be misconfigured.
To Kill the existing port 8080, which is already in use.
Step 18: Go to command prompt- type netstat -a -o -n
Step 19 find the PID for tomcat port 0.0.0.0:8080 then kill that PID using below command
Step 20 - taskkill /F /PID 28345
This post will explain how to sort the list by name using Comparator and java 8 Stream.
usage of BiFunction
package com.siva;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.function.BiFunction;
import java.util.stream.Stream;
public class TestJava8Example {
public static void main(String[] args) {
//Usage of BiFunction
BiFunction add = (a, b) -> a + b;
System.out.println("Addition of two values["+add.apply(20, 30) +"]");
//usage of stream
List arrayList = new ArrayList();
Person p = new Person();
p.setName("siva");
p.setAge(32);
arrayList.add(p);
Person p1 = new Person();
p1.setName("kumar");
p1.setAge(33);
arrayList.add(p1);
Person p2 = new Person();
p2.setName("raju");
p2.setAge(33);
arrayList.add(p2);
Person p3 = new Person();
p3.setName("jatin");
p3.setAge(2);
arrayList.add(p3);
Stream stream = arrayList.stream();
stream.forEach(x -> System.out.println("Name: [" + x.getName()+"] Age ["+x.getAge()+"]"));
//Sort By name Using comparator
Comparator byPersonName = (Person p4, Person p5) -> p4.getName().compareTo(
p5.getName());
Stream sorted = arrayList.stream().sorted(byPersonName);
sorted.forEach(e -> System.out.println("sorted Name: [" + e.getName()+"] Age ["+e.getAge()+"]"));
}
}
output
Addition of two values[50]
Name: [siva] Age [32]
Name: [kumar] Age [33]
Name: [raju] Age [33]
Name: [jatin] Age [2]
sorted Name: [jatin] Age [2]
sorted Name: [kumar] Age [33]
sorted Name: [raju] Age [33]
sorted Name: [siva] Age [32]
This post will explain , how to work with Jboss Drools.
Step 1: Open eclipse and install Drools plugin through Market place.
Help - Eclipse Marketplace- search for drools and install the same.
Step 2: Create a new Maven Project and add below code snippet in pom.xml
//created on: 7 Sep, 2017
package src.main.resources.rules
import com.sample.*;
//list any import classes here.
rule "We have an Best Cricketer"
salience 10
when
then
System.out.println("We have an Best Cricketer");
end
rule "Cricket Lives"
salience 10
when
then
System.out.println("Hurrah!!! Cricket Lives");
end
rule "Hello World"
when
Cricketer( name == "sachin" )
then
System.out.println( "Hello sachin" );
end
rule "Cricket Score above 50"
when
$cricketerDetails : Cricketer( score >= 50 )
then
System.out.println( "I'm best bat's man , my name is[ " + $cricketerDetails.getName() + "]and my score is["+$cricketerDetails.getScore()+"]");
end
rule "Cricket Score below 50"
when
$cricketerDetails : Cricketer( score < 50 )
then
System.out.println( "I'm not best bat's man , my name is[ " + $cricketerDetails.getName() + "]and my score is["+$cricketerDetails.getScore()+"]");
end
Step 3: Write a Simple Pojo Java class.
package com.sample;
public class Cricketer {
private String name;
private boolean honest;
private int score;
public Cricketer(){
}
public Cricketer(String name, boolean honest,int score){
this.name = name;
this.honest = honest;
this.score = score;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public boolean isHonest() {
return honest;
}
public void setHonest(boolean honest) {
this.honest = honest;
}
public int getScore() {
return score;
}
public void setScore(int score) {
this.score = score;
}
}
Step 4: Now Write a Test java class to execute the drool file.
package com.sample;
import org.kie.api.KieServices;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
public class BestCricketer {
public static void main(String[] args) {
KieServices ks = KieServices.Factory.get();
KieContainer kContainer = ks.getKieClasspathContainer();
KieSession ksession = kContainer.newKieSession("ksession-rules");
Cricketer sachin = new Cricketer("sachin", true,70);
Cricketer dravid = new Cricketer("dravid", true,55);
Cricketer rohan = new Cricketer("rohan", true,100);
Cricketer ajay = new Cricketer("ajay", true,40);
ksession.insert( sachin );
ksession.insert( dravid );
ksession.insert( rohan );
ksession.insert( ajay );
ksession.fireAllRules();
}
}
Step 5: Output could be like below
We have an Best Cricketer
Hurrah!!! Cricket Lives
Hello sachin
I'm best bat's man , my name is[ rohan]and my score is[100]
I'm best bat's man , my name is[ dravid]and my score is[55]
I'm best bat's man , my name is[ sachin]and my score is[70]
I'm not best bat's man , my name is[ ajay]and my score is[40]
Step 3: we need to create applicationContext.xml inside WEB-INF folder. This will have details related to database and other values. Here mentioned only DB details.
Step 4: Create dispatcher-servlet.xml(in web.xml we have mentioned servlet name as dispatcher, so in sping mvc xml configuration with name [servletname-servlet.xml].
So here we have to give name as dispatcher-servlet.xml
Step 5: Create a database schema name as employee and create a table called user with the columns - id,name,password,gender,country
Step 6: Configuration files has been created for spring-mvc . Now we need to write source code. First we will create controller class with name UserController under package - com.siva.controller
package com.siva.web;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.SessionAttributes;
import com.siva.domain.User;
import com.siva.service.UserService;
@Controller
@RequestMapping("/userRegistration.htm")
@SessionAttributes("user")
public class UserController {
private UserService userService;
@Autowired
public void setUserService(UserService userService) {
this.userService = userService;
}
@RequestMapping(method = RequestMethod.GET)
public String showUserForm(ModelMap model)
{
User user = new User();
model.addAttribute(user);
return "userForm";
}
@RequestMapping(method = RequestMethod.POST)
public String onSubmit(@ModelAttribute("user") User user) {
userService.add(user);
return "redirect:userSuccess.htm";
}
public UserService getUserService() {
return userService;
}
}
Step 7: Create domain class with name User under com.siva.domain package
package com.siva.domain;
public class User {
private int id;
private String name;
private String password;
private String gender;
private String country;
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 String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getGender() {
return gender;
}
public void setGender(String gender) {
this.gender = gender;
}
public String getCountry() {
return country;
}
public void setCountry(String country) {
this.country = country;
}
}
Step 8: Create service and serviceImpl classes inside com.siva.service package.
package com.siva.service;
import com.siva.domain.User;
public interface UserService {
public void add(User user);
}
package com.siva.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import com.siva.dao.UserDAO;
import com.siva.domain.User;
@Repository("userService")
public class UserServiceImpl implements UserService {
@Autowired
private UserDAO userDAO;
public void setUserDAO(UserDAO userDAO) {
this.userDAO = userDAO;
}
@Override
public void add(User user) {
//Persist the user object here.
userDAO.add(user);
System.out.println("User added successfully");
System.out.println("UserName["+user.getName()+"]");
System.out.println("Gender["+user.getGender()+"]");
System.out.println("Pasword["+user.getPassword()+"]");
System.out.println("Country["+user.getCountry()+"]");
}
public UserDAO getUserDAO() {
return userDAO;
}
}
Step 9: Create dao and daoImpl classes inside com.siva.dao package.
package com.siva.dao;
import com.siva.domain.User;
public interface UserDAO {
public void add(User user);
}
package com.siva.dao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import com.siva.domain.User;
@Repository("userDAO")
public class UserDAOImpl implements UserDAO {
@Autowired
public JdbcTemplate jdbcTemplate;
public JdbcTemplate getJdbcTemplate() {
return jdbcTemplate;
}
@Override
public void add(User user) {
//Persist the user object here.
String sql = "INSERT INTO USER(id,name,gender,password,country) VALUES(?, ?, ?,?,?)";
int returnValue = getJdbcTemplate().update(
sql,
new Object[] {user.getId(), user.getName(), user.getGender(),user.getPassword(),user.getCountry()});
if(1 == returnValue)
System.out.println("Record inserted successfully");
else{
System.out.println("Record inserted Failure");
}
}
}
Step 10: Java code has been completed. Now we need to write jsp files under /WEB-INF/jsp/userForm.jsp
Step 11: create one more jsp /WEB-INF/jsp/userSuccess.jsp
<%@ page language="java" contentType="text/html; charset=ISO-8859-1"
pageEncoding="ISO-8859-1"%>
Success Page
User Details
User ID : ${user.id}
User Name : ${user.name}
Password : ${user.password}
Gender : ${user.gender}
Country : ${user.country}
Step 12 : We need to add the jar file under /WEB-INF/lib
Step 13: We can run this project by using any one of the server. I have used tomcat and input and output will be display like below.
use URL - http://localhost:8080/spring_junit/userRegistration.htm and provide input details like id, name etc..
Step 14: Now it's time to write junit test case for service. Here i have written simple test case , u can write more test cases depening upon your requirement.
Step 15: First Create a UserServiceAndControllerTest under package - com.siva.test
Step 16: In the above class we have 4 test methods first two are to check whether service and controller classes loaded successfully or not.
Other two are actual functionality for service and controller method test through spring mockmvc.
Step 17 : In the above class to test the controller method either passing user object values as hard coded or we can pass through json object.
I have passed here json object for this we need to create one json class to read the json file and conver it into user json object.
Step 18: create UserJSONReader.java under package com.siva.test
package com.siva.test;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import javax.json.Json;
import javax.json.JsonObject;
import javax.json.JsonReader;
import com.siva.domain.User;
public class UserJSONReader {
public User getUserJSOnObject(){
User user = new User();
try {
InputStream fis = new FileInputStream("user_json.txt");
//create JsonReader object
JsonReader jsonReader = Json.createReader(fis);
//get JsonObject from JsonReader
JsonObject jsonObject = jsonReader.readObject();
user.setId(jsonObject.getInt("id"));
user.setName(jsonObject.getString("name"));
user.setPassword(jsonObject.getString("password"));
user.setCountry(jsonObject.getString("country"));
user.setGender(jsonObject.getString("gender"));
jsonReader.close();
fis.close();
} catch (IOException e) {
e.printStackTrace();
}
return user;
}
}
Step 19: create user_json.txt file under project.
{
"id":14,
"name":"Jatin",
"password":"jatin 123",
"gender":"Male",
"country":"India is a Great Country"
}
Step 20: Now we need to create one xml file with name-UserServiceAndControllerTest-context.xml
Step 21: This is very important step for spring junit. need to configure bean details inside java class. Create class called AppConfig under package com.siva.test
package com.siva.test;
import javax.sql.DataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.mock.web.MockHttpSession;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;
import com.siva.dao.UserDAO;
import com.siva.dao.UserDAOImpl;
import com.siva.service.UserService;
import com.siva.service.UserServiceImpl;
import com.siva.web.UserController;
import com.siva.web.UserSuccessController;
@Configuration
public class AppConfig {
@Bean
public UserService getUserService(){
return new UserServiceImpl();
}
@Bean
public UserDAO getUserDAO(){
return new UserDAOImpl();
}
@Bean
public JdbcTemplate getJdbcTemplate() {
JdbcTemplate jdbcTemplate = new JdbcTemplate();
jdbcTemplate.setDataSource(getDataSource());
return jdbcTemplate;
}
@Bean
public DataSource getDataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
//MySQL database we are using
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/employee");//change url
dataSource.setUsername("root");//change userid
dataSource.setPassword("root");//change pwd
return dataSource;
}
@Bean
public UserController getUserController(){
return new UserController();
}
@Bean
public UserSuccessController getUserSuccessController(){
return new UserSuccessController();
}
@Bean
public MockHttpSession getMockHttpSession(){
return new MockHttpSession();
}
}
Step 21: Once everything is done , then we will run this Test program as Run AS Junit, it has to insert data successfully and test case execution should be passed.
Step 0: Java 1.7 or above needs to be installed.
Step1 : Download spring xd from below URL Spring XD
Step2: Unzip and place it where ever you desire. I have placed it in F:\softwares\spring-xd
Step3: Open command Prompt- go to F:\softwares\spring-xd\spring-xd-1.2.0.RELEASE\xd\bin
Step 4: F:\softwares\spring-xd\spring-xd-1.2.0.RELEASE\xd\bin>xd-singlenode
Spring xd will start and displayed as mentioned below.
Step 5: Now open another command prompt to run the shell- F:\softwares\spring-xd\spring-xd-1.2.0.RELEASE\shell\bin
Step 6: F:\softwares\spring-xd\spring-xd-1.2.0.RELEASE\shell\bin>xd-shell
Shell prompt will display as mentioned below.
Step 7: Now we need to create twitter steam inside Spring XD shell
Step 8: We need to create an application inside twitter to get the consumer key and consumer secret key
Step 9: I have created application with name- twitterspringxdsearchjava.
Step 10: Please login into - https://apps.twitter.com and create your own application
Step 11: Now we need to run the created twitter application using spring xd shell
Step 12: output file created inside - F:\tmp\xd\output with name – twitterspringxdsearchjava.out
Step 13: This file will have live tweets data in json format.
This post will explain how to load environment specific[DEV,SIT,UAT,PROD] properties from the single properties file
Step 1: Create simple java project using eclipse
Step 2: Create a abstract class , with under package - com.javaguru.property, i have created with name - PropertyClient.java
package com.javaguru.property;
public abstract class PropertyClient {
protected String hostName;
protected String userId;
protected String password;
public PropertyClient(String hostName, String userId, String password) {
super();
this.hostName = hostName;
this.userId = userId;
this.password = password;
}
public PropertyClient(){
}
public String getHostName() {
return hostName;
}
public void setHostName(String hostName) {
this.hostName = hostName;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
//common methods related to functionality
}
Step 3: Create implementation class.
package com.javaguru.property;
public class PropertyClientImpl extends PropertyClient{
public PropertyClientImpl(String hostName, String userId, String password) {
super(hostName, userId, password);
}
public PropertyClientImpl(){
super();
}
//Implementation of abstract methods
}
Step 4: Create property file name called - application.properties under src folder
