テックメモ – ページ 29 – 自分用のメモです。内容が間違っていたり、作りかけで動作しないコードなどあるのでご注意ください。

2018-10-27

C# IEnumerable

ちょいメモ

    class MyEnum : IEnumerable<String>
    {
        public IEnumerator<string> GetEnumerator()
        {
            for(int i = 1; i <= 10; i++)
            {
                yield return i.ToString();
            }
        }

        //IEnumerator<string>はIEnumerableを継承しているので、
        //２つとも実装。ただし、下記の方は直接指定しないとアクセスできない。

        IEnumerator IEnumerable.GetEnumerator()
        {
            for (int i = 11; i <= 20; i++)
            {
                yield return i.ToString();
            }
        }
    }

    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();

            var m = new MyEnum();
            foreach (string s in m)
            {
                System.Diagnostics.Debug.Print(s);//1-10
            }

            IEnumerable n = new MyEnum();
            foreach (string s in n)
            {
                System.Diagnostics.Debug.Print(s);//10-20
            }
        }

    }

class MyEnum : IEnumerable<String>

{

public IEnumerator<string> GetEnumerator()

{

for(int i = 1; i <= 10; i++)

{

yield return i.ToString();

}

//IEnumerator<string>はIEnumerableを継承しているので、

//２つとも実装。ただし、下記の方は直接指定しないとアクセスできない。

IEnumerator IEnumerable.GetEnumerator()

{

for (int i = 11; i <= 20; i++)

{

yield return i.ToString();

}

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

var m = new MyEnum();

foreach (string s in m)

{

System.Diagnostics.Debug.Print(s);//1-10

}

IEnumerable n = new MyEnum();

foreach (string s in n)

{

System.Diagnostics.Debug.Print(s);//10-20

}

2018-10-26

C# ObservableCollection

ちょいメモ

    class Person
    {
        public string Name;
        public int Age;
    }

    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();

            ObservableCollection<Person> peoples = new ObservableCollection<Person>();
            peoples.Add(new Person { Name = "taro", Age = 1 });
            peoples.CollectionChanged += new System.Collections.Specialized.NotifyCollectionChangedEventHandler(Notify);

            //値の変更では反応しない。
            peoples[0].Name = "taro3";

            //ここで反応
            peoples.Add(new Person { Name = "jiro", Age = 2 });
        }
        private void Notify(object sender, EventArgs e)
        {
            MessageBox.Show("");
        }
        
    }

class Person

{

public string Name;

public int Age;

}

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

ObservableCollection<Person> peoples = new ObservableCollection<Person>();

peoples.Add(new Person { Name = "taro", Age = 1 });

peoples.CollectionChanged += new System.Collections.Specialized.NotifyCollectionChangedEventHandler(Notify);

//値の変更では反応しない。

peoples[0].Name = "taro3";

//ここで反応

peoples.Add(new Person { Name = "jiro", Age = 2 });

}

private void Notify(object sender, EventArgs e)

{

MessageBox.Show("");

}

2018-10-252020-05-05

デザインパターン一言メモ

Adapter

IAdapterがAdapteeに委譲。

継承で実現する場合もある。

Prototype

IPrototypeが自身を複製。

Memento

OriginatorがMementoを作成、復元。

State/Strategy

IState/IStrategyでポリモーフィズム。

具体的にはclientからIState/IStrategyを利用し、インスタンスもclient内で生成することが多い。
インスタンス生成時に条件分岐等でアルゴリズムの切替え、状態の切替えを実施。

Decorator

IComponentを共通で実装。
ConcreateComponentからDecoratorに処理を委譲。

Composite

IComponentを共通で実装。
CompositeとLeafがある。
CompsiteがIComponentのコレクションを保持。

Proxy

ISubjectを共通で実装。
Proxyが自分で処理をすることも必要ならRealSubjectに処理を委譲することもできる。

Flyweight

FlyweightFactoryでFlyweigthインスタンスを生成し自身のpoolコレクションに保存。
利用時も既にインスタンスが存在すれば、それを利用する。

Singleton

コンストラクタをprivateにする。
自身のstaticメンバーにインスタンスを保存

Iterator

IIteratorにIAggregateのコレクションを保持する。
IAggregateでIIteratorのインスタンス生成して利用する。

Template Method

テンプレートメソッドはabstractメソッドのみ使う。
サブクラスでabstractメソッドを実装。
スーパークラスがサブクラスをコントロール。

