Title

diff --git a/boot/pom.xml b/boot/pom.xml new file mode 100644 index 0000000..3061051 --- /dev/null +++ b/boot/pom.xml @@ -0,0 +1,64 @@ + + + 4.0.0 + + com.max + boot + 1.0-SNAPSHOT + + + org.springframework.boot + spring-boot-starter-parent + 1.5.9.RELEASE + + + + + + org.apache.maven.plugins + maven-compiler-plugin + + 1.8 + 1.8 + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.boot + spring-boot-starter + + + org.springframework.boot + spring-boot-starter-data-jpa + + + + + + + mysql + mysql-connector-java + + + org.springframework.boot + spring-boot-starter-test + + + org.springframework.boot + spring-boot-starter-actuator + + + \ No newline at end of file diff --git a/boot/src/main/java/com/max/Main.java b/boot/src/main/java/com/max/Main.java new file mode 100644 index 0000000..c3a2fb0 --- /dev/null +++ b/boot/src/main/java/com/max/Main.java @@ -0,0 +1,33 @@ +package com.max; + +import com.max.interfaces.MyComponent; +import org.springframework.beans.factory.annotation.Autowired; +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//(scanBasePackages = "com.max") +//@EnableAutoConfiguration +//@Configuration +//@ComponentScan("com.max") +public class Main { + @Autowired + MyComponent myComponent; + @Autowired + ApplicationContext context; + public static void main(String[] args) { + SpringApplication.run(Main.class, args); + } + @Bean + public CommandLineRunner commandLineRunner(ApplicationContext ctx) { + return args -> { + MyComponent bean1 = context.getBean(MyComponent.class); + bean1.print(); + MyComponent bean = ctx.getBean(MyComponent.class); + bean.print(); + myComponent.print(); + }; + } +} diff --git a/boot/src/main/java/com/max/MainDb.java b/boot/src/main/java/com/max/MainDb.java new file mode 100644 index 0000000..9892c11 --- /dev/null +++ b/boot/src/main/java/com/max/MainDb.java @@ -0,0 +1,25 @@ +package com.max; + + +import com.max.entities.User; +import com.max.interfaces.UserRepository; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.CommandLineRunner; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.annotation.Bean; + +@SpringBootApplication +public class MainDb { + @Autowired + UserRepository userRepository; + public static void main(String[] args) { + SpringApplication.run(MainDb.class, args); + } + @Bean + public CommandLineRunner commandLineRunner() { + return args -> { + userRepository.save(new User("Max")); + }; + } +} diff --git a/boot/src/main/java/com/max/MainWeb.java b/boot/src/main/java/com/max/MainWeb.java new file mode 100644 index 0000000..5183d71 --- /dev/null +++ b/boot/src/main/java/com/max/MainWeb.java @@ -0,0 +1,12 @@ +package com.max; + + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class MainWeb { + public static void main(String[] args) { + SpringApplication.run(MainWeb.class, args); + } +} diff --git a/boot/src/main/java/com/max/controllers/WebController.java b/boot/src/main/java/com/max/controllers/WebController.java new file mode 100644 index 0000000..731b2e5 --- /dev/null +++ b/boot/src/main/java/com/max/controllers/WebController.java @@ -0,0 +1,12 @@ +package com.max.controllers; + +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RestController; + +@RestController +public class WebController { + @GetMapping("webBoot") + public String webBoot() { + return "Hello world"; + } +} diff --git a/boot/src/main/java/com/max/entities/User.java b/boot/src/main/java/com/max/entities/User.java new file mode 100644 index 0000000..1c464d5 --- /dev/null +++ b/boot/src/main/java/com/max/entities/User.java @@ -0,0 +1,36 @@ +package com.max.entities; + +import javax.persistence.Entity; +import javax.persistence.GeneratedValue; +import javax.persistence.GenerationType; +import javax.persistence.Id; +import java.io.Serializable; + +@Entity +public class User implements Serializable { + @GeneratedValue(strategy = GenerationType.AUTO) + @Id + int id; + String name; + + public User() {} + public User(String name) { + this.name = name; + } + + 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; + } +} diff --git a/boot/src/main/java/com/max/impl/MyComponentImpl.java b/boot/src/main/java/com/max/impl/MyComponentImpl.java new file mode 100644 index 0000000..54e5ea8 --- /dev/null +++ b/boot/src/main/java/com/max/impl/MyComponentImpl.java @@ -0,0 +1,12 @@ +package com.max.impl; + +import com.max.interfaces.MyComponent; +import org.springframework.stereotype.Component; + +@Component +public class MyComponentImpl implements MyComponent { + @Override + public void print() { + System.out.println("Hello world"); + } +} diff --git a/boot/src/main/java/com/max/interfaces/MyComponent.java b/boot/src/main/java/com/max/interfaces/MyComponent.java new file mode 100644 index 0000000..cfb07c4 --- /dev/null +++ b/boot/src/main/java/com/max/interfaces/MyComponent.java @@ -0,0 +1,5 @@ +package com.max.interfaces; + +public interface MyComponent { + void print(); +} diff --git a/boot/src/main/java/com/max/interfaces/UserRepository.java b/boot/src/main/java/com/max/interfaces/UserRepository.java new file mode 100644 index 0000000..7531ef5 --- /dev/null +++ b/boot/src/main/java/com/max/interfaces/UserRepository.java @@ -0,0 +1,9 @@ +package com.max.interfaces; + +import com.max.entities.User; +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.transaction.annotation.Transactional; + +@Transactional +public interface UserRepository extends JpaRepository { +} diff --git a/boot/src/main/resources/application.properties b/boot/src/main/resources/application.properties new file mode 100644 index 0000000..37823b5 --- /dev/null +++ b/boot/src/main/resources/application.properties @@ -0,0 +1,7 @@ +spring.jpa.hibernate.ddl-auto=create-drop +spring.datasource.url=jdbc:mysql://localhost:3306/Lessons +spring.datasource.username=root +spring.datasource.password=1 +management.security.enabled=false +logging.level.org.hibernate.SQL=DEBUG +spring.jpa.properties.hibernate.show_sql=true \ No newline at end of file diff --git a/boot/src/test/java/BootTest.java b/boot/src/test/java/BootTest.java new file mode 100644 index 0000000..c6e7eaf --- /dev/null +++ b/boot/src/test/java/BootTest.java @@ -0,0 +1,24 @@ +import com.max.interfaces.MyComponent; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.SpringBootConfiguration; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.context.annotation.ComponentScan; +import org.springframework.test.context.junit4.SpringRunner; + +@RunWith(SpringRunner.class) +@SpringBootTest(classes = BootTest.Config.class) +//@TestConfiguration +public class BootTest { + @Autowired +// @MockBean + MyComponent bean; + @Test + public void test() { + bean.print(); + } + @SpringBootConfiguration + @ComponentScan("com.max") + static class Config {} +} diff --git a/ee/src/servlets/GetIp.java b/ee/src/servlets/GetIp.java new file mode 100644 index 0000000..b170c85 --- /dev/null +++ b/ee/src/servlets/GetIp.java @@ -0,0 +1,16 @@ +package servlets; + +import javax.servlet.ServletException; +import javax.servlet.annotation.WebServlet; +import javax.servlet.http.HttpServlet; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; + +@WebServlet("/getIp") +public class GetIp extends HttpServlet { + @Override + protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { + resp.getWriter().write(req.getRemoteAddr()); + } +} diff --git a/hiber/resources/entities/Book.hbm.xml b/hiber/resources/entities/Book.hbm.xml new file mode 100644 index 0000000..0c6c69e --- /dev/null +++ b/hiber/resources/entities/Book.hbm.xml @@ -0,0 +1,7 @@ + + + + + + + \ No newline at end of file diff --git a/hiber/resources/entities/Student.hbm.xml b/hiber/resources/entities/Student.hbm.xml new file mode 100644 index 0000000..2e4c0eb --- /dev/null +++ b/hiber/resources/entities/Student.hbm.xml @@ -0,0 +1,8 @@ + + + + + + + + \ No newline at end of file diff --git a/hiber/resources/hibernate.cfg.xml b/hiber/resources/hibernate.cfg.xml new file mode 100644 index 0000000..9046ae3 --- /dev/null +++ b/hiber/resources/hibernate.cfg.xml @@ -0,0 +1,30 @@ + + + + + + + + + jdbc:mysql://localhost:3306/Lessons + com.mysql.jdbc.Driver + root + 1 + org.hibernate.dialect.MySQL5Dialect + + true + org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory + + true + update + + + + + + + + + + + \ No newline at end of file diff --git a/hiber/resources/hibernate.properties b/hiber/resources/hibernate.properties new file mode 100644 index 0000000..44b7e51 --- /dev/null +++ b/hiber/resources/hibernate.properties @@ -0,0 +1 @@ +#hibernate.connection.url = jdbc:mysql://localhost:3306/Lessons \ No newline at end of file diff --git a/hiber/src/ConfigHiberLesson.java b/hiber/src/ConfigHiberLesson.java new file mode 100644 index 0000000..ab31378 --- /dev/null +++ b/hiber/src/ConfigHiberLesson.java @@ -0,0 +1,21 @@ +import entities.Student; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.cfg.Configuration; + +public class ConfigHiberLesson { + public static void main(String[] args) { + Configuration cfg = new Configuration() + .setProperty("hibernate.dialect", "org.hibernate.dialect.MariaDBDialect") + .setProperty("hibernate.connection.username", "root") + .setProperty("hibernate.connection.password", "1") + .setProperty("hibernate.connection.url", "jdbc:mysql://localhost:3306/Lessons") + .configure(); + try(SessionFactory sessionFactory = cfg.buildSessionFactory(); + Session session = sessionFactory.openSession()) { + session.beginTransaction(); + session.save(new Student("Max")); + session.getTransaction().commit(); + } + } +} diff --git a/hiber/src/HelloWorld.java b/hiber/src/HelloWorld.java new file mode 100644 index 0000000..14a561a --- /dev/null +++ b/hiber/src/HelloWorld.java @@ -0,0 +1,55 @@ +import entities.HomeAddress; +import entities.Person; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.boot.MetadataSources; +import org.hibernate.boot.registry.StandardServiceRegistry; +import org.hibernate.boot.registry.StandardServiceRegistryBuilder; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +public class HelloWorld { + public static void main(String[] args) { + StandardServiceRegistry registry = new StandardServiceRegistryBuilder().configure().build(); + try(SessionFactory sessionFactory = new MetadataSources( registry ).buildMetadata().buildSessionFactory(); + Session session = sessionFactory.openSession()) { + session.beginTransaction(); + + HomeAddress homeAddress = new HomeAddress("Lenina"); + List list = new ArrayList<>(); + list.add(homeAddress); + list.add(new HomeAddress("Gukova")); + + List marks = new ArrayList<>(); + marks.add(1); + marks.add(3); + marks.add(2); + +// Map map = new HashMap<>(); +// map.put("one", "1"); +// map.put("two", "2"); + + Person person = new Person("Max", list, marks, "123"); +// session.persist(homeAddress); + session.persist(person); + + Map book = new HashMap<>(); + book.put( "isbn", "978-9730228236" ); + book.put( "title", "High-Performance Java Persistence" ); + book.put( "author", "Vlad Mihalcea" ); + + session.save( "Book", book ); + + Person iCode = session.byNaturalId(Person.class).using("iCode", "123").getReference(); + System.out.println(iCode); + + Person load = session.load(Person.class, 85); +// System.out.println(load.getMarks()); +// List homeAddress = load.getHomeAddress(); + session.getTransaction().commit(); + } + } +} diff --git a/hiber/src/Main.java b/hiber/src/Main.java new file mode 100644 index 0000000..46374f2 --- /dev/null +++ b/hiber/src/Main.java @@ -0,0 +1,118 @@ +import entities.hierarchies.Car; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.boot.MetadataSources; +import org.hibernate.boot.registry.StandardServiceRegistry; +import org.hibernate.boot.registry.StandardServiceRegistryBuilder; +import org.hibernate.query.NativeQuery; + +import java.util.List; + +public class Main { + public static void main(String[] args) throws InterruptedException { + StandardServiceRegistry registry = new StandardServiceRegistryBuilder().configure().build(); + try(SessionFactory sessionFactory = new MetadataSources( registry ).buildMetadata().buildSessionFactory(); + Session session = sessionFactory.openSession()) { + + session.beginTransaction(); + NativeQuery nativeQuery = session.createNativeQuery("select * from Car", Car.class); + List resultList = nativeQuery.getResultList(); + for (Car car : resultList) { + System.out.println("id " + car.getId() + " number " + car.getNumber()); + } + session.getTransaction().commit(); + +// session.beginTransaction(); +// Query query = session.createNamedQuery("getCarByNumber"); +// query.setParameter("number", "123"); +// Car car = (Car) query.uniqueResult(); +// System.out.println(car.getId()); +// session.getTransaction().commit(); + +// session.beginTransaction(); +// session.createQuery("update Car c set c.number = '234' where c.id = 247").executeUpdate(); +// session.createQuery("insert into Car (id,number) select c.id + 4, concat(c.number, '1') from Car c where c.id = 247").executeUpdate(); +// session.createQuery("delete Car c where c.id = 251").executeUpdate(); +// session.getTransaction().commit(); + +// session.beginTransaction(); +// Query query = session.createQuery("from Car c where c.number != '123'"); +// =, >, >=, <, <=, <>, != +// Query query = session.createQuery("from Car c where c.number is not null"); +// Query query = session.createQuery("from Car c where c.number like '%123%'"); +// Query query = session.createQuery("from Car c where number BETWEEN 1 and 1000"); +// Query query = session.createQuery("from Car c where number in (123,1234)"); +// Query query = session.createQuery("from Car c where c.number is empty"); +// Query query = session.createQuery("from Car c where c.number = '123' or c.number = '2' and c.number = '3'"); +// Query query = session.createQuery("from Car c where number = 123L"); +// Query query = session.createQuery("from Car c where number = 123.0"); +// Query query = session.createQuery("from Car c where number = 123.0F"); +// Query query = session.createQuery("from Car c where number = 120 + 3"); +// Query query = session.createQuery("from Car c where number = 12 || 3"); +// List list = query.list(); +// for (Car car : list) { +// System.out.println(car.getNumber()); +// } +// session.getTransaction().commit(); + +// session.beginTransaction(); +// User user = new User("Max"); +// Role admin = new Role("admin"); +// Role moderator = new Role("moderator"); +// List roles = new ArrayList<>(); +// roles.add(admin); +// roles.add(moderator); +// user.setRoleList(roles); +// session.persist(user); +// session.getTransaction().commit(); + +// session.beginTransaction(); +//// Query query = session.createQuery("from User"); +// Query query = session.createQuery("select distinct u from User u join fetch u.roleList"); +// List list = query.list(); +// session.getTransaction().commit(); +// +// for (User user : list) { +// System.out.println(user.getName()); +// System.out.println(user.getRoleList().size()); +// } + +// session.beginTransaction(); +// Query query = session.createQuery("select max(id) from Car c"); +// Query query = session.createQuery("select min(id) from Car c"); +// Query query = session.createQuery("select count(id) from Car c"); +// Query query = session.createQuery("select sum(id) from Car c"); +// Query query = session.createQuery("select avg(id) from Car c"); +// jpql +// Query query = session.createQuery("select concat(id, ' id') from Car c"); +// Query query = session.createQuery("select substring(c.number, 0,1) from Car c"); +// Query query = session.createQuery("select upper(c.number) from Car c"); +// Query query = session.createQuery("select lower(c.number) from Car c"); +// Query query = session.createQuery("select trim(c.number) from Car c"); +// Query query = session.createQuery("select length(c.number) from Car c"); +// Query query = session.createQuery("select locate('1', c.number) from Car c"); +// Query query = session.createQuery("select abs(number) from Car c"); +// Query query = session.createQuery("select mod(number, 10) from Car c"); +// Query query = session.createQuery("select sqrt(number) from Car c"); +// Query query = session.createQuery("select current_date from Car c"); +// Query query = session.createQuery("select current_time from Car c"); +// Query query = session.createQuery("select current_timestamp from Car c"); +// hql +// Query query = session.createQuery("select bit_length(c.number) from Car c"); +// Query query = session.createQuery("select cast(c.number as string) from Car c"); +// Query query = session.createQuery("select extract(YEAR from current_timestamp) from Car c"); +// Query query = session.createQuery("select year(current_timestamp) from Car c"); +// Query query = session.createQuery("select DAY(current_timestamp) from Car c"); +// Query query = session.createQuery("select MONTH(current_timestamp) from Car c"); +// Query query = session.createQuery("select HOUR(current_timestamp) from Car c"); +// Query query = session.createQuery("select MINUTE(current_timestamp) from Car c"); +// Query query = session.createQuery("select SECOND(current_timestamp) from Car c"); +// Query query = session.createQuery("select STR(current_timestamp) from Car c"); +// List list = query.list(); +// for (String str : list) { +// System.out.println(str); +// } +// session.getTransaction().commit(); + } + } +} diff --git a/hiber/src/entities/Address.java b/hiber/src/entities/Address.java new file mode 100644 index 0000000..97e0a49 --- /dev/null +++ b/hiber/src/entities/Address.java @@ -0,0 +1,37 @@ +package entities; + +import javax.persistence.Embeddable; +import java.io.Serializable; + +@Embeddable +//@Access(AccessType.FIELD) +public class Address implements Serializable { + + public Address() {} + + public Address(String street, int number) { + this.street = street; + this.number = number; + } + + String street; + int number; + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + + Address address = (Address) o; + + if (number != address.number) return false; + return street != null ? street.equals(address.street) : address.street == null; + } + + @Override + public int hashCode() { + int result = street != null ? street.hashCode() : 0; + result = 31 * result + number; + return result; + } +} diff --git a/hiber/src/entities/EntityStates.java b/hiber/src/entities/EntityStates.java new file mode 100644 index 0000000..3a455b7 --- /dev/null +++ b/hiber/src/entities/EntityStates.java @@ -0,0 +1,38 @@ +package entities; + +import entities.hierarchies.Car; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.boot.MetadataSources; +import org.hibernate.boot.registry.StandardServiceRegistry; +import org.hibernate.boot.registry.StandardServiceRegistryBuilder; + +public class EntityStates { + public static void main(String[] args) { + StandardServiceRegistry registry = new StandardServiceRegistryBuilder().configure().build(); + try(SessionFactory sessionFactory = new MetadataSources( registry ).buildMetadata().buildSessionFactory(); + Session session = sessionFactory.openSession()) { + session.beginTransaction(); + + session.getTransaction().commit(); + Car car = new Car("123"); + System.out.println(car.getId()); + session.persist(car); + session.flush(); + System.out.println(car.getId()); +// car.setNumber("321"); +// session.detach(car); +// car.setNumber("456"); +//// session.merge(car); +// session.update(car); +// session.remove(car); +// System.out.println(car.getId()); +// System.out.println(car.getNumber()); + car.setNumber("789"); + session.refresh(car); + System.out.println(car.getNumber()); + + session.getTransaction().commit(); + } + } +} diff --git a/hiber/src/entities/HomeAddress.java b/hiber/src/entities/HomeAddress.java new file mode 100644 index 0000000..7dfafdc --- /dev/null +++ b/hiber/src/entities/HomeAddress.java @@ -0,0 +1,23 @@ +package entities; + +import javax.persistence.Embeddable; +import javax.persistence.GeneratedValue; +import javax.persistence.Id; + +//@Entity +@Embeddable +public class HomeAddress { +// @Id +// @GeneratedValue +// int id; + String street; + + public HomeAddress() {} + public HomeAddress(String street) { + this.street = street; + } + + public String getStreet() { + return street; + } +} diff --git a/hiber/src/entities/LockExample.java b/hiber/src/entities/LockExample.java new file mode 100644 index 0000000..5299b72 --- /dev/null +++ b/hiber/src/entities/LockExample.java @@ -0,0 +1,48 @@ +package entities; + +import entities.hierarchies.Car; +import org.hibernate.LockMode; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.boot.MetadataSources; +import org.hibernate.boot.registry.StandardServiceRegistry; +import org.hibernate.boot.registry.StandardServiceRegistryBuilder; + +public class LockExample { + public static void main(String[] args) throws InterruptedException { + StandardServiceRegistry registry = new StandardServiceRegistryBuilder().configure().build(); + try(SessionFactory sessionFactory = new MetadataSources( registry ).buildMetadata().buildSessionFactory(); + Session session = sessionFactory.openSession(); + Session session2 = sessionFactory.openSession()) { + + session.beginTransaction(); + Car car = new Car("123"); + session.persist(car); + session.getTransaction().commit(); + + final int carId = car.getId(); + + new Thread() { + @Override + public void run() { + session.beginTransaction(); + Car car = session.load(Car.class, carId, LockMode.PESSIMISTIC_WRITE); + car.setNumber(car.getNumber() + "4"); + try {Thread.sleep(400);} catch (InterruptedException e) {} + session.getTransaction().commit(); + } + }.start(); + + new Thread() { + @Override + public void run() { + session2.beginTransaction(); + Car car = session2.load(Car.class, carId, LockMode.PESSIMISTIC_WRITE); + car.setNumber(car.getNumber() + "5"); + session2.getTransaction().commit(); + } + }.start(); + Thread.sleep(600); + } + } +} diff --git a/hiber/src/entities/Person.java b/hiber/src/entities/Person.java new file mode 100644 index 0000000..e5816df --- /dev/null +++ b/hiber/src/entities/Person.java @@ -0,0 +1,64 @@ +package entities; + +import org.hibernate.annotations.NaturalId; + +import javax.persistence.ElementCollection; +import javax.persistence.Entity; +import javax.persistence.GeneratedValue; +import javax.persistence.Id; +import java.util.List; + +@Entity +public class Person { + @Id + @GeneratedValue + private int id; + private String name; + @ElementCollection + private List homeAddress; + @ElementCollection +// @OrderBy("marks") +// @OrderColumn +// @org.hibernate.annotations.OrderBy(clause = "marks DESC") +// @SortComparator(MyComparator.class) + private List marks; + + @NaturalId + private String iCode; + +// @ElementCollection +// @CollectionTable(name = "PersonMap") +// @Column(name = "name") +// @MapKeyColumn(name = "'key'") +// private Map map; + + public Person() {} + public Person(String name, List homeAddress) { + this.name = name; + this.homeAddress = homeAddress; + } + + public Person(String name, List homeAddress, List marks) { + this.name = name; + this.homeAddress = homeAddress; + this.marks = marks; + } + + public Person(String name, List homeAddress, List marks, String iCode) { + this.name = name; + this.homeAddress = homeAddress; + this.marks = marks; + this.iCode = iCode; + } + + @Override + public String toString() { + return "Person{" + + "id=" + id + + ", name='" + name + '\'' + + ", homeAddress=" + homeAddress + + ", marks=" + marks + + ", iCode='" + iCode + '\'' + + '}'; + } +} diff --git a/hiber/src/entities/Role.java b/hiber/src/entities/Role.java new file mode 100644 index 0000000..dc916dc --- /dev/null +++ b/hiber/src/entities/Role.java @@ -0,0 +1,34 @@ +package entities; + +import javax.persistence.Entity; +import javax.persistence.GeneratedValue; +import javax.persistence.Id; + +@Entity +public class Role { + @Id + @GeneratedValue + int id; + String name; + + public Role() {} + public Role(String name) { + this.name = name; + } + + 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; + } +} diff --git a/hiber/src/entities/Student.java b/hiber/src/entities/Student.java new file mode 100644 index 0000000..0fe11f3 --- /dev/null +++ b/hiber/src/entities/Student.java @@ -0,0 +1,96 @@ +package entities; + +import enums.Days; +import org.hibernate.annotations.Formula; +import org.hibernate.annotations.UpdateTimestamp; + +import javax.persistence.*; +import java.util.Date; + +@Entity +//@Table(name = "stud") +public final class Student { +// @Id +// @GeneratedValue +// private int id; + +// private int id; +// @Basic(optional = false, fetch = FetchType.LAZY) +// @Column(name = "StudentName", unique = true, nullable = false, updatable = false) +// @Type(type = "text") + @Access(AccessType.FIELD) + private String name; + + @Enumerated(EnumType.STRING) + private Days days; + +// @Temporal(TemporalType.DATE) +// @CreationTimestamp + @UpdateTimestamp + private Date date; + + @EmbeddedId + private Address address; + + private int age = 20; + + @Formula("id + age") + private int idPlusAge; + + public Student() {} + + public Student(String name) { + this.name = name; + } + + public Student(String name, Days days) { + this.name = name; + this.days = days; + } + + public Student(String name, Days days, Date date) { + this.name = name; + this.days = days; + this.date = date; + } + +// public int getId() { +// return id; +// } +// +// public void setId(int id) { +// this.id = id; +// } + + public String getName() { + return "Mr. " + name; + } + + public void setName(String name) { + this.name = name; + } + + public Days getDays() { + return days; + } + + public void setDays(Days days) { + this.days = days; + } + + public int getIdPlusAge() { + return idPlusAge; + } + + public void setIdPlusAge(int idPlusAge) { + this.idPlusAge = idPlusAge; + } + + public Address getAddress() { + return address; + } + + public void setAddress(Address address) { + this.address = address; + } +} diff --git a/hiber/src/entities/User.java b/hiber/src/entities/User.java new file mode 100644 index 0000000..a7a0dec --- /dev/null +++ b/hiber/src/entities/User.java @@ -0,0 +1,43 @@ +package entities; + +import javax.persistence.*; +import java.util.List; + +@Entity +public class User { + @Id + @GeneratedValue + int id; + String name; + @OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY) + List roleList; + + public User() {} + public User(String name) { + this.name = name; + } + + 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 List getRoleList() { + return roleList; + } + + public void setRoleList(List roleList) { + this.roleList = roleList; + } +} diff --git a/hiber/src/entities/hierarchies/Car.java b/hiber/src/entities/hierarchies/Car.java new file mode 100644 index 0000000..f4d0462 --- /dev/null +++ b/hiber/src/entities/hierarchies/Car.java @@ -0,0 +1,66 @@ +package entities.hierarchies; + +import org.hibernate.annotations.Fetch; +import org.hibernate.annotations.FetchMode; +import org.hibernate.annotations.NamedQueries; +import org.hibernate.annotations.NamedQuery; + +import javax.persistence.Entity; +import javax.persistence.GeneratedValue; +import javax.persistence.Id; + +@Entity +//@Inheritance(strategy = InheritanceType.TABLE_PER_CLASS) +//@MappedSuperclass +//@OptimisticLocking(type = OptimisticLockType.VERSION) +//@Cacheable +//@Cache(usage = CacheConcurrencyStrategy.READ_ONLY) +@NamedQueries(@NamedQuery(name = "getCarByNumber", query = "select c from Car c where c.number = :number")) +public class Car { + @Id + @GeneratedValue + private int id; + @Fetch(FetchMode.SELECT) + private String number; +// @Version +// int version; + + public Car() {} + public Car(String number) { + this.number = number; + } + + public int getId() { + return id; + } + + public void setId(int id) { + this.id = id; + } + + public String getNumber() { + return number; + } + + public void setNumber(String number) { + this.number = number; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + + Car car = (Car) o; + + if (id != car.id) return false; + return number != null ? number.equals(car.number) : car.number == null; + } + + @Override + public int hashCode() { + int result = id; + result = 31 * result + (number != null ? number.hashCode() : 0); + return result; + } +} diff --git a/hiber/src/entities/hierarchies/Opel.java b/hiber/src/entities/hierarchies/Opel.java new file mode 100644 index 0000000..2828da3 --- /dev/null +++ b/hiber/src/entities/hierarchies/Opel.java @@ -0,0 +1,13 @@ +package entities.hierarchies; + +import javax.persistence.Entity; + +@Entity +public class Opel extends Car { + private int price; + + public Opel(String number, int price) { + super(number); + this.price = price; + } +} diff --git a/hiber/src/entities/hierarchies/Toyota.java b/hiber/src/entities/hierarchies/Toyota.java new file mode 100644 index 0000000..5b5b1ae --- /dev/null +++ b/hiber/src/entities/hierarchies/Toyota.java @@ -0,0 +1,13 @@ +package entities.hierarchies; + +import javax.persistence.Entity; + +@Entity +public class Toyota extends Car { + private String maxSpeed; + + public Toyota(String number, String maxSpeed) { + super(number); + this.maxSpeed = maxSpeed; + } +} diff --git a/hiber/src/enums/Days.java b/hiber/src/enums/Days.java new file mode 100644 index 0000000..e5db738 --- /dev/null +++ b/hiber/src/enums/Days.java @@ -0,0 +1,5 @@ +package enums; + +public enum Days { + MONDAY, TUESDAY, WEDNESDAY, THURSDAY, FRIDAY +} diff --git a/kotln/src/com/max/Annotations.kt b/kotln/src/com/max/Annotations.kt new file mode 100644 index 0000000..6e207b3 --- /dev/null +++ b/kotln/src/com/max/Annotations.kt @@ -0,0 +1,12 @@ +package com.max + +fun main(args: Array) { + +} +const val message = "" +@Deprecated(message) +@MyAnnotation("") +fun test() {} + +@Target(AnnotationTarget.PROPERTY, AnnotationTarget.CLASS, AnnotationTarget.FUNCTION) +annotation class MyAnnotation(val name: String) \ No newline at end of file diff --git a/kotln/src/com/max/BasicTypes.kt b/kotln/src/com/max/BasicTypes.kt new file mode 100644 index 0000000..f3373fa --- /dev/null +++ b/kotln/src/com/max/BasicTypes.kt @@ -0,0 +1,18 @@ +package com.max + +fun main(args: Array) { + val i: Int = 1 + val j: Int? = null + val l: Long = i.toLong() + val list: List = listOf(1, 2, 3) + l.toInt() in list + var any: Any = 5 + var any2: Any = "Str" + var any3: Any? = null + var unit: Unit +} +fun f(): Unit { } +fun fail(): Nothing { +// return Nothing() + throw IllegalStateException() +} \ No newline at end of file diff --git a/kotln/src/com/max/CallFunctions.kt b/kotln/src/com/max/CallFunctions.kt new file mode 100644 index 0000000..8b93b27 --- /dev/null +++ b/kotln/src/com/max/CallFunctions.kt @@ -0,0 +1,43 @@ +package com.max + +//import CallFunction.lastChar as last + +var i = 5; +fun main(args: Array) { + print(message = i) + def() +// print("ho".lastChar()) +// print("String".lastChar) + print("Hello " concat "world!" ) + print(arrayOf(1,2,3).size) + + //lot of code + print(i + 1) + //more code + + //lot of code + print(i + 2) + //more code + fun prnt(j: Int) { + //lot of code + print(i + j) + //more code + } + prnt(i + 1) + prnt(i + 2) +} +fun def(s: String = "hello") { + print(s) +} +//fun String.lastChar(): Char = get(length - 1)//don't work on inheritance +//fun String.lastChar(): Char = this.get(this.length - 1) +//val String.lastChar: Char get() = get(length - 1) +infix fun String.concat(other: String) = this + other + +fun arrayOf(vararg vals: Int): IntArray { + val array = IntArray(vals.size) + for(i in 0..vals.size - 1) { + array.set(i, vals[i]) + } + return array +} diff --git a/kotln/src/com/max/Classes.kt b/kotln/src/com/max/Classes.kt new file mode 100644 index 0000000..56bd562 --- /dev/null +++ b/kotln/src/com/max/Classes.kt @@ -0,0 +1,7 @@ +package com.max + +fun main(args: Array) { + var user = User("Max", 22) +} + +class User(name:String, age: Int) \ No newline at end of file diff --git a/kotln/src/com/max/Collections.kt b/kotln/src/com/max/Collections.kt new file mode 100644 index 0000000..09ef25c --- /dev/null +++ b/kotln/src/com/max/Collections.kt @@ -0,0 +1,12 @@ +package com.max +fun main(args: Array) { + val set = setOf(1, 1, 2) + val list = listOf(1, 2, 3) + val map = mapOf(1 to "one", 2 to "two") + print(set.first()) + print(set.last()) + print(set.size) + print(set.max()) + print(set.average()) + print(set) +} diff --git a/kotln/src/com/max/CollectionsArrays.kt b/kotln/src/com/max/CollectionsArrays.kt new file mode 100644 index 0000000..2853e44 --- /dev/null +++ b/kotln/src/com/max/CollectionsArrays.kt @@ -0,0 +1,15 @@ +package com.max + +fun main(args: Array) { + val result = ArrayList() + ///// + val arr1 = arrayOf(1,2,3) + val arr2 = arrayOfNulls(10) + val arr3 = Array(26) { i -> ('a' + i).toString() } + val arr4 = IntArray(5) + val arr5 = intArrayOf(0, 0, 0, 0, 0) + val arr6 = IntArray(5) { i -> (i+1) * (i+1) } +} +fun arrays(numbers: List) {} +fun arrays2(numbers: List?) {} +fun copyElements(source: Collection, target: MutableCollection, list: List, mutableList: MutableList) {} \ No newline at end of file diff --git a/kotln/src/com/max/Constructors.kt b/kotln/src/com/max/Constructors.kt new file mode 100644 index 0000000..fc69e4d --- /dev/null +++ b/kotln/src/com/max/Constructors.kt @@ -0,0 +1,71 @@ +package com.max + +fun main(args: Array) { +// var v = User2() +// v.name = "Mike" +// print(v.name) + var k = Client("Max", 1) + print(k) +} + +class Student(name: String) + +class Student2 constructor(_name: String = "Max") { + val name: String + init { + name = _name + } +} +class Student3(_nickname: String) +{ val nickname = _nickname} + +open class Student4 (val nickname: String) +class Student5(nickname: String) : Student4(nickname) + +open class Student6 +class Student7: Student6() + +class Student8 private constructor() + +open class Student9 { + constructor() + constructor(i: Int) +} + +//class Student10: Student9() { +class Student10: Student9 { +// constructor() + constructor(): this(5) + constructor(i: Int): super(5) {} +} + +///////////////// +interface User1 { + abstract val name: String + val nickname: String get() = name.substringBefore(' ') +} +class PrivateUser(override val name: String) : User1 +class SubscribingUser(val famiryName: String) : User1 { + override val name: String get() = famiryName.substringBefore(' ') +} +class User2 { + private var name: String = "Max" + get() = field + private set(value: String) { + field = value + } +} +/////////////// +data class Client(val name: String, val postalCode: Int) { +// override fun toString() = "Client(name=$name, postalCode=$postalCode)" +// override fun equals(other: Any?): Boolean { +// if (other == null || other !is Client) +// return false +// return name == other.name && postalCode == other.postalCode +// } +// override fun hashCode(): Int = name.hashCode() * 31 + postalCode +// fun copy(name: String = this.name, postalCode: Int = this.postalCode) = Client(name, postalCode) +} +/////////// +class DelegatingCollection(innerList: Collection = ArrayList()): Collection by innerList {} +//////////////// \ No newline at end of file diff --git a/kotln/src/com/max/ControlFlow.kt b/kotln/src/com/max/ControlFlow.kt new file mode 100644 index 0000000..2b94121 --- /dev/null +++ b/kotln/src/com/max/ControlFlow.kt @@ -0,0 +1,22 @@ +package com.max + +fun main(args: Array) { +// lookForAlice(people) +} + +fun lookForAlice(people: List) { + people.forEach label@{ + if (it.name == "Alice") return@label + } + println("Alice might be somewhere") +} + +fun lookForAlice2(people: List) { + people.forEach { + if (it.name == "Alice") { + println("Found!") + return@forEach + } + } + println("Alice is not found") +} \ No newline at end of file diff --git a/kotln/src/com/max/DelegatingProperties.kt b/kotln/src/com/max/DelegatingProperties.kt new file mode 100644 index 0000000..55437db --- /dev/null +++ b/kotln/src/com/max/DelegatingProperties.kt @@ -0,0 +1,18 @@ +package com.max + +import kotlin.reflect.KProperty + +fun main(args: Array) { + val foo = Foo() + print(foo.p) + foo.p = 6 + print(foo.p) +} +class Foo { + var p: Int by Delegate(5) +} + +class Delegate(var value: Int) { + operator fun getValue(foo: Foo, kProperty: KProperty<*>) :Int { return value } + operator fun setValue(foo: Foo, kProperty: KProperty<*>, value: Int) { this.value = value } +} \ No newline at end of file diff --git a/kotln/src/com/max/Enums.kt b/kotln/src/com/max/Enums.kt new file mode 100644 index 0000000..9a39342 --- /dev/null +++ b/kotln/src/com/max/Enums.kt @@ -0,0 +1,22 @@ +package com.max + +fun main(args: Array) { + val color = Color.BLUE + when(color) { + Color.RED,Color.GREEN -> print("red") + Color.BLUE -> print("blue") + } + print(bigger(5, 6)) +} + +fun bigger(a: Int, b: Int) = if(a > b) a else b + +enum class Color { + RED, ORANGE, YELLOW, GREEN, BLUE, INDIGO, VIOLET +} +enum class Color2(val r: Int, val g: Int, val b: Int) { + RED(255, 0, 0), ORANGE(255, 165, 0), + YELLOW(255, 255, 0), GREEN(0, 255, 0), BLUE(0, 0, 255), + INDIGO(75, 0, 130), VIOLET(238, 130, 238); + fun rgb() = (r * 256 + g) * 256 + b +} diff --git a/kotln/src/com/max/Exceptions.kt b/kotln/src/com/max/Exceptions.kt new file mode 100644 index 0000000..00c4d4b --- /dev/null +++ b/kotln/src/com/max/Exceptions.kt @@ -0,0 +1,18 @@ +package com.max + +import java.io.IOException + +fun main(args: Array) { + var i = try { + throw IOException("hello") + throw Exception("hello") + 1 + } catch (e: Exception) { + print("catch") + 2 + } finally { + print("finaly") + 3 + } + print(i as Int) +} \ No newline at end of file diff --git a/kotln/src/com/max/Functions.kt b/kotln/src/com/max/Functions.kt new file mode 100644 index 0000000..4e203e5 --- /dev/null +++ b/kotln/src/com/max/Functions.kt @@ -0,0 +1,5 @@ +package com.max +fun main(args: Array) { + +} +fun add(a: Int, b: Int) = a + b; \ No newline at end of file diff --git a/kotln/src/com/max/GenericVarience.kt b/kotln/src/com/max/GenericVarience.kt new file mode 100644 index 0000000..a164b59 --- /dev/null +++ b/kotln/src/com/max/GenericVarience.kt @@ -0,0 +1,20 @@ +package com.max + +fun main(args: Array) { + var list :List = ArrayList() + var producer :Producer = Producer() + var producer2 :Producer2 = Producer2() + var producer3 :Producer<*> = Producer() + var producer4 :Producer2<*> = Producer2() +} +class Producer { +// operator fun invoke():T +} +class Producer2 { + fun produce(t: T) {} +} +class Producer3 { +// operator fun invoke(t: T): R +} +open class Animal {} +class Cat : Animal() {} \ No newline at end of file diff --git a/kotln/src/com/max/Generics.kt b/kotln/src/com/max/Generics.kt new file mode 100644 index 0000000..46a33e1 --- /dev/null +++ b/kotln/src/com/max/Generics.kt @@ -0,0 +1,22 @@ +package com.max + +fun main(args: Array) { + val authors = listOf("Dmitry", "Svetlana") + val authors2 = listOf("Dmitry", 2) + val authors3: List = listOf("Dmitry", "Sveta") +// val authors4: List = listOf("Dmitry", "Sveta") +} + +fun gen(t: T, predicate: (T) -> T): T { + return t +} +interface MyList { + operator fun get(t: T): T = t +} +class StringList: MyList { +} +class GenericList: MyList { +} +fun oneHalf(value: T): Double { + return value.toDouble() / 2.0 +} \ No newline at end of file diff --git a/kotln/src/com/max/GenericsInRuntime.kt b/kotln/src/com/max/GenericsInRuntime.kt new file mode 100644 index 0000000..9d54a21 --- /dev/null +++ b/kotln/src/com/max/GenericsInRuntime.kt @@ -0,0 +1,18 @@ +package com.max + +import java.util.* +import javax.xml.ws.Service + +fun main(args: Array) { + var value: List = ArrayList() + check(value) + + val items = listOf("one", 2, "three") + println(items.filterIsInstance()) +} +fun check(value: Any) { +// value is List + value is List<*> +} +//fun isA(value: Any) = value is T +inline fun isA(value: Any) = value is T \ No newline at end of file diff --git a/kotln/src/com/max/Hierarhies.kt b/kotln/src/com/max/Hierarhies.kt new file mode 100644 index 0000000..12125d3 --- /dev/null +++ b/kotln/src/com/max/Hierarhies.kt @@ -0,0 +1,42 @@ +package com.max + +fun main(args: Array) { + var b: Clickable + b = Button(5) +} +interface Clickable{ + fun click(); + fun showOff() = println("I'm clickable!") +} +interface Focusable { + fun showOff() = println("focus") +} + +class Button(i:Int) : Clickable, Focusable { + override fun click() = println("I was clicked") + override fun showOff() = println("I'm Button!") +} + +open class RichButton : Clickable { + final override fun click() {} +} + +abstract class Animated { + abstract fun animate() + open fun stopAnimating() {} + private fun animateTwice() {} +} + +internal open class TalkativeButton : Focusable +{ private fun yell() = println("Hey!") + protected fun whisper() = println("Let's talk!") +} +var two = One().Two(); +class One { + inner class Two{} +} + +sealed class Expr { + class Num(val value: Int) : Expr() {} +} +class Sum() : Expr() {} \ No newline at end of file diff --git a/kotln/src/com/max/HighOrderFunctions.kt b/kotln/src/com/max/HighOrderFunctions.kt new file mode 100644 index 0000000..f959f05 --- /dev/null +++ b/kotln/src/com/max/HighOrderFunctions.kt @@ -0,0 +1,23 @@ +package com.max + +fun main(args: Array) { + val sum = { x: Int, y: Int -> x + y } + val action = { println(42) } + val sum2: (Int, Int) -> Int = { x, y -> x + y } + val action2: () -> Unit = { println(42) } + + twoAndThree { a, b -> a + b } + twoAndThree { a, b -> a * b } +} +fun twoAndThree(operation: (Int, Int) -> Int) { + val result = operation(2, 3) + println("The result is $result") +} +fun toString(transform: (it: Int) -> String? = { it.toString() }) {} + +fun getShippingCostCalculator(bool: Boolean): (i: Int) -> Double { + if (bool) { + return { i -> i * 1.5 } + } + return { i -> i * 1.3 } +} \ No newline at end of file diff --git a/kotln/src/com/max/InlineFunctions.kt b/kotln/src/com/max/InlineFunctions.kt new file mode 100644 index 0000000..2c91090 --- /dev/null +++ b/kotln/src/com/max/InlineFunctions.kt @@ -0,0 +1,30 @@ +package com.max + +import java.util.concurrent.locks.Lock + +fun main(args: Array) { + println(people.filter { it.age < 30 }) +} +inline fun synchronized(lock: Lock, noinline action: () -> T): T { + lock.lock() + try { + test(action) + return action() + } + finally { + lock.unlock() + } +} +fun test(action: () -> T) {} + +fun foo(l: Lock) { + println("Before sync") + synchronized(l) { + println("Action") + } + println("Action") +} +///////////collections +data class Person2(val name: String, val age: Int) +val people = listOf(Person2("Alice", 29), Person2("Bob", 31)) + diff --git a/kotln/src/com/max/Lambda.kt b/kotln/src/com/max/Lambda.kt new file mode 100644 index 0000000..fdfeab9 --- /dev/null +++ b/kotln/src/com/max/Lambda.kt @@ -0,0 +1,53 @@ +package com.max + +fun main(args: Array) { + val sum = { x: Int, y: Int -> x + y } + sum(1,2); + { println(42) }() + run { println(42) }; + { x: Int, y: Int -> print(x + y); print("" + x + y) }(1,2) + val getAge = { person: P -> person.age() } + val getAge2 = P::age + fun salute() = println("Salute!") + run(::salute) +// val action = { s: String, integer: Int -> +// two(s, integer) +// } +// val nextAction = ::two + val personContructor = ::P + val person = personContructor() + person.age() + + fun P.isAdult() = age() >= 21 + val predicate = P::isAdult + person.isAdult() +} +//fun two(s: String, integer: Int){} +class P() { + fun age(): Int = 5 +} +////////////////////// +class Person(var name: String, var age: Int) +fun collection() { + val list = listOf(1, 2, 3, 4) + list.filter { it % 2 == 0 } + list.map { it * it } + + val people = listOf(Person("Alice", 29), Person("Bob", 31)) + people.map { it.age > 30 } + people.map(Person::name) + + people.filter { it.age > 30 }.map(Person::name) + people.asSequence().filter { it.age > 30 }.map(Person::name).toList() + + val numbers = mapOf(0 to "zero", 1 to "one") + println(numbers.mapValues { it.value.toUpperCase() }) + + val canBeInClub27 = { p: Person -> p.age <= 27 } + println(people.all(canBeInClub27)) + println(people.any(canBeInClub27)) + println(!people.any(canBeInClub27)) + println(people.count(canBeInClub27)) + println(people.find(canBeInClub27))//first matching or null + println(people.groupBy { it.age }) +} \ No newline at end of file diff --git a/kotln/src/com/max/Loop.kt b/kotln/src/com/max/Loop.kt new file mode 100644 index 0000000..6249805 --- /dev/null +++ b/kotln/src/com/max/Loop.kt @@ -0,0 +1,14 @@ +package com.max +fun main(args: Array) { + var i = 1..10 + for(j in i) + print(j) + for(i in 10 downTo 1 step 1) + print(i) + for(i in 1..10) + print(i) + for(i in 1 until 10) + print(i) + for(j in i) + if(j !in 5..10) print(j) +} diff --git a/kotln/src/com/max/Main.kt b/kotln/src/com/max/Main.kt new file mode 100644 index 0000000..90cc8ee --- /dev/null +++ b/kotln/src/com/max/Main.kt @@ -0,0 +1,3 @@ +package com.max + +fun main(args: Array) {} \ No newline at end of file diff --git a/kotln/src/com/max/ObjectKeyword.kt b/kotln/src/com/max/ObjectKeyword.kt new file mode 100644 index 0000000..2824ab3 --- /dev/null +++ b/kotln/src/com/max/ObjectKeyword.kt @@ -0,0 +1,31 @@ +package com.max + +fun main(args: Array) { +// Bar.i = 6 +// Bar.printI() +// Bar2.Foo +// Bar2.getI() + var bar = Bar2.getBar() + var runnable = object : Runnable { + override fun run() { + //new thread + } + } +} + +object Bar { + var i = 5 + fun printI() { + print(i) + } + object Foo {} +} + +class Bar2 { + private constructor() + companion object Foo { + fun getBar() { + Bar2() + } + } +} \ No newline at end of file diff --git a/kotln/src/com/max/OverloadOperations.kt b/kotln/src/com/max/OverloadOperations.kt new file mode 100644 index 0000000..6052dea --- /dev/null +++ b/kotln/src/com/max/OverloadOperations.kt @@ -0,0 +1,60 @@ +package com.max + +import java.math.BigDecimal + +fun main(args: Array) { + val p1 = Point(10, 20) + val p2 = Point(30, 40) + println(p1 + p2) + var point = Point(1, 2) + point += Point(3, 4) + println(point) + + val list = arrayListOf(1, 2) + list += 3 + val newList = list + listOf(4, 5) + println(list) + println(newList) + + val p = Point(10, 20) + println(-p) + + /////compare + print(Point(0,0) == Point(0,0)) + print(Point(0,0) === Point(0,0)) + print(Point(0,0).equals(Point(0,0))) + + print(Point(0,0) > (Point(0,0))) + + ////collections and arrays + println(p[1]) + println(5 in Point(20, 30)) + + //destructing declaration +// val (x, y) = p +// println(x) +// println(y) +} +data class Point(val x: Int, val y: Int) : Comparable { + operator fun plus(other: Point): Point { + return Point(x + other.x, y + other.y) + } + operator fun unaryMinus(): Point { + return Point(-x, -y) + } +// operator fun inc(): Point { +// return Point(--x, --y) +// } + override fun compareTo(other: Point): Int { + return compareValuesBy(this, other, Point::x, Point::y) + } + operator fun get(index: Int): Int { + return when(index) {0 -> x 1 -> y else -> throw IndexOutOfBoundsException("Invalid coordinate $index") } + } + operator fun contains(i: Int): Boolean { + return i in this.x until this.y + } +// operator fun component1() = x +// operator fun component2() = y +} +operator fun BigDecimal.inc() = this + BigDecimal.ONE \ No newline at end of file diff --git a/kotln/src/com/max/Reflection.kt b/kotln/src/com/max/Reflection.kt new file mode 100644 index 0000000..8f4985d --- /dev/null +++ b/kotln/src/com/max/Reflection.kt @@ -0,0 +1,31 @@ +package com.max + +import kotlin.reflect.KFunction +import kotlin.reflect.full.memberProperties + +fun main(args: Array) { + val person = Person33("Alice", 29) + val kClass = person.javaClass.kotlin + println(kClass.simpleName) + kClass.memberProperties.forEach { println(it.name) } + + val kFunction = ::foo22 + kFunction.call(42) + + val kFunction2 = ::sum22 + println(kFunction2.invoke(1, 2) + kFunction2(3, 4)) + + val kProperty = ::counter + kProperty.setter.call(21) + println(kProperty.get()) + + val memberProperty = Person33::age + println(memberProperty.get(person)) +} + +class Person33(val name: String, val age: Int) + +fun foo22(x: Int) = println(x) +fun sum22(x: Int, y: Int) = x + y + +var counter = 0 \ No newline at end of file diff --git a/kotln/src/com/max/TypeSystem.kt b/kotln/src/com/max/TypeSystem.kt new file mode 100644 index 0000000..fa13f39 --- /dev/null +++ b/kotln/src/com/max/TypeSystem.kt @@ -0,0 +1,27 @@ +package com.max + +fun main(args: Array) { + var n: String? + n = "" +// n = null + strLen(n) + val x: String? = null +// var y: String = x + strLen2(x) + strLen2(x ?: "")//if null set "" + + var str = n as? String + val sNotNull: String = str!!//null pointer exception + + val s: String? = "" +// strLen(s) + s?.let { s -> strLen(s)} +} +fun strLen(s: String) = s.length +fun strLen2(s: String?) = if (s != null) s.length else 0 +fun strLen3(s: String?) = s?.length +class TypeSystem { + private lateinit var myString: String +} +fun String?.isNullOrBlank(): Boolean = + this == null || this.isBlank() \ No newline at end of file diff --git a/kotln/src/com/max/Variables.kt b/kotln/src/com/max/Variables.kt new file mode 100644 index 0000000..1aba14a --- /dev/null +++ b/kotln/src/com/max/Variables.kt @@ -0,0 +1,6 @@ +package com.max +fun main(args: Array) { + var a: Int + var b: String + var c = 5 +} diff --git a/mongo/resources/META-INF/persistence.xml b/mongo/resources/META-INF/persistence.xml new file mode 100644 index 0000000..7bd5823 --- /dev/null +++ b/mongo/resources/META-INF/persistence.xml @@ -0,0 +1,18 @@ + + + + org.eclipse.persistence.jpa.PersistenceProvider + entity.User + + + + + + + + + \ No newline at end of file diff --git a/mongo/src/ArrayInsert.java b/mongo/src/ArrayInsert.java new file mode 100644 index 0000000..e31aa6c --- /dev/null +++ b/mongo/src/ArrayInsert.java @@ -0,0 +1,26 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import org.bson.Document; + +import java.util.ArrayList; +import java.util.List; +import java.util.UUID; + +public class ArrayInsert { + public static void main(String args[]) { + try { + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection coll = db.getCollection("users"); + List documents = new ArrayList(); + for (int i = 0; i < 10; i++) { + documents.add(new Document("key", UUID.randomUUID().toString())); + } + coll.insertMany(documents); + } catch (Exception e) { + System.err.println(e.getClass().getName() + ": " + + e.getMessage()); + } + } +} diff --git a/mongo/src/BulkInsert.java b/mongo/src/BulkInsert.java new file mode 100644 index 0000000..ffbb74c --- /dev/null +++ b/mongo/src/BulkInsert.java @@ -0,0 +1,25 @@ +import com.mongodb.MongoClient; +import com.mongodb.bulk.BulkWriteResult; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import com.mongodb.client.model.InsertOneModel; +import com.mongodb.client.model.WriteModel; +import org.bson.Document; + +import java.util.ArrayList; +import java.util.List; + +public class BulkInsert { + public static void main(String[] args) { + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection users = db.getCollection("users"); + + List> documents = new ArrayList<>(); + documents.add(new InsertOneModel<>(new Document("name", "Den").append("age", 33))); + documents.add(new InsertOneModel<>(new Document("name", "Yen").append("age", 44))); + + BulkWriteResult bulkWriteResult = users.bulkWrite(documents); + System.out.println(bulkWriteResult.getMatchedCount()); + } +} diff --git a/mongo/src/EmbeddedInsert.java b/mongo/src/EmbeddedInsert.java new file mode 100644 index 0000000..8bce17a --- /dev/null +++ b/mongo/src/EmbeddedInsert.java @@ -0,0 +1,20 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import org.bson.Document; + +public class EmbeddedInsert { + public static void main( String args[] ){ + try{ + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection coll = db.getCollection("users"); + Document doc = new Document("name", "louis").append("age", 29).append("info", + new Document("email", "louis@mail.com").append("phone", "876-134-667")); + coll.insertOne(doc); + } + catch(Exception e){ + System.err.println( e.getClass().getName() + ": " + e.getMessage() ); + } + } +} diff --git a/mongo/src/HelloMongo.java b/mongo/src/HelloMongo.java new file mode 100644 index 0000000..7e37b2d --- /dev/null +++ b/mongo/src/HelloMongo.java @@ -0,0 +1,15 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoDatabase; +import com.mongodb.client.MongoIterable; + +public class HelloMongo { + public static void main( String args[] ){ + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + db.createCollection("myCollection"); + MongoIterable strings = db.listCollectionNames(); + for (String name : strings) { + System.out.println(name); + } + } +} diff --git a/mongo/src/HiberExample.java b/mongo/src/HiberExample.java new file mode 100644 index 0000000..61b812b --- /dev/null +++ b/mongo/src/HiberExample.java @@ -0,0 +1,19 @@ +import entity.User; + +import javax.persistence.EntityManager; +import javax.persistence.EntityManagerFactory; +import javax.persistence.Persistence; + +public class HiberExample { + public static void main(String[] args) throws InterruptedException { + EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory("mongo-ogm"); + EntityManager entityManager = entityManagerFactory.createEntityManager(); + + entityManager.getTransaction().begin(); + entityManager.persist(new User("Max3", 33)); + entityManager.getTransaction().commit(); + + entityManager.close(); + entityManagerFactory.close(); + } +} \ No newline at end of file diff --git a/mongo/src/Indexes.java b/mongo/src/Indexes.java new file mode 100644 index 0000000..ee84fda --- /dev/null +++ b/mongo/src/Indexes.java @@ -0,0 +1,20 @@ +import com.mongodb.BasicDBObject; +import com.mongodb.DBObject; +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import org.bson.Document; + +import static com.mongodb.client.model.Filters.eq; + +public class Indexes { + public static void main(String[] args) { + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection users = db.getCollection("users"); + users.createIndex(new BasicDBObject("name",1).append("age", 1)); + users.createIndex(new BasicDBObject("name", "text")); + DBObject search = new BasicDBObject("$search", "mytext"); + users.find(eq("$text", search)); + } +} diff --git a/mongo/src/Main.java b/mongo/src/Main.java new file mode 100644 index 0000000..dffc123 --- /dev/null +++ b/mongo/src/Main.java @@ -0,0 +1,12 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import org.bson.Document; + +public class Main { + public static void main(String[] args) { + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection users = db.getCollection("users"); + } +} \ No newline at end of file diff --git a/mongo/src/MongoAuth.java b/mongo/src/MongoAuth.java new file mode 100644 index 0000000..84d67d6 --- /dev/null +++ b/mongo/src/MongoAuth.java @@ -0,0 +1,18 @@ +import com.mongodb.MongoClient; +import com.mongodb.MongoCredential; +import com.mongodb.ServerAddress; +import com.mongodb.client.MongoDatabase; + +import java.util.Arrays; +import java.util.List; + +public class MongoAuth { + public static void main( String args[] ){ + MongoCredential credential = MongoCredential.createPlainCredential("root", "test", "1".toCharArray()); + List mongoCredentials = Arrays.asList(credential); + ServerAddress serverAddress = new ServerAddress("localhosst", 27017); + MongoClient mongoClient = new MongoClient(serverAddress, mongoCredentials); + MongoDatabase db = mongoClient.getDatabase("test");; + System.out.println("Successfully connected to MongoDB"); + } +} diff --git a/mongo/src/SampleDelete.java b/mongo/src/SampleDelete.java new file mode 100644 index 0000000..9e238e4 --- /dev/null +++ b/mongo/src/SampleDelete.java @@ -0,0 +1,19 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import com.mongodb.client.result.DeleteResult; +import org.bson.Document; + +import static com.mongodb.client.model.Filters.eq; + +public class SampleDelete { + public static void main( String args[] ){ + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection users = db.getCollection("users"); + users.deleteOne(eq("name", "max")); + DeleteResult deleteResult = users.deleteMany(eq("name", "max")); + System.out.println(deleteResult.getDeletedCount()); + users.drop(); + } +} diff --git a/mongo/src/SampleInsert.java b/mongo/src/SampleInsert.java new file mode 100644 index 0000000..3fb6cc5 --- /dev/null +++ b/mongo/src/SampleInsert.java @@ -0,0 +1,19 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import org.bson.Document; + +public class SampleInsert { + public static void main( String args[] ){ + try{ + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection coll = db.getCollection("users"); + Document doc = new Document("name", "Max").append("age", 25) .append("phone", "321-654-987"); + coll.insertOne(doc); + } + catch(Exception e){ + System.err.println( e.getClass().getName() + ": " + e.getMessage() ); + } + } +} diff --git a/mongo/src/SampleQuery.java b/mongo/src/SampleQuery.java new file mode 100644 index 0000000..aba651b --- /dev/null +++ b/mongo/src/SampleQuery.java @@ -0,0 +1,23 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoCursor; +import com.mongodb.client.MongoDatabase; +import org.bson.Document; + +public class SampleQuery { + public static void main( String args[] ){ + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection coll = db.getCollection("users"); + System.out.println(coll.count()); + + MongoCursor cursor = coll.find().iterator(); +// MongoCursor cursor1 = coll.find().skip(100).limit(5).iterator(); +// MongoCursor cursor2 = coll.find(eq("name", "john")).iterator(); +// MongoCursor cursor3 = coll.find(and(gt("age", 20), lte("age", 40))).iterator(); + while (cursor.hasNext()) { + Document doc = cursor.next(); + System.out.println(doc.toJson()); + } + } +} diff --git a/mongo/src/SampleUpdate.java b/mongo/src/SampleUpdate.java new file mode 100644 index 0000000..f9dc60d --- /dev/null +++ b/mongo/src/SampleUpdate.java @@ -0,0 +1,18 @@ +import com.mongodb.MongoClient; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import com.mongodb.client.result.UpdateResult; +import org.bson.Document; + +import static com.mongodb.client.model.Filters.eq; + +public class SampleUpdate { + public static void main( String args[] ){ + MongoClient mongoClient = new MongoClient("localhost", 27017); + MongoDatabase db = mongoClient.getDatabase("test"); + MongoCollection coll = db.getCollection("users"); + coll.updateOne(eq("name", "max"), new Document("$set", new Document("age", 50))); + UpdateResult updateResult = coll.updateMany(eq("name", "john"), new Document("$set", new Document("age", 50))); + System.out.println(updateResult.getModifiedCount()); + } +} diff --git a/mongo/src/entity/User.java b/mongo/src/entity/User.java new file mode 100644 index 0000000..439cb49 --- /dev/null +++ b/mongo/src/entity/User.java @@ -0,0 +1,52 @@ +package entity; + +import org.eclipse.persistence.nosql.annotations.DataFormatType; +import org.eclipse.persistence.nosql.annotations.Field; +import org.eclipse.persistence.nosql.annotations.NoSql; + +import javax.persistence.Entity; +import javax.persistence.GeneratedValue; +import javax.persistence.Id; + +@Entity +@NoSql(dataFormat= DataFormatType.MAPPED) +public class User { + @Id + @GeneratedValue + @Field(name="_id") + private String id; + String name; + int age; + + public User() { + } + + public User(String name, int age) { + this.name = name; + this.age = age; + } + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } + + 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; + } +} diff --git a/spark/pom.xml b/spark/pom.xml new file mode 100644 index 0000000..23d89e0 --- /dev/null +++ b/spark/pom.xml @@ -0,0 +1,47 @@ + + + 4.0.0 + + com.max + spark + 1.0-SNAPSHOT + jar + + + + org.apache.maven.plugins + maven-compiler-plugin + + 1.8 + 1.8 + + + + + + + + org.apache.spark + spark-core_2.11 + 2.2.0 + + + org.apache.spark + spark-hive_2.11 + 2.2.0 + + + mysql + mysql-connector-java + 6.0.6 + + + org.apache.spark + spark-streaming_2.11 + 2.2.0 + + + + \ No newline at end of file diff --git a/spark/src/main/java/com/max/BasicActions.java b/spark/src/main/java/com/max/BasicActions.java new file mode 100644 index 0000000..0a8b36b --- /dev/null +++ b/spark/src/main/java/com/max/BasicActions.java @@ -0,0 +1,26 @@ +package com.max; + +import org.apache.spark.SparkConf; +import org.apache.spark.api.java.JavaRDD; +import org.apache.spark.api.java.JavaSparkContext; + +import java.util.Arrays; + +public class BasicActions { + public static void main(String[] args) { + SparkConf conf = new SparkConf().setMaster("local").setAppName("wordCount"); + JavaSparkContext sc = new JavaSparkContext(conf); + + JavaRDD list = sc.parallelize(Arrays.asList(1, 2, 3)); + System.out.println(list.reduce((x,y) -> x + y)); + System.out.println(list.fold(0, (x,y) -> x + y)); +// System.out.println(list.aggregate(0, (x,y) -> x + y)); + System.out.println(list.collect()); + System.out.println(list.take(2)); + System.out.println(list.top(2)); + System.out.println(list.takeSample(false, 2)); + list.foreach(x -> System.out.print(x)); + System.out.println(list.count()); + System.out.println(list.countByValue()); + } +} diff --git a/spark/src/main/java/com/max/BasicTransformations.java b/spark/src/main/java/com/max/BasicTransformations.java new file mode 100644 index 0000000..856ca58 --- /dev/null +++ b/spark/src/main/java/com/max/BasicTransformations.java @@ -0,0 +1,35 @@ +package com.max; + +import org.apache.spark.SparkConf; +import org.apache.spark.api.java.JavaRDD; +import org.apache.spark.api.java.JavaSparkContext; + +import java.util.ArrayList; +import java.util.Arrays; + +public class BasicTransformations { + public static void main(String[] args) { + SparkConf conf = new SparkConf().setMaster("local").setAppName("wordCount"); + JavaSparkContext sc = new JavaSparkContext(conf); + + JavaRDD list = sc.parallelize(Arrays.asList(1, 2, 3)); + System.out.println("list"); + list.foreach(f -> System.out.println(f)); + JavaRDD map = list.map(i -> i * i); + System.out.println("map"); + map.foreach(f -> System.out.println(f)); + JavaRDD filter = map.filter(i -> i != 1); + System.out.println("filter"); + filter.foreach(f -> System.out.println(f)); + JavaRDD

Hello World!

Activation Failed

Activation Successful!