project package update

src/main/java/kr/co/swh/lecture/opensource/discord/project/DicAnalysis.java → src/main/java/kr/co/swh/lecture/opensource/project/discode/MakeSentimentalDictionary.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.discord.project;
+package kr.co.swh.lecture.opensource.project.discode;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -14,7 +14,7 @@ import org.apache.http.util.EntityUtils;
 
 import com.google.gson.Gson;
 
-public class DicAnalysis {
+public class MakeSentimentalDictionary {
 
 	public static void main(String[] args) {
 		// TODO Auto-generated method stub
@@ -38,8 +38,8 @@ public class DicAnalysis {
 		try {
 			response = client.execute(requestGet);
 			responseString = EntityUtils.toString(response.getEntity());
-			SentimentalDic[] value = gson.fromJson(responseString, SentimentalDic[].class);
-			for(SentimentalDic dic : value) {
+			SentimentalDictionary[] value = gson.fromJson(responseString, SentimentalDictionary[].class);
+			for(SentimentalDictionary dic : value) {
 				String insertTableSQL = "INSERT INTO SENTIMENTAL_DIC"
 						+ "(word_root, polarity) VALUES"
 						+ "(?,?)";

src/main/java/kr/co/swh/lecture/opensource/discord/project/SendJDA.java → src/main/java/kr/co/swh/lecture/opensource/project/discode/SendJDA.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.discord.project;
+package kr.co.swh.lecture.opensource.project.discode;
 
 import java.io.IOException;
 import java.sql.Connection;
@@ -30,7 +30,7 @@ public class SendJDA {
 	public static JDA jda;
 	public static void main(String[] args) {
 		// TODO Auto-generated method stub
-		List<SentimentalDic> dicList = initDatabase();
+		List<SentimentalDictionary> dicList = initDatabase();
 		JDABuilder jb = new JDABuilder(AccountType.BOT);
 		jb.setAutoReconnect(true);
 		jb.setStatus(OnlineStatus.DO_NOT_DISTURB);
@@ -45,9 +45,9 @@ public class SendJDA {
 		}
 	}
 
-	public static List<SentimentalDic> initDatas() {
+	public static List<SentimentalDictionary> initDatas() {
 		Gson gson = new Gson();
-		List<SentimentalDic> dicList = new ArrayList<SentimentalDic>();
+		List<SentimentalDictionary> dicList = new ArrayList<SentimentalDictionary>();
 		CloseableHttpClient client = HttpClients.createDefault();
 		HttpResponse response = null;
 		String responseString = "";
@@ -55,7 +55,7 @@ public class SendJDA {
 		try {
 			response = client.execute(requestGet);
 			responseString = EntityUtils.toString(response.getEntity());
-			SentimentalDic[] value = gson.fromJson(responseString, SentimentalDic[].class);
+			SentimentalDictionary[] value = gson.fromJson(responseString, SentimentalDictionary[].class);
 			dicList.addAll(Arrays.asList(value));
 		} catch (IOException e2) {
 			// TODO Auto-generated catch block
@@ -64,8 +64,8 @@ public class SendJDA {
 		return dicList;
 	}
 	
-	public static List<SentimentalDic> initDatabase(){
-		List<SentimentalDic> dicList = new ArrayList<SentimentalDic>();
+	public static List<SentimentalDictionary> initDatabase(){
+		List<SentimentalDictionary> dicList = new ArrayList<SentimentalDictionary>();
 		Connection connection = null;
 		try {
 			Class.forName("com.mysql.jdbc.Driver");
@@ -82,7 +82,7 @@ public class SendJDA {
 			statement = connection.createStatement();
 			ResultSet rs = statement.executeQuery("SELECT * FROM SENTIMENTAL_DIC;");
 			while(rs.next()){
-				SentimentalDic dic = new SentimentalDic();
+				SentimentalDictionary dic = new SentimentalDictionary();
 				dic.setWord_root(rs.getString("word_root"));
 				dic.setPolarity(String.valueOf(rs.getInt("polarity")));
 				dicList.add(dic);

src/main/java/kr/co/swh/lecture/opensource/discord/project/SentimentalDic.java → src/main/java/kr/co/swh/lecture/opensource/project/discode/SentimentalDictionary.java

@@ -1,6 +1,6 @@
-package kr.co.swh.lecture.opensource.discord.project;
+package kr.co.swh.lecture.opensource.project.discode;
 
-public class SentimentalDic {
+public class SentimentalDictionary {
 	private String word;
 	private String word_root;
 	private String polarity;

src/main/java/kr/co/swh/lecture/opensource/discord/project/TListener.java → src/main/java/kr/co/swh/lecture/opensource/project/discode/TListener.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.discord.project;
+package kr.co.swh.lecture.opensource.project.discode;
 
 import java.util.List;
 
@@ -13,9 +13,9 @@ import net.dv8tion.jda.api.events.message.MessageReceivedEvent;
 import net.dv8tion.jda.api.hooks.ListenerAdapter;
 
 public class TListener extends ListenerAdapter{
-	List<SentimentalDic> dicList;
+	List<SentimentalDictionary> dicList;
 	
-	public TListener(List<SentimentalDic> dicList) {
+	public TListener(List<SentimentalDictionary> dicList) {
 		this.dicList = dicList;
 	}
 	@Override
@@ -36,7 +36,7 @@ public class TListener extends ListenerAdapter{
 		for (LNode node : Analyzer.parseJava(msg.getContentRaw())) {
 			Morpheme m = node.morpheme();
 			if(!m.feature().head().equalsIgnoreCase("jks")) {
-				for(SentimentalDic dic : dicList) {
+				for(SentimentalDictionary dic : dicList) {
 					if(dic.getWord_root().equalsIgnoreCase(m.surface())){
 						count += Integer.parseInt(dic.getPolarity());
 					}

src/main/java/kr/co/swh/lecture/opensource/jsoup/news/A_CrawlClient.java → src/main/java/kr/co/swh/lecture/opensource/project/news/A_CrawlClient.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.jsoup.news;
+package kr.co.swh.lecture.opensource.project.news;
 
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;

src/main/java/kr/co/swh/lecture/opensource/jsoup/news/ArticleCrawlerModel.java → src/main/java/kr/co/swh/lecture/opensource/project/news/ArticleCrawlerModel.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.jsoup.news;
+package kr.co.swh.lecture.opensource.project.news;
 
 public class ArticleCrawlerModel {
 	

src/main/java/kr/co/swh/lecture/opensource/jsoup/news/ICrawlService.java → src/main/java/kr/co/swh/lecture/opensource/project/news/ICrawlService.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.jsoup.news;
+package kr.co.swh.lecture.opensource.project.news;
 
 public interface ICrawlService {
 	public void crawlling() throws Exception;

src/main/java/kr/co/swh/lecture/opensource/jsoup/news/NaverNewsCrawlSource.java → src/main/java/kr/co/swh/lecture/opensource/project/news/NaverNewsCrawlSource.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.jsoup.news;
+package kr.co.swh.lecture.opensource.project.news;
 
 import java.io.IOException;
 import java.util.HashMap;

src/main/java/kr/co/swh/lecture/opensource/sparkjava/news/Input.java → src/main/java/kr/co/swh/lecture/opensource/project/sparkjava/News.java

@@ -1,13 +1,13 @@
-package kr.co.swh.lecture.opensource.sparkjava.news;
+package kr.co.swh.lecture.opensource.project.sparkjava;
 
-public class Input {
+public class News {
 	private String category;
 	private String id;
 	private String date;
 	private String title;
 	private String script;
 	
-	public Input(String category, String id, String date, String title, String script) {
+	public News(String category, String id, String date, String title, String script) {
 		this.category = category;
 		this.id = id;
 		this.date = date;

src/main/java/kr/co/swh/lecture/opensource/sparkjava/news/Step1.java → src/main/java/kr/co/swh/lecture/opensource/project/sparkjava/Step1.java

@@ -1,4 +1,4 @@
-package kr.co.swh.lecture.opensource.sparkjava.news;
+package kr.co.swh.lecture.opensource.project.sparkjava;
 
 
 import static spark.Spark.get;
@@ -54,7 +54,7 @@ public class Step1 {
 			if(acc.equals("1")) res = stmt.executeQuery(acQuery);
 			else res = stmt.executeQuery(inacQuery);
 			while (res.next()) {
-				Input i = new Input(res.getString("category"), res.getString("id"), res.getString("date"), res.getString("title"), res.getString("script"));
+				News i = new News(res.getString("category"), res.getString("id"), res.getString("date"), res.getString("title"), res.getString("script"));
 				String academy2Json = new Gson().toJson(i);		
 				jArr.add(i);		// json문자열로 넣지 말고, 객체형태로 추가
 			}

src/main/python/kr/co/swh/lecture/opensource/project/twitter_crawler_streaming.py

@@ -0,0 +1,41 @@
+# https://imasoftwareengineer.tistory.com/97?category=791547
+import tweepy
+from tweepy.streaming import StreamListener
+from tweepy import OAuthHandler
+from tweepy import Stream
+import json
+
+# twitter 계정이 있다면 앱을 만들어서 등록
+# 그렇지 않을 시에는 데이터베이스에 있는 정보 등록
+consumer_key = 'M3ioqfTgFkX2x04cYj8zoxoqB'
+consumer_secret = 'W52Zj3NL4CCwN1ROFsJY2M6qP6AZtNtWu2Ppkvf21x7PkFnEcz'
+access_token = '728767904-rvWxQuaQ7kIpOibulxvoHipDT8pWuEoukp4GaFYu'
+access_secret = 'DrIV41WcnXKCTW1rDUAzmcD4alzq3cHYW90pfrOvvhuvL'
+
+# 리스너 - 스트리밍 API로 부터 값이 들어오면 아래의 리스너가 실행된다.
+class Listener(StreamListener):
+    def on_data(self, data):
+        try:
+            all_data = json.loads(data)
+            tweet = all_data["text"]
+            print(tweet)
+        except:
+            print('Err')
+
+    def on_error(self, status):
+        print("ERROR: " + str(status))
+
+def main():
+    # 리스너 생성
+    l = Listener()
+    auth = OAuthHandler(consumer_key, consumer_secret)
+    auth.set_access_token(access_token, access_secret)
+    stream = Stream(auth, l) # 리스너와 인증키을 통해 스트리밍 객체 생성
+
+    # 언어=한국어(ko), 해시태그=필터할 단어
+    stream.filter(languages=["ko"], track=['코로나'])
+
+if __name__ == '__main__':
+    main()
+
+main()

src/main/python/kr/co/swh/lecture/opensource/twitter/twitter_crawler_streaming.py

@@ -1,40 +1,42 @@
-# https://imasoftwareengineer.tistory.com/97?category=791547
-import tweepy
-from tweepy.streaming import StreamListener
-from tweepy import OAuthHandler
-from tweepy import Stream
-import json
-
-# twitter 계정이 있다면 앱을 만들어서 등록
-# 그렇지 않을 시에는 데이터베이스에 있는 정보 등록
-consumer_key = 'xx'
-consumer_secret = 'xx'
-access_token = 'xx'
-access_secret = 'xx'
-
-# 리스너 - 스트리밍 API로 부터 값이 들어오면 아래의 리스너가 실행된다.
-class Listener(StreamListener):
-    def on_data(self, data):
-        with open('sample.json', 'a', encoding='utf-8') as f:
-            json_data = json.loads(data)    # str -> json으로 변환
-            json.dump(json_data, f, ensure_ascii=False) # json을 원형 그대로 파일에 저장(인코딩 깨짐을 방지)
-            print(json_data)
-        return True
-
-    def on_error(self, status):
-        print("ERROR: " + str(status))
-
-def main():
-    # 리스너 생성
-    l = Listener()
-    auth = OAuthHandler(consumer_key, consumer_secret)
-    auth.set_access_token(access_token, access_secret)
-    stream = Stream(auth, l) # 리스너와 인증키을 통해 스트리밍 객체 생성
-
-    # 언어=한국어(ko), 해시태그=필터할 단어
-    stream.filter(languages=["ko"], track=['손흥민'])
-
-if __name__ == '__main__':
-    main()
-
+# https://imasoftwareengineer.tistory.com/97?category=791547
+import tweepy
+from tweepy.streaming import StreamListener
+from tweepy import OAuthHandler
+from tweepy import Stream
+import json
+
+# twitter 계정이 있다면 앱을 만들어서 등록
+# 그렇지 않을 시에는 데이터베이스에 있는 정보 등록
+consumer_key = 'xx'
+consumer_secret = 'xx'
+access_token = 'xx'
+access_secret = 'xx'
+
+# 리스너 - 스트리밍 API로 부터 값이 들어오면 아래의 리스너가 실행된다.
+class Listener(StreamListener):
+    def on_data(self, data):
+#         all_data = json.loads(data)
+#         tweet = all_data["text"]    # 트위터 내용 중 text 정보만 가져오고 싶을 때,
+        with open('sample.json', 'a', encoding='utf-8') as f:
+            json_data = json.loads(data)    # str -> json으로 변환
+            json.dump(json_data, f, ensure_ascii=False) # json을 원형 그대로 파일에 저장(인코딩 깨짐을 방지)
+            print(json_data)
+        return True
+
+    def on_error(self, status):
+        print("ERROR: " + str(status))
+
+def main():
+    # 리스너 생성
+    l = Listener()
+    auth = OAuthHandler(consumer_key, consumer_secret)
+    auth.set_access_token(access_token, access_secret)
+    stream = Stream(auth, l) # 리스너와 인증키을 통해 스트리밍 객체 생성
+
+    # 언어=한국어(ko), 해시태그=필터할 단어
+    stream.filter(languages=["ko"], track=['손흥민'])
+
+if __name__ == '__main__':
+    main()
+
 main()