C#文件加密辦法匯總。本站提示廣大學習愛好者:(C#文件加密辦法匯總)文章只能為提供參考,不一定能成為您想要的結果。以下是C#文件加密辦法匯總正文
在這篇文章中,我們將會看到如何在vert.x運用中應用HSQL,固然也能夠應用隨意率性JDBC,和應用vertx-jdbc-client供給的異步的API,這篇文章的代碼在github。
異步?
vert.x一個很主要的特色就是它的異步性。應用異步的API,不須要等成果前往,當有成果前往時,vert.x會自動告訴。為了解釋這個,我們來看一個簡略的例子。
我們假定有個add辦法。普通來講,會像int r = add(1, 1)如許來應用它。這是一個同步的API,所以你必需比及前往成果。異步的API會是如許:add(1, 1, r -> { /*do something with the result*/})。在這個版本中,你傳入了一個Handler,當成果盤算出來時才被挪用。這個辦法不前往任何器械,完成以下:
public void add(int a, int b, Handler<Integer> resultHandler) { int r = a + b; resultHandler.handle(r); }
為了不混雜概念,異步API其實不是多線程。像我們在add例子裡看到的,並沒有觸及多線程。
異步JDBC
看了一些根本的異步的API,如今懂得下vertx-jdbc-client。這個組件可以或許讓我們經由過程JDBC driver與數據庫交互。這些交互都是異步的,之前如許:
String sql = "SELECT * FROM Products"; ResultSet rs = stmt.executeQuery(sql);
如今要如許:
connection.query("SELECT * FROM Products", result -> { // do something with the result });
這個模子更高效,當成果出來後vert.x告訴,防止了期待成果。
增長maven依附
在pom.xml文件中增長兩個 Maven dependencies
<dependency> <groupId>io.vertx</groupId> <artifactId>vertx-jdbc-client</artifactId> <version>3.1.0</version> </dependency> <dependency> <groupId>org.hsqldb</groupId> <artifactId>hsqldb</artifactId> <version>2.3.3</version> </dependency>
第一個依附供給了vertx-jdbc-client,第二個供給了HSQL JDBC的驅動。假如你想應用別的一個數據庫,修正這個依附,同時你還須要修正JDBC url和JDBC driver名。
初始化JDBC client
創立JDBC 客戶端(client):
在MyFirstVerticle類中,聲明一個新變量JDBCClient jdbc,而且在start辦法中添加:
jdbc = JDBCClient.createShared(vertx, config(), "My-Whisky-Collection");
創立了一個JDBC client實例,應用verticle的設置裝備擺設文件設置裝備擺設JDBC client。這個設置裝備擺設文件須要供給上面的設置裝備擺設能力讓JDBC client正常任務:
url-JDBC url,例如:jdbc:hsqldb:mem:db?shutdown=true
_driver class-JDBC的驅動,例如:org.hsqldb.jdbcDriver
有了client,接上去須要銜接數據庫。銜接數據庫是經由過程應用jdbc.getConnection來完成的,jdbc.getConnection須要傳入一個Handler<AsyncResult<SQLConnection>>參數。我們深刻的懂得下這個類型。起首,這是一個Handler,是以當成果預備好時它就會被挪用。這個成果是AsyncResult<SQLConnection>的一個實例。AsyncResult是vert.x供給的一個構造,應用它可以或許曉得銜接數據庫的操作是勝利或掉敗了。假如勝利了,它就會供給一個成果,這裡成果是一個SQLConnection的實例。
當你吸收一個AsyncResult的實例時,代碼平日是:
if (ar.failed()) { System.err.println("The operation has failed...: " + ar.cause().getMessage()); } else { // Use the result: result = ar.result(); }
須要獲得到SQLConnection,然後啟動rest的運用。由於釀成了異步的,這須要轉變啟動運用的方法。是以,假如將啟動序列劃分紅多塊:
startBackend( (connection) -> createSomeData(connection, (nothing) -> startWebApp( (http) -> completeStartup(http, fut) ), fut ), fut);
startBackend- 獲得SQLConnection對象,然後挪用下一步
createSomeData- 初始化數據庫並拔出數據。當完成後,挪用下一步
startWebApp- 啟動web運用
completeStartup- 最初完成啟動
fut由vert.x傳入,告訴曾經啟動或許啟動進程中碰到的成績。
startBackend辦法:
private void startBackend(Handler<AsyncResult<SQLConnection>> next, Future<Void> fut) { jdbc.getConnection(ar -> { if (ar.failed()) { fut.fail(ar.cause()); } else { next.handle(Future.succeededFuture(ar.result())); } }); }
這個辦法獲得了一個SQLConnection對象,檢討操作能否完成。假如勝利,會挪用下一步。掉敗了,就會申報一個毛病。其他的辦法遵守異樣的形式:
檢討上一步操作能否勝利
處置營業邏輯
挪用下一步
SQL
客戶端曾經預備好了,如今寫SQL。從createSomeData辦法開端,這個辦法也是啟動次序中的一部門:
private void createSomeData(AsyncResult<SQLConnection> result, Handler<AsyncResult<Void>> next, Future<Void> fut) { if (result.failed()) { fut.fail(result.cause()); } else { SQLConnection connection = result.result(); connection.execute( "CREATE TABLE IF NOT EXISTS Whisky (id INTEGER IDENTITY, name varchar(100), " + "origin varchar(100))", ar -> { if (ar.failed()) { fut.fail(ar.cause()); connection.close(); return; } connection.query("SELECT * FROM Whisky", select -> { if (select.failed()) { fut.fail(ar.cause()); connection.close(); return; } if (select.result().getNumRows() == 0) { insert( new Whisky("Bowmore 15 Years Laimrig", "Scotland, Islay"), connection, (v) -> insert(new Whisky("Talisker 57° North", "Scotland, Island"), connection, (r) -> { next.handle(Future.<Void>succeededFuture()); connection.close(); })); } else { next.handle(Future.<Void>succeededFuture()); connection.close(); } }); }); } }
這個辦法檢討SQLConnection能否可用,然後履行一些SQL語句。起首,假如表不存在就創立表。看看上面代碼:
connection.execute( SQL statement, handler called when the statement has been executed )
handler吸收AsyncResult<Void>,例如:只要是告訴罷了,沒有現實前往的成果。
封閉銜接
操作完成後,別忘了封閉SQL鏈接。這個銜接會被放入銜接池而且可以被反復應用。
在這個handler的代碼裡,檢討了statement能否准確的履行了,假如准確,我們接上去檢討表能否含稀有據,假如沒有,將會應用insert辦法拔出數據:
private void insert(Whisky whisky, SQLConnection connection, Handler<AsyncResult<Whisky>> next) { String sql = "INSERT INTO Whisky (name, origin) VALUES ?, ?"; connection.updateWithParams(sql, new JsonArray().add(whisky.getName()).add(whisky.getOrigin()), (ar) -> { if (ar.failed()) { next.handle(Future.failedFuture(ar.cause())); return; } UpdateResult result = ar.result(); // Build a new whisky instance with the generated id. Whisky w = new Whisky(result.getKeys().getInteger(0), whisky.getName(), whisky.getOrigin()); next.handle(Future.succeededFuture(w)); }); }
這個辦法應用帶有INSERT(拔出)statement(聲明)的upateWithParams辦法,且傳入了值。這個辦法防止了SQL注入。一旦statement履行了(當數據庫沒有此條數據就會創立),就創立一個新的Whisky對象,主動生成ID。
帶稀有據庫(SQL)的REST
下面的辦法都是啟動次序的一部門。然則,關於挪用REST API的辦法又是怎樣樣的呢?以getAll辦法為例。這個辦法被web運用前端挪用,並檢索存儲的一切的產物:
private void getAll(RoutingContext routingContext) { jdbc.getConnection(ar -> { SQLConnection connection = ar.result(); connection.query("SELECT * FROM Whisky", result -> { List<Whisky> whiskies = result.result().getRows().stream().map(Whisky::new).collect(Collectors.toList()); routingContext.response() .putHeader("content-type", "application/json; charset=utf-8") .end(Json.encodePrettily(whiskies)); connection.close(); // Close the connection }); }); }
這個辦法取得了一個SQLConnection對象,然後收回一個查詢。一旦獲得到查詢成果,它會像之前的辦法一樣寫HTTP response。getOne、deleteOne、updateOne和addOne辦法都是一樣的。留意,在response以後,須要要封閉SQL銜接。
看下傳入到query辦法的handler供給的成果。獲得了一個包括了查詢成果的ResultSet。每行都是一個JsonObject,是以,假如你有一個數據對象應用JsonObject作為獨一的參數,那末創立這個對象很簡略。
測試
須要小小的更新下測試法式,增長設置裝備擺設JDBCClient。在MyFirstVerticleTest類中,將setUp辦法中創立的DeploymentOption對象修正成:
DeploymentOptions options = new DeploymentOptions() .setConfig(new JsonObject() .put("http.port", port) .put("url", "jdbc:hsqldb:mem:test?shutdown=true") .put("driver_class", "org.hsqldb.jdbcDriver") );
除http.port,還設置裝備擺設了JDBC url和JDBC驅動。測試時,應用的是一個內存數據庫。在src/test/resources/my-it-config.json文件中也要做異樣的修正。
{ "http.port": ${http.port}, "url": "jdbc:hsqldb:mem:it-test?shutdown=true", "driver_class": "org.hsqldb.jdbcDriver" }
src/main/conf/my-application-conf.json文件也異樣須要修正,這不是為了測試,而是為了運轉這個運用:
{ "http.port" : 8082, "url": "jdbc:hsqldb:file:db/whiskies", "driver_class": "org.hsqldb.jdbcDriver" }
這裡這個JDBC url和上一個文件的有點紛歧樣,由於須要將數據庫存儲到硬盤中。
展現時光!
開端構建法式:
mvn clean package
沒有修正API(沒有更改宣布的java文件和REST接口),測試應當是可以順遂的運轉的。
啟動運用:
java -jar target/my-first-app-1.0-SNAPSHOT-fat.jar -conf src/main/conf/my-application-conf.json
拜訪http://localhost:8082/assets/index.html,然後,你可以看到這個運用應用的是數據庫了。這一次,就算重啟運用,這些數據依然在,由於存儲產物被耐久化到硬盤裡了。
總結
這篇文章中,曉得了怎樣在vert.x裡應用JDBC數據庫,並沒有許多龐雜的器械。開端能夠會被這個異步的開辟模子驚奇到,然則,一旦你開端應用了,你就很難再歸去了。
下一次,我們將看到這個運用怎樣應用mongoDB來調換HSQL。
迎接存眷<a href="http://quanke.name/" rel="nofollow" ></a>
交換群:231419585
轉載請注明出處,感謝