Builder

DirectorはIBuilderで定義したメソッドのみ使う。
DirectorがBuilderをコントロール。

Factory Method

Template Methodと同じ構造。
インスタンス生成が必要な部分をサブクラスで実装。

Factory抽象クラスの中で実装したcreateで抽象createProductなどインスタンス生成の手順を定義し、サブクラスでcreateProductを実装する。

インスタンス生成のコントロールを得るという点から下記のような方法が有名。
(Factory Methodをパラメータ化)

Class Test {
Test(int type){
_type = type;
}
}

↓

Class Test{
private Test(int type){ //コンストラクタをprivate
_type = type;
}
static create(int type){ //インスタンス生成メソッドを準備
return new Test(type);
}
}

Abstract Factory

IFactoryでIProduct1,IProduct2の生成を定義。
どのような部品セット(1,2)なのかをIFactoryで定義し、IProductでそれぞれの処理を定義。

Bridge

継承と実装を分離。
機能追加は、Abstractionを継承したRefinedAbstractionに。
実装は、Abstractionより委譲されたImplementorに。

Visitor

IVisitorはデータ構造ごとのvisitを実装する。
IAcceptorのacceptの中でvisitを呼び、自身をvisitに渡す。
ダブルディパッチ。

Chain of Responsibility

IHandlerは転送先のIHandlerを自身に持ち
処理が完了か次が見つからないとき以外は次に転送し続ける。

Facade

サブシステム化し、単純な窓口を提供。

Mediator

IMediatorでIColleaugeを生成しメンバーとして保持、さらにIColleauge.SetMediatorで自身を渡す。
IColleaugeは自身に変更があったらIMediator.ColleagueChangedでIMediatorに通知。
IMediatorはColleagueChangedが呼ばれたとき、保持するIColleaugeすべての状態からロジックを判断する。

Observer

ISubjectがIObserverを保持しISubjectが変化したらIObserver.Updateを呼ぶ。
被験者が観察者のインスタンスを保持する。

Command

処理の呼び出しをメッセージからオブジェクトにする。

ICommandはExecuteを定義し、Receiverを保持。
Receiverは実際のActionを定義しICommand.Excuteの中でReceiver.Actionを呼ぶ。
Invokerは起動者でボタンのようなイメージ。

Interpreter

独自構文の文字列をContextに渡しトークン解析する。
ContextはhasNextやnextTokenなどで解析したトークンを取得できる。

構文解析クラスは文法ごとにIAbstractExpression実装した
TerminalExpression、NonterminalExpressionを準備。
NonterminalExpression1、NonterminalExpression2、TerminalExpression
のようにそれぞれ作成する。

実際は、
NonterminalExpression1.Parse(new Context(文字列))のように渡されると、
NonterminalExpression1の内部でnew NonterminalExpression2.Parse(context)
のように最後のTerminalExpressionまで内部で呼ぶ。

Null Object

IAbstractionをRealObjectとNullObjectが実装。
IAbstraction.Request()でRealObjectを返すが、Request()がNullを返す場合はNullObjectを返す。

2018-10-192020-05-06

golang jwt-go 色々

基本的な生成と検証のみ

package main

import (
	"errors"
	"log"

	jwt "github.com/dgrijalva/jwt-go"
)

/*

・Jwt構成

Base64urlでエンコードされている。
"+" > "-"
"/" > "_"
"=" > ""

Jwtは3パート、ヘッダー、ペイロード、署名がある。
ヘッダーはtypとalgで構成。
ペイロードはClaim(属性)で必須はないが予約パラメータはある。
署名はエンコ済みヘッダーとペイロードをピリオドでつないで、algのアルゴリズムで署名したもの。

・Bearer認証(トークンを持ってきたら認証する方式)

トークンをヘッダーに付与する場合、Authorizationヘッダーに付与する。
(カスタムヘッダー(x-付)にすることもできる)

ヘッダー形式
Authorization: auth-scheme credential
auth-schemeの１つとしてBearer

Bearer認証のヘッダー形式
Authorization: Bearer token68

*/

func main() {

	tokenString := createToken("123")
	log.Print(tokenString)

	//生成した文字列をそのままチェックしてみる。
	log.Print(authToken(tokenString, "123")) //ok

	//生成した文字列を違うキーでチェックしてみる。
	log.Print(authToken(tokenString, "234")) //signature is invalid

}

func createToken(key string) string {

	/*

		生成方法いくつか

		token := jwt.New(jwt.SigningMethodHS256)
		c := token.Claims.(jwt.MapClaims)
		c["user"] = "taro"

		--------------------------------------------------------

		c := jwt.StandardClaims{
			Audience: "taro",
		}
		token := jwt.NewWithClaims(jwt.SigningMethodHS256, c)

		--------------------------------------------------------

		type User struct {
			Name string
			jwt.StandardClaims
		}

		token := jwt.NewWithClaims(jwt.GetSigningMethod("HS256"), &User{
			Name: "taro",
		})

	*/

	//電子署名
	token := jwt.New(jwt.SigningMethodHS256)

	//属性情報
	c := token.Claims.(jwt.MapClaims)
	c["user"] = "taro"

	/*

		標準Claimが準備されている

	*/

	//keyで文字列化
	tokenString, _ := token.SignedString([]byte(key))
	return tokenString
}

func authToken(tokenString string, key string) string {

	//keyでtoken化
	token, err := jwt.Parse(tokenString, func(token *jwt.Token) (interface{}, error) {

		//このようなアルゴリズムチェックを入れている記事が多い。
		//HMAC(共通),ECDSA,RSA(公開)
		if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok {
			return nil, errors.New("alg error")
		}

		//keyを返す
		return []byte(key), nil

	})

	if err != nil {
		log.Print(err)
		return ""
	}

	if !token.Valid {
		return "valid error"
	}

	return "ok"
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

package main

import (

"errors"

"log"

jwt "github.com/dgrijalva/jwt-go"

)

・Jwt構成

Base64urlでエンコードされている。

"+" > "-"

"/" > "_"

"=" > ""

Jwtは3パート、ヘッダー、ペイロード、署名がある。

ヘッダーはtypとalgで構成。

ペイロードはClaim(属性)で必須はないが予約パラメータはある。

署名はエンコ済みヘッダーとペイロードをピリオドでつないで、algのアルゴリズムで署名したもの。

・Bearer認証(トークンを持ってきたら認証する方式)

トークンをヘッダーに付与する場合、Authorizationヘッダーに付与する。

(カスタムヘッダー(x-付)にすることもできる)

ヘッダー形式

Authorization: auth-scheme credential

auth-schemeの１つとしてBearer

Bearer認証のヘッダー形式

Authorization: Bearer token68

func main() {

tokenString := createToken("123")

log.Print(tokenString)

//生成した文字列をそのままチェックしてみる。

log.Print(authToken(tokenString, "123")) //ok

//生成した文字列を違うキーでチェックしてみる。

log.Print(authToken(tokenString, "234")) //signature is invalid

}

func createToken(key string) string {

生成方法いくつか

token := jwt.New(jwt.SigningMethodHS256)

c := token.Claims.(jwt.MapClaims)

c["user"] = "taro"

--------------------------------------------------------

c := jwt.StandardClaims{

Audience: "taro",

}

token := jwt.NewWithClaims(jwt.SigningMethodHS256, c)

--------------------------------------------------------

type User struct {

Name string

jwt.StandardClaims

}

token := jwt.NewWithClaims(jwt.GetSigningMethod("HS256"), &User{

Name: "taro",

})

//電子署名

token := jwt.New(jwt.SigningMethodHS256)

//属性情報

c := token.Claims.(jwt.MapClaims)

c["user"] = "taro"

標準Claimが準備されている

//keyで文字列化

tokenString, _ := token.SignedString([]byte(key))

return tokenString

}

func authToken(tokenString string, key string) string {

//keyでtoken化

token, err := jwt.Parse(tokenString, func(token *jwt.Token) (interface{}, error) {

//このようなアルゴリズムチェックを入れている記事が多い。

//HMAC(共通),ECDSA,RSA(公開)

if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok {

return nil, errors.New("alg error")

}

//keyを返す

return []byte(key), nil

})

if err != nil {

log.Print(err)

return ""

}

if !token.Valid {

return "valid error"

}

return "ok"

}

2018-10-092020-05-10

VBA SQL実験用③(SQL Server)

以前作ったものにSELECT以外も動くように少し修正。SQLの動きを調べるのにエクセルからテーブルの作成やSQLの実行ができると楽。

Sub auto_open()

Application.CommandBars("cell").Reset

With Application.CommandBars("cell").Controls.Add
.OnAction = "t"
.Caption = "テーブル作成・登録"
End With

With Application.CommandBars("cell").Controls.Add
.OnAction = "e"
.Caption = "SQL実行"
End With

End Sub

Sub auto_close()

On Error Resume Next

For i = 1 To 2
  Application.CommandBars("cell").Controls("テーブル作成・登録").Delete
  Application.CommandBars("cell").Controls("SQL実行").Delete
Next i

End Sub

Sub t()

Set cn = CreateObject("adodb.connection")
cn.Open "Provider=SQLOLEDB;Data Source=PC\SQLEXPRESS;Initial Catalog=my_database;Integrated Security=SSPI;"

tbl = InputBox("テーブル名")
If tbl = "" Then Exit Sub

'テーブル削除

On Error Resume Next
cn.Execute "drop table " & tbl

'テーブル作成

On Error GoTo 0

fld = ""

For c = Selection(1).Column To Selection(Selection.Count).Column

  Select Case Right(ActiveSheet.Cells(Selection(1).Row, c).Value, 1)
    Case "s"
    tmp = "varchar(255)"
    Case "i"
    tmp = "bigint"
    Case "m"
    tmp = "money"
    Case "d"
    tmp = "datetime"
  End Select
  
  fld = fld & ActiveSheet.Cells(Selection(1).Row, c).Value & " " & tmp & ","

Next c

fld = Left(fld, Len(fld) - 1)

q = "create table " & tbl & " (id integer identity(1,1) primary key," & fld & ")": Debug.Print q
cn.Execute q

'データ登録

fld = ""

For c = Selection(1).Column To Selection(Selection.Count).Column
  fld = fld & ActiveSheet.Cells(Selection(1).Row, c).Value & ","
Next c

fld = Left(fld, Len(fld) - 1)

For r = (Selection(1).Row) + 1 To Selection(Selection.Count).Row
  For cc = Selection(1).Column To Selection(Selection.Count).Column
    rec = rec & "'" & ActiveSheet.Cells(r, cc).Value & "'" & ","
  Next cc

  rec = Left(rec, Len(rec) - 1)
  
  q = "insert into " & tbl & " (" & fld & ") values (" & rec & ")": Debug.Print q
  cn.Execute q

  rec = ""
Next r

If cn.State = 1 Then cn.Close
Set cn = Nothing

MsgBox "done"

End Sub

Sub s(q)

Set cn = CreateObject("adodb.connection")
Set rn = CreateObject("adodb.recordset")

cn.Open "Provider=SQLOLEDB;Data Source=PC\SQLEXPRESS;Initial Catalog=my_database;Integrated Security=SSPI;"
rn.Open q, cn

'フィールド作成

i = 0

For c = Selection(1).Column To (Selection(1).Column + rn.Fields.Count) - 1
  Cells(Selection(Selection.Count).Row + 1, c).Value = rn.Fields(i).Name
  i = i + 1
Next c

'データ読込

Cells(Selection(Selection.Count).Row + 2, Selection(1).Column).CopyFromRecordset rn

If rn.State = 1 Then rn.Close
Set rn = Nothing

If cn.State = 1 Then cn.Close
Set cn = Nothing

End Sub

Sub o(q)

Set cn = CreateObject("adodb.connection")

cn.Open "Provider=SQLOLEDB;Data Source=PC\SQLEXPRESS;Initial Catalog=my_database;Integrated Security=SSPI;"
cn.Execute q

If cn.State = 1 Then cn.Close
Set cn = Nothing

End Sub

Sub e()

If Selection.Rows.Count = 1 Then
  q = ActiveCell.Value
Else
  For r = 1 To Selection.Rows.Count
    q = q & " " & Selection(r)
  Next r
End If

If Left(q, 1) = "s" Then
  s (q)
Else
  o (q)
End If

End Sub

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

Sub auto_open()

Application.CommandBars("cell").Reset

With Application.CommandBars("cell").Controls.Add

.OnAction = "t"

.Caption = "テーブル作成・登録"

End With

With Application.CommandBars("cell").Controls.Add

.OnAction = "e"

.Caption = "SQL実行"

End With

End Sub

Sub auto_close()

On Error Resume Next

For i = 1 To 2

Application.CommandBars("cell").Controls("テーブル作成・登録").Delete

Application.CommandBars("cell").Controls("SQL実行").Delete

Next i

End Sub

Sub t()

Set cn = CreateObject("adodb.connection")

cn.Open "Provider=SQLOLEDB;Data Source=PC\SQLEXPRESS;Initial Catalog=my_database;Integrated Security=SSPI;"

tbl = InputBox("テーブル名")

If tbl = "" Then Exit Sub

'テーブル削除

On Error Resume Next

cn.Execute "drop table " & tbl

'テーブル作成

On Error GoTo 0

fld = ""

For c = Selection(1).Column To Selection(Selection.Count).Column

Select Case Right(ActiveSheet.Cells(Selection(1).Row, c).Value, 1)

Case "s"

tmp = "varchar(255)"

Case "i"

tmp = "bigint"

Case "m"

tmp = "money"

Case "d"

tmp = "datetime"

End Select

fld = fld & ActiveSheet.Cells(Selection(1).Row, c).Value & " " & tmp & ","

Next c

fld = Left(fld, Len(fld) - 1)

q = "create table " & tbl & " (id integer identity(1,1) primary key," & fld & ")": Debug.Print q

cn.Execute q

'データ登録

fld = ""

For c = Selection(1).Column To Selection(Selection.Count).Column

fld = fld & ActiveSheet.Cells(Selection(1).Row, c).Value & ","

Next c

fld = Left(fld, Len(fld) - 1)

For r = (Selection(1).Row) + 1 To Selection(Selection.Count).Row

For cc = Selection(1).Column To Selection(Selection.Count).Column

rec = rec & "'" & ActiveSheet.Cells(r, cc).Value & "'" & ","

Next cc

rec = Left(rec, Len(rec) - 1)

q = "insert into " & tbl & " (" & fld & ") values (" & rec & ")": Debug.Print q

cn.Execute q

rec = ""

Next r

If cn.State = 1 Then cn.Close

Set cn = Nothing

MsgBox "done"

End Sub

Sub s(q)

Set cn = CreateObject("adodb.connection")

Set rn = CreateObject("adodb.recordset")

cn.Open "Provider=SQLOLEDB;Data Source=PC\SQLEXPRESS;Initial Catalog=my_database;Integrated Security=SSPI;"

rn.Open q, cn

'フィールド作成

i = 0

For c = Selection(1).Column To (Selection(1).Column + rn.Fields.Count) - 1

Cells(Selection(Selection.Count).Row + 1, c).Value = rn.Fields(i).Name

i = i + 1

Next c

'データ読込

Cells(Selection(Selection.Count).Row + 2, Selection(1).Column).CopyFromRecordset rn

If rn.State = 1 Then rn.Close

Set rn = Nothing

If cn.State = 1 Then cn.Close

Set cn = Nothing

End Sub

Sub o(q)

Set cn = CreateObject("adodb.connection")

cn.Open "Provider=SQLOLEDB;Data Source=PC\SQLEXPRESS;Initial Catalog=my_database;Integrated Security=SSPI;"

cn.Execute q

If cn.State = 1 Then cn.Close

Set cn = Nothing

End Sub

Sub e()

If Selection.Rows.Count = 1 Then

q = ActiveCell.Value

Else

For r = 1 To Selection.Rows.Count

q = q & " " & Selection(r)

Next r

End If

If Left(q, 1) = "s" Then

s (q)

Else

o (q)

End If

End Sub

2018-10-092020-05-06

golang 簡易テスト実施

package FileList

type FileList struct {
	lists []string
}

func NewList() *FileList {
	c := new(FileList)
	c.lists = make([]string, 0)
	return c
}

func (c *FileList) Add(s string) {
	c.lists = append(c.lists, s)
}

func (c *FileList) GetAll() []string {
	return c.lists
}

package FileList

type FileList struct {

lists []string

}

func NewList() *FileList {

c := new(FileList)

c.lists = make([]string, 0)

return c

}

func (c *FileList) Add(s string) {

c.lists = append(c.lists, s)

}

func (c *FileList) GetAll() []string {

return c.lists

}

package FileList

import (
	"log"
	"testing"
)

//TestXXXとする
func TestA(t *testing.T) {

	fileList := NewList()
	fileList.Add("鉛筆")
	fileList.Add("ボールペン")

	f := fileList.GetAll()
	if len(f) != 2 {
		t.Fatalf("length error %d", len(f))
		//Fatalは失敗時テスト終了
	}

	if f[1] != "鉛筆" {
		t.Error("鉛筆なし")
		t.Log(f)
	}

	log.Print("done")
}

package FileList

import (

"log"

"testing"

)

//TestXXXとする

func TestA(t *testing.T) {

fileList := NewList()

fileList.Add("鉛筆")

fileList.Add("ボールペン")

f := fileList.GetAll()

if len(f) != 2 {

t.Fatalf("length error %d", len(f))

//Fatalは失敗時テスト終了

}

if f[1] != "鉛筆" {

t.Error("鉛筆なし")

t.Log(f)

}

log.Print("done")

}

2018-10-052020-05-06

golang チャンネル

package main

import (
	"fmt"
	"log"
)

func main() {

	//定義
	c := make(chan int)

	/*
		capacityはchannel内でのバッファ
		capacityに空きがないと送信側で処理待ちになる

		非同期の終了待ちは途中で抜けると送信側の処理待ちが残ってしまう

		closeしたチャンネルは操作できない
	*/

	go func(s chan<- int) {

		for i := 0; i < 5; i++ {
			s <- i //送信
		}

		close(s) //受信側でcloseを検知する

	}(c) //即時関数の引数にcを渡している

	//close待ちする場合(非同期の終了待ち)
	<-c

	//for-rangeで受信
	for v := range c {
		fmt.Println(v)
	}

	//forで受信
	//closeの場合okがfalse
	for {
		value, ok := <-c
		if !ok {
			break
		}
		fmt.Println(value)
	}

	//すべて受信(closeの場合0)
	vv := <-c
	log.Print("_", vv)

}

package main

import (

"fmt"

"log"

)

func main() {

//定義

c := make(chan int)

capacityはchannel内でのバッファ

capacityに空きがないと送信側で処理待ちになる

非同期の終了待ちは途中で抜けると送信側の処理待ちが残ってしまう

closeしたチャンネルは操作できない

go func(s chan<- int) {

for i := 0; i < 5; i++ {

s <- i //送信

}

close(s) //受信側でcloseを検知する

}(c) //即時関数の引数にcを渡している

//close待ちする場合(非同期の終了待ち)

<-c

//for-rangeで受信

for v := range c {

fmt.Println(v)

}

//forで受信

//closeの場合okがfalse

for {

value, ok := <-c

if !ok {

break

}

fmt.Println(value)

}

//すべて受信(closeの場合0)

vv := <-c

log.Print("_", vv)

}

2018-10-042020-05-06

golang クロージャ

package main

import (
	"log"
)

/*
無名関数が定義された環境(スコープ)の変数が保存される
*/

func main() {
	f := out()
	f()//11
	f()//12
}

func out() func() {

	i := 10
	return func() {
		i++
		log.Print(i)
	}
}

package main

import (

"log"

)

無名関数が定義された環境(スコープ)の変数が保存される

func main() {

f := out()

f()//11

f()//12

}

func out() func() {

i := 10

return func() {

i++

log.Print(i)

}

2018-10-032020-05-06

golang sshでdbのバックアップ

サーバーにあるwordpressのDBをバックアップしようと思い、sshを調べた。
ファイルの転送に手軽な方法がなかったため標準出力をファイルへ書き出すことに。

package main

import (
	"io/ioutil"
	"log"
	"os"

	"golang.org/x/crypto/ssh"
)

func main() {

	host := ""
	port := ""
	user := ""

	backupQuery := "mysqldumpする"
	downloadQuery := "catする"

	buf, err := ioutil.ReadFile("id_rsa.pem") //openssl rsa -in ~/.ssh/id_rsa -outform pem > id_rsa.pem
	if err != nil {
		log.Print(err)
		return
	}
	key, err := ssh.ParsePrivateKey(buf)
	if err != nil {
		log.Print(err)
		return
	}

	config := &ssh.ClientConfig{
		User: user,
		Auth: []ssh.AuthMethod{
			ssh.PublicKeys(key),
		},
		HostKeyCallback: ssh.InsecureIgnoreHostKey(),
	}

	conn, err := ssh.Dial("tcp", host+":"+port, config)
	if err != nil {
		log.Print(err)
		return
	}
	defer conn.Close()

	backupSession, err := conn.NewSession()
	if err != nil {
		log.Print(err)
		return
	}
	remoteCmd(backupQuery, backupSession)

	downloadSession, err := conn.NewSession()
	if err != nil {
		log.Print(err)
		return
	}
	remoteCmd(downloadQuery, downloadSession)

	log.Print("done")
}

func remoteCmd(query string, session *ssh.Session) {

	defer session.Close()

	//リモートの標準出力をローカルの標準出力へ
	//session.Stdout = os.Stdout

	f, _ := os.Create("test.sql")
	session.Stdout = f
	session.Stderr = os.Stderr

	/*
		RunはWait付き。StartはWait無し
		出力はsessionのStdio,Stderr
		sessionに付きコマンドは1度
	*/

	if err := session.Run(query); err != nil {
		log.Print(err)
		return
	}

}

package main

import (

"io/ioutil"

"log"

"os"

"golang.org/x/crypto/ssh"

)

func main() {

host := ""

port := ""

user := ""

backupQuery := "mysqldumpする"

downloadQuery := "catする"

buf, err := ioutil.ReadFile("id_rsa.pem") //openssl rsa -in ~/.ssh/id_rsa -outform pem > id_rsa.pem

if err != nil {

log.Print(err)

return

}

key, err := ssh.ParsePrivateKey(buf)

if err != nil {

log.Print(err)

return

}

config := &ssh.ClientConfig{

User: user,

Auth: []ssh.AuthMethod{

ssh.PublicKeys(key),

HostKeyCallback: ssh.InsecureIgnoreHostKey(),

}

conn, err := ssh.Dial("tcp", host+":"+port, config)

if err != nil {

log.Print(err)

return

}

defer conn.Close()

backupSession, err := conn.NewSession()

if err != nil {

log.Print(err)

return

}

remoteCmd(backupQuery, backupSession)

downloadSession, err := conn.NewSession()

if err != nil {

log.Print(err)

return

}

remoteCmd(downloadQuery, downloadSession)

log.Print("done")

}

func remoteCmd(query string, session *ssh.Session) {

defer session.Close()

//リモートの標準出力をローカルの標準出力へ

//session.Stdout = os.Stdout

f, _ := os.Create("test.sql")

session.Stdout = f

session.Stderr = os.Stderr

RunはWait付き。StartはWait無し

出力はsessionのStdio,Stderr

sessionに付きコマンドは1度

if err := session.Run(query); err != nil {

log.Print(err)

return

}

2018-10-022020-05-06

golang色々

静的ファイル配信。jsonパース

package main

import (
	"encoding/json"

	"io/ioutil"
	"log"
	"net/http"
	"os"
	"path/filepath"
)

func main() {

	//静的ファイル配信

	//http.Dirはhttp://foo:bar/のようなクエリのないURLがローカルのどのパス(root)となるかという意味
	//http://foo:bar/aaaのような指定の場合/aaaもローカルパスに必要となる。

	currentPath, _ := os.Executable()
	localRoot := filepath.Dir(currentPath)
	remoteRoot := http.Dir(localRoot)

	http.Handle("/", http.FileServer(remoteRoot))

	//パスを変更する場合
	//http.Handle("/html/", http.StripPrefix("/html/", http.FileServer(remoteRoot)))

	//リクエスト処理

	http.HandleFunc("/read", read)

	if err := http.ListenAndServe(":9000", nil); err != nil {
		log.Fatal(err)
	}
}

var dt interface{}

/*

type DataFormat struct {
	RequestID string
}

のように構造体を宣言し、インスタンスでjson.Unmarshalを受ける。

dt := DataFormat{}

*/

func read(w http.ResponseWriter, r *http.Request) {

	if r.Method != http.MethodPost {
		w.WriteHeader(http.StatusServiceUnavailable)
		return
	}

	/*

		json.Unmarshal(data []byte, v interface{}) error
		でjsonを受け取る

		io.Readerから[]byteに変換

		ioutil.ReadAll(io.Reader) ([]bytes, error)
		bytes.Buffer.ReadFrom(io.Reader) (int64, error)
		io.Copy(io.Writer, io.Reader) (int64, error)

	*/

	body, err := ioutil.ReadAll(r.Body)
	if err != nil {
		w.WriteHeader(http.StatusServiceUnavailable)
		log.Print(err)
		return
	}

	if err := json.Unmarshal(body, &dt); err != nil {
		w.WriteHeader(http.StatusServiceUnavailable)
		log.Print(err)
		return
	}

	//dtはinterface型で実際はmap型

	/*

		jsonがネストしていない場合アサーションのみで取り出せる。

		d := dt.(map[string]interface{})
		log.Print(d["main"])
		log.Print(reflect.TypeOf(d)) -> map[string]interface {}

		全体が配列のjsonなら以下のように取り出せる
		配列は[]interface{}のrangeで処理

		for _, aa := range dt.([]interface{}) {
			for cc, bb := range aa.(map[string]interface{}) {
				log.Print(cc)
				log.Print(bb)
			}
		}

		中で配列ネストされているような場合

		for k, v := range dt.(map[string]interface{}) {

			log.Print("1:", k) //jsonのkeyが入る
			log.Print("2:", v) //jsonのvalueが入る

			//vとvvは同じ値で型のtypeOfが入るのではない
			switch vv := v.(type) {
			case []interface{}:
				for _, y := range vv {
					yy := y.(map[string]interface{})
					log.Print("3:", yy["ID"])
					log.Print("4:", yy["名称"])
				}
			default:
				log.Print("5:", v)
			}
		}

	*/

	w.Header().Set("content-type", "application/json;charset=UTF-8")
	w.WriteHeader(http.StatusOK)

	if err := json.NewEncoder(w).Encode(dt); err != nil {
		w.WriteHeader(http.StatusServiceUnavailable)
		log.Print(err)
		return
	}
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

package main

import (

"encoding/json"

"io/ioutil"

"log"

"net/http"

"os"

"path/filepath"

)

func main() {

//静的ファイル配信

//http.Dirはhttp://foo:bar/のようなクエリのないURLがローカルのどのパス(root)となるかという意味

//http://foo:bar/aaaのような指定の場合/aaaもローカルパスに必要となる。

currentPath, _ := os.Executable()

localRoot := filepath.Dir(currentPath)

remoteRoot := http.Dir(localRoot)

http.Handle("/", http.FileServer(remoteRoot))

//パスを変更する場合

//http.Handle("/html/", http.StripPrefix("/html/", http.FileServer(remoteRoot)))

//リクエスト処理

http.HandleFunc("/read", read)

if err := http.ListenAndServe(":9000", nil); err != nil {

log.Fatal(err)

}

var dt interface{}

type DataFormat struct {

RequestID string

}

のように構造体を宣言し、インスタンスでjson.Unmarshalを受ける。

dt := DataFormat{}

func read(w http.ResponseWriter, r *http.Request) {

if r.Method != http.MethodPost {

w.WriteHeader(http.StatusServiceUnavailable)

return

}

json.Unmarshal(data []byte, v interface{}) error

でjsonを受け取る

io.Readerから[]byteに変換

ioutil.ReadAll(io.Reader) ([]bytes, error)

bytes.Buffer.ReadFrom(io.Reader) (int64, error)

io.Copy(io.Writer, io.Reader) (int64, error)

body, err := ioutil.ReadAll(r.Body)

if err != nil {

w.WriteHeader(http.StatusServiceUnavailable)

log.Print(err)

return

}

if err := json.Unmarshal(body, &dt); err != nil {

w.WriteHeader(http.StatusServiceUnavailable)

log.Print(err)

return

}

//dtはinterface型で実際はmap型

jsonがネストしていない場合アサーションのみで取り出せる。

d := dt.(map[string]interface{})

log.Print(d["main"])

log.Print(reflect.TypeOf(d)) -> map[string]interface {}

全体が配列のjsonなら以下のように取り出せる

配列は[]interface{}のrangeで処理

for _, aa := range dt.([]interface{}) {

for cc, bb := range aa.(map[string]interface{}) {

log.Print(cc)

log.Print(bb)

}

中で配列ネストされているような場合

for k, v := range dt.(map[string]interface{}) {

log.Print("1:", k) //jsonのkeyが入る

log.Print("2:", v) //jsonのvalueが入る

//vとvvは同じ値で型のtypeOfが入るのではない

switch vv := v.(type) {

case []interface{}:

for _, y := range vv {

yy := y.(map[string]interface{})

log.Print("3:", yy["ID"])

log.Print("4:", yy["名称"])

}

default:

log.Print("5:", v)

}

w.Header().Set("content-type", "application/json;charset=UTF-8")

w.WriteHeader(http.StatusOK)

if err := json.NewEncoder(w).Encode(dt); err != nil {

w.WriteHeader(http.StatusServiceUnavailable)

log.Print(err)

return

